diff --git a/log/input.go b/log/input.go index dd0b293..609cff0 100644 --- a/log/input.go +++ b/log/input.go @@ -93,7 +93,10 @@ func log(level Severity, msg string, tracer *ContextTracer) { // wake up writer if necessary if logsWaitingFlag.SetToIf(false, true) { - logsWaiting <- struct{}{} + select { + case logsWaiting <- struct{}{}: + default: + } } } diff --git a/log/logging.go b/log/logging.go index 4000df4..fe777ab 100644 --- a/log/logging.go +++ b/log/logging.go @@ -109,7 +109,7 @@ var ( pkgLevels = make(map[string]Severity) pkgLevelsLock sync.Mutex - logsWaiting = make(chan struct{}, 4) + logsWaiting = make(chan struct{}, 1) logsWaitingFlag = abool.NewBool(false) shutdownFlag = abool.NewBool(false)