From f87c73bc1e33efd8b61c4daae71e2ebd3ef6d8b8 Mon Sep 17 00:00:00 2001 From: kenanfarukcakir Date: Tue, 6 Aug 2024 12:36:57 +0000 Subject: [PATCH] add env var for alive conn send --- aggregator/data.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/aggregator/data.go b/aggregator/data.go index abb99ea..6303a7b 100644 --- a/aggregator/data.go +++ b/aggregator/data.go @@ -1573,18 +1573,20 @@ func (a *Aggregator) sendOpenConnection(sl *SocketLine) { } } -// TODO: connection send is made here, sendOpenConnection must be called, refactor this func and its calling place func (a *Aggregator) clearSocketLines(ctx context.Context) { ticker := time.NewTicker(120 * time.Second) skLineCh := make(chan *SocketLine, 1000) + sendAliveConnections, _ := strconv.ParseBool(os.Getenv("SEND_ALIVE_TCP_CONNECTIONS")) go func() { // spawn N goroutines to clear socket map for i := 0; i < 10; i++ { go func() { for skLine := range skLineCh { // send open connections to datastore - a.sendOpenConnection(skLine) + if sendAliveConnections { + a.sendOpenConnection(skLine) + } // clear socket history skLine.DeleteUnused() }