coverage-sweep 5/6: bug-fix wave A (Bug 27–51 + regression tests)#22

Merged

randomizedcoder merged 30 commits into

mainfrom

bugfix-wave-a

Jun 15, 2026

Commits on Jun 14, 2026

Fix two netlinker syscall-path bugs (#25, #26)

randomizedcoder
and
claude
committed
Bug 27: getLatestSchemaID had no timeout and ignored ctx

randomizedcoder
and
claude
committed
Bug 28: kafkaDest.Close dropped in-flight records (no Flush)

randomizedcoder
and
claude
committed
Bug 29: getLatestSchemaIDAt silently returned id:0 on 4xx/5xx

randomizedcoder
and
claude
committed
Bug 30: kafka_to_clickhouse getLatestSchemaIDAt same 4xx/5xx → id:0

randomizedcoder
and
claude
committed
Bug 31: clickhouse insert wrong FORMAT for envelope=true (default)

randomizedcoder
and
claude
committed
Bug 32: pollStreamRecv spun CPU on persistent stream errors

randomizedcoder
and
claude
committed
Bug 33: handleRecvCQE nil-deref on orphan CQEs

randomizedcoder
and
claude
committed
Bug 34: runReceiver hung on shutdown — ReadFromUDP isn't ctx-aware

randomizedcoder
and
claude
committed
Bug 35: handleRecord cross-contaminated decoded records (no Reset)

randomizedcoder
and
claude
committed
Bug 36: udp_receiver_server runReceiver same proto.Reset miss

randomizedcoder
and
claude
committed
Bug 37: pollAllNetlinkSockets miscounted polled fds (off-by-1 from xtcpNS)

randomizedcoder
and
claude
committed
Bug 38: checkDirectoryExists nil-deref on non-not-exist Stat errors

randomizedcoder
and
claude
committed
Bug 39: SOCKOPT attribute used DeserializeCGroupIDXTCP placeholder

randomizedcoder
and
claude
committed
Bug 40: netNamespaceInstance leaked one fd + goroutine per nsDelete

randomizedcoder
and
claude
committed
Bug 41: reconcileMaps leaked netlinkers + fd on backstop deletes

randomizedcoder
and
claude
committed
Bug 42: stream() spun CPU on io.EOF — should break, not continue

randomizedcoder
and
claude
committed
Bug 43: kafka_to_clickhouse primaryFunction sleep ignored ctx

randomizedcoder
and
claude
committed
Bug 44: SetPollFrequency could wedge gRPC handler forever

randomizedcoder
and
claude
committed
Bug 45: PollFlatRecords blocking send wedged gRPC stream handler

randomizedcoder
and
claude
committed
Bug 46: encodeLengthDelimitedProtobufList dropped varint return value

randomizedcoder
and
claude
committed
Bug 47: Ring.Close leaked in-flight buffers when drain deadline expired

randomizedcoder
and
claude
committed
Bug 48: netlinkerIoUring log.Fatalf paths killed whole daemon

randomizedcoder
and
claude
committed
Bug 49: setSocketTimeoutViaSyscall log.Fatalf killed whole daemon

randomizedcoder
and
claude
committed
Bug 50: BBRv2/v3 congestion records mis-labelled as BBRv1

randomizedcoder
and
claude
committed
Test: consolidate CongInfoXTCP dispatch tests into one table-driven case

randomizedcoder
and
claude
committed
Bug 51: dialWithRetry off-by-one + non-positive-attempts pretty-print

randomizedcoder
and
claude
committed
Test: table-driven TestAtoiOr0 + TestBytesIndex

randomizedcoder
and
claude
committed
Test: regression tests for bug 41 reconcileMaps cancel-on-delete

randomizedcoder
and
claude
committed
gofmt: format quality-report main_test.go (pulled forward from later in layer)

randomizedcoder
and
claude
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

coverage-sweep 5/6: bug-fix wave A (Bug 27–51 + regression tests)#22

coverage-sweep 5/6: bug-fix wave A (Bug 27–51 + regression tests)#22
randomizedcoder merged 30 commits into
mainfrom
bugfix-wave-a

Commits on Jun 14, 2026

Fix two netlinker syscall-path bugs (#25, #26)

Bug 27: getLatestSchemaID had no timeout and ignored ctx

Bug 28: kafkaDest.Close dropped in-flight records (no Flush)

Bug 29: getLatestSchemaIDAt silently returned id:0 on 4xx/5xx

Bug 30: kafka_to_clickhouse getLatestSchemaIDAt same 4xx/5xx → id:0

Bug 31: clickhouse insert wrong FORMAT for envelope=true (default)

Bug 32: pollStreamRecv spun CPU on persistent stream errors

Bug 33: handleRecvCQE nil-deref on orphan CQEs

Bug 34: runReceiver hung on shutdown — ReadFromUDP isn't ctx-aware

Bug 35: handleRecord cross-contaminated decoded records (no Reset)

Bug 36: udp_receiver_server runReceiver same proto.Reset miss

Bug 37: pollAllNetlinkSockets miscounted polled fds (off-by-1 from xtcpNS)

Bug 38: checkDirectoryExists nil-deref on non-not-exist Stat errors

Bug 39: SOCKOPT attribute used DeserializeCGroupIDXTCP placeholder

Bug 40: netNamespaceInstance leaked one fd + goroutine per nsDelete

Bug 41: reconcileMaps leaked netlinkers + fd on backstop deletes

Bug 42: stream() spun CPU on io.EOF — should break, not continue

Bug 43: kafka_to_clickhouse primaryFunction sleep ignored ctx

Bug 44: SetPollFrequency could wedge gRPC handler forever

Bug 45: PollFlatRecords blocking send wedged gRPC stream handler

Bug 46: encodeLengthDelimitedProtobufList dropped varint return value

Bug 47: Ring.Close leaked in-flight buffers when drain deadline expired

Bug 48: netlinkerIoUring log.Fatalf paths killed whole daemon

Bug 49: setSocketTimeoutViaSyscall log.Fatalf killed whole daemon

Bug 50: BBRv2/v3 congestion records mis-labelled as BBRv1

Test: consolidate CongInfoXTCP dispatch tests into one table-driven case

Bug 51: dialWithRetry off-by-one + non-positive-attempts pretty-print

Test: table-driven TestAtoiOr0 + TestBytesIndex

Test: regression tests for bug 41 reconcileMaps cancel-on-delete

gofmt: format quality-report main_test.go (pulled forward from later in layer)