Merge pull request #276 from shubhamcoc/log_race_bugfix

fix: added mutex lock and unlock around read to logger struct for con…
influxdata · Sep 16, 2021 · 18cfd3d · 18cfd3d
2 parents cd0d5b4 + d715542
commit 18cfd3d
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/log/logger.go b/log/logger.go
@@ -74,42 +74,58 @@ func (l *logger) SetPrefix(prefix string) {
 }
 
 func (l *logger) Debugf(format string, v ...interface{}) {
+	l.lock.Lock()
 	if l.logLevel >= DebugLevel {
 		log.Print(l.prefix, " D! ", fmt.Sprintf(format, v...))
 	}
+	l.lock.Unlock()
 }
 func (l *logger) Debug(msg string) {
+	l.lock.Lock()
 	if l.logLevel >= DebugLevel {
 		log.Print(l.prefix, " D! ", msg)
 	}
+	l.lock.Unlock()
 }
 
 func (l *logger) Infof(format string, v ...interface{}) {
+	l.lock.Lock()
 	if l.logLevel >= InfoLevel {
 		log.Print(l.prefix, " I! ", fmt.Sprintf(format, v...))
 	}
+	l.lock.Unlock()
 }
 func (l *logger) Info(msg string) {
+	l.lock.Lock()
 	if l.logLevel >= DebugLevel {
 		log.Print(l.prefix, " I! ", msg)
 	}
+	l.lock.Unlock()
 }
 
 func (l *logger) Warnf(format string, v ...interface{}) {
+	l.lock.Lock()
 	if l.logLevel >= WarningLevel {
 		log.Print(l.prefix, " W! ", fmt.Sprintf(format, v...))
 	}
+	l.lock.Unlock()
 }
 func (l *logger) Warn(msg string) {
+	l.lock.Lock()
 	if l.logLevel >= WarningLevel {
 		log.Print(l.prefix, " W! ", msg)
 	}
+	l.lock.Unlock()
 }
 
 func (l *logger) Errorf(format string, v ...interface{}) {
+	l.lock.Lock()
 	log.Print(l.prefix, " E! ", fmt.Sprintf(format, v...))
+	l.lock.Unlock()
 }
 
 func (l *logger) Error(msg string) {
+	l.lock.Lock()
 	log.Print(l.prefix, " [E]! ", msg)
+	l.lock.Unlock()
 }