fix timemachine lock (#3767)

* refactor without label
* fix the deadlock

Author: sabban

cmd/crowdsec/output.go

@@ -70,7 +70,8 @@ func runOutput(input chan types.Event, overflow chan types.Event, buckets *leaky
 	)
 
 	ticker := time.NewTicker(1 * time.Second)
-LOOP:
+	defer ticker.Stop()
+
 	for {
 		select {
 		case <-ticker.C:
@@ -97,8 +98,7 @@ LOOP:
 					log.Errorf("while pushing leftovers to api : %s", err)
 				}
 			}
-
-			break LOOP
+			return nil
 		case event := <-overflow:
 			/*if alert is empty and mapKey is present, the overflow is just to cleanup bucket*/
 			if event.Overflow.Alert == nil && event.Overflow.Mapkey != "" {
@@ -125,7 +125,12 @@ LOOP:
 			}
 			if event.Overflow.Reprocess {
 				log.Debugf("Overflow being reprocessed.")
-				input <- event
+				select {
+				case input <- event:
+					log.Debugf("reprocessing overflow event")
+				case <-parsersTomb.Dead():
+					log.Debugf("parsing is dead, skipping")
+				}
 			}
 			if dumpStates {
 				continue
@@ -136,8 +141,4 @@ LOOP:
 			cacheMutex.Unlock()
 		}
 	}
-
-	ticker.Stop()
-
-	return nil
 }