assemblers: remove unused tcp stream waitgroup

Signed-off-by: Dan Bond <danbond@protonmail.com>
honeycombio · Oct 29, 2023 · 2e039ad · 2e039ad
1 parent fe2ebd3
commit 2e039ad
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 9 deletions.
diff --git a/assemblers/tcp_assembler.go b/assemblers/tcp_assembler.go
@@ -190,7 +190,6 @@ func (h *tcpAssembler) Stop() {
 		h.streamPool.Dump()
 	}
 
-	h.streamFactory.WaitGoRoutines()
 	h.logAssemblerStats()
 	log.Debug().
 		Int("closed", closed).

diff --git a/assemblers/tcp_stream_factory.go b/assemblers/tcp_stream_factory.go
@@ -1,18 +1,16 @@
 package assemblers
 
 import (
-	"sync"
-
 	"github.com/gopacket/gopacket"
 	"github.com/gopacket/gopacket/layers"
 	"github.com/gopacket/gopacket/reassembly"
-	"github.com/honeycombio/honeycomb-network-agent/config"
 	"github.com/rs/zerolog/log"
+
+	"github.com/honeycombio/honeycomb-network-agent/config"
 )
 
 type tcpStreamFactory struct {
 	config     config.Config
-	wg         sync.WaitGroup
 	eventsChan chan Event
 }
 
@@ -31,7 +29,3 @@ func (factory *tcpStreamFactory) New(net, transport gopacket.Flow, tcp *layers.T
 	IncrementActiveStreamCount()
 	return NewTcpStream(net, transport, factory.config, factory.eventsChan)
 }
-
-func (factory *tcpStreamFactory) WaitGoRoutines() {
-	factory.wg.Wait()
-}