Improve logging control flow

safing · Nov 4, 2022 · f6f644f · f6f644f
1 parent 70b5813
commit f6f644f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git 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
@@ -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)