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

overlay/batch: remove end-of-batch debug scaffolding

Browse Source 
The Warn("==== end of batch ====") delimiter (and the `logged` flag that
fed it) was left over from debugging the cross-slot gap logging.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
This commit is contained in:
JackDoan
2026-07-27 15:26:45 -05:00
parent be35d4f059
commit c06bfb46be
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
overlay/batch/tcp_coalesce.go
-5
View File
@@ -450,7 +450,6 @@ func (c *TCPCoalescer) reorderForFlush() {
runStart = i + 1 runStart = i + 1
} }
out := c.slots[:0] out := c.slots[:0]
logged := false
for _, s := range c.slots { for _, s := range c.slots {
if n := len(out); n > 0 { if n := len(out); n > 0 {
prev := out[n-1] prev := out[n-1]
@@ -463,7 +462,6 @@ func (c *TCPCoalescer) reorderForFlush() {
// gap via its OOO queue. // gap via its OOO queue.
if c.l.Enabled(context.Background(), slog.LevelDebug) { if c.l.Enabled(context.Background(), slog.LevelDebug) {
if prev.nextSeq != slotSeedSeq(s) { if prev.nextSeq != slotSeedSeq(s) {
logged = true
gap := int64(slotSeedSeq(s)) - int64(prev.nextSeq) gap := int64(slotSeedSeq(s)) - int64(prev.nextSeq)
c.l.Debug("tcp coalesce: cross-slot seq gap", c.l.Debug("tcp coalesce: cross-slot seq gap",
"src", flowKeyAddr(s.fk, false), "src", flowKeyAddr(s.fk, false),
@@ -489,9 +487,6 @@ func (c *TCPCoalescer) reorderForFlush() {
} }
out = append(out, s) out = append(out, s)
} }
if logged {
c.l.Warn("==== end of batch ====")
}
c.slots = out c.slots = out
} }