From 68092b184451921cf1b71bfb7a2f5728b1332351 Mon Sep 17 00:00:00 2001 From: Viktor Liu Date: Tue, 14 Apr 2026 17:28:46 +0200 Subject: [PATCH] Close leaked connection when Stop races with reconnect --- client/internal/netflow/conntrack/conntrack.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/client/internal/netflow/conntrack/conntrack.go b/client/internal/netflow/conntrack/conntrack.go index 2788d89e6..259f5e37e 100644 --- a/client/internal/netflow/conntrack/conntrack.go +++ b/client/internal/netflow/conntrack/conntrack.go @@ -180,6 +180,14 @@ func (c *ConnTrack) reconnect() (chan nfct.Event, chan error) { } c.mux.Lock() + if !c.started { + // Stop() ran while we were reconnecting. + c.mux.Unlock() + if closeErr := conn.Close(); closeErr != nil { + log.Debugf("close conntrack connection: %v", closeErr) + } + return nil, nil + } c.conn = conn c.mux.Unlock()