Skip to content

Commit 4bbd5b4

Browse files
committed
Refine allocation of channel capacity for internal udpip processor
1 parent f5f0d3d commit 4bbd5b4

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

router/underlayproviders/udpip/udpip.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -846,7 +846,13 @@ func (l *internalLink) start(
846846
procQs []chan *router.Packet,
847847
pool router.PacketPool,
848848
) {
849-
l.procQ = make(chan *router.Packet, cap(procQs[0]))
849+
maxCap := 0
850+
for _, q := range procQs {
851+
if cap(q) > maxCap {
852+
maxCap = cap(q)
853+
}
854+
}
855+
l.procQ = make(chan *router.Packet, maxCap)
850856
l.procStop = make(chan struct{})
851857
l.procDone = make(chan struct{})
852858

0 commit comments

Comments
 (0)