personal_interest_mirrors/nebula
1
0
Fork 0
mirror of https://github.com/slackhq/nebula.git synced 2026-08-15 10:36:57 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

udp: downgrade the per-batch sendmmsg failure log to debug

Browse Source
This commit is contained in:
JackDoan
2026-07-27 15:32:31 -05:00
parent eea3c81626
commit be35d4f059
1 changed files with 16 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files
udp/udp_linux_writebatch.go
+16 -13
View File
@@ -3,6 +3,7 @@
package udp
import (
"context"
"encoding/binary"
"errors"
"fmt"
@@ -324,19 +325,21 @@ sendChunks:
if ecns != nil {
ecn0 = ecns[baseI]
}
w.l.Warn("sendmmsg had problem",
"sent", sent, "err", serr,
"entries", entry,
"entry0_runLen", runLen0,
"entry0_segSize", seg0,
"entry0_iovlen", hdr0.Iovlen,
"entry0_controllen", hdr0.Controllen,
"entry0_namelen", hdr0.Namelen,
"entry0_ecn", ecn0,
"entry0_dst", addrs[baseI],
"isV4", w.isV4,
"gso", w.gsoSupported,
)
if w.l.Enabled(context.Background(), slog.LevelDebug) {
w.l.Debug("sendmmsg had problem",
"sent", sent, "err", serr,
"entries", entry,
"entry0_runLen", runLen0,
"entry0_segSize", seg0,
"entry0_iovlen", hdr0.Iovlen,
"entry0_controllen", hdr0.Controllen,
"entry0_namelen", hdr0.Namelen,
"entry0_ecn", ecn0,
"entry0_dst", addrs[baseI],
"isV4", w.isV4,
"gso", w.gsoSupported,
)
}
for k := baseI; k < i; k++ {
if werr := sendto(w.fd, bufs[k], addrs[k], w.isV4); werr == nil {
written++