From 86f41c802745fc62e1b102bde897cb61dfa52ca9 Mon Sep 17 00:00:00 2001 From: Matthew Penner Date: Sat, 22 Jan 2022 10:18:13 -0700 Subject: [PATCH] server: remove Push timeout from sinkPool --- server/sink.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/server/sink.go b/server/sink.go index 908748e..9a1835a 100644 --- a/server/sink.go +++ b/server/sink.go @@ -2,7 +2,6 @@ package server import ( "sync" - "time" ) // sinkPool represents a pool with sinks. @@ -60,12 +59,9 @@ func (p *sinkPool) Destroy() { func (p *sinkPool) Push(v []byte) { p.mx.RLock() for _, c := range p.sinks { - // TODO: should this be done in parallel? select { // Send the log output to the channel case c <- v: - // Timeout after 100 milliseconds, this will cause the write to the channel to be cancelled. - case <-time.After(100 * time.Millisecond): } } p.mx.RUnlock()