Skip to content

Commit 90048b2

Browse files
committed
ipn/wg: m logs for batch writes
1 parent 4359e0b commit 90048b2

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

intra/ipn/wg/wgconn2.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -624,7 +624,7 @@ retry:
624624
}
625625
// send all msgs
626626
err = s.send(c, br, (*msgs)[:len(bufs)])
627-
loge(err)("wg: bind2: %s send(%d) to %s (retry? %t); err(%v)", s.id, len(bufs), ua, retried, err)
627+
loge(err)("wg: bind2: %s GSO: send(%d) to %s (retry? %t); err(%v)", s.id, len(bufs), ua, retried, err)
628628
}
629629
if retried {
630630
x := zeroaddr
@@ -640,7 +640,8 @@ retry:
640640
func (s *StdNetBind2) send(conn *net.UDPConn, pc batchWriter, msgs []ipv6.Message) (err error) {
641641
var n, start int
642642

643-
if pc != nil && core.IsNotNil(pc) {
643+
batch := pc != nil && core.IsNotNil(pc)
644+
if batch {
644645
for {
645646
n, err = pc.WriteBatch(msgs[start:], 0)
646647
if err != nil || n == len(msgs[start:]) {
@@ -660,9 +661,10 @@ func (s *StdNetBind2) send(conn *net.UDPConn, pc batchWriter, msgs []ipv6.Messag
660661
log.E("wg: bind2: %s send: to %v; err %v", s.id, addr, err)
661662
break
662663
}
664+
n += 1
663665
}
664666
}
665-
loge(err)("wg: bind2: %s send: n(%d); err? %v", s.id, n, err)
667+
loge(err)("wg: bind2: %s send: batch? %t; n(%d); err? %v", s.id, batch, n, err)
666668
return err
667669
}
668670

0 commit comments

Comments
 (0)