Skip to content

Commit fc80b7e

Browse files
committed
Fix packet to queue assignment for internal udpip link
1 parent 4bbd5b4 commit fc80b7e

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

router/underlayproviders/udpip/udpip.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1024,9 +1024,9 @@ func (l *internalLink) receive(size int, srcAddr *net.UDPAddr, p *router.Packet)
10241024
var q chan *router.Packet
10251025
procID, ok := computeProcID(p.RawPacket, len(l.procQs), l.seed)
10261026
if ok {
1027-
q = l.procQ
1028-
} else {
10291027
q = l.procQs[procID]
1028+
} else {
1029+
q = l.procQ
10301030
}
10311031
select {
10321032
case q <- p:

0 commit comments

Comments
 (0)