Removed/refactored locking in splunk forward success flow.

Financial-Times · Jul 6, 2018 · 7a87041 · 7a87041
1 parent 67efee1
commit 7a87041
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/processor.go b/processor.go
@@ -57,13 +57,13 @@ func (logProcessor *logProcessor) Start() {
 					if err != nil {
 						// cache again and retry later
 						logProcessor.Enqueue(s)
-					} else {
-					}
-					mutex.Lock()
-					if err != nil && level < maxBackoff {
-						levelUp = true
+
+						mutex.Lock()
+						if level < maxBackoff {
+							levelUp = true
+						}
+						mutex.Unlock()
 					}
-					mutex.Unlock()
 				})
 			}
 		}()