Skip select if drainEvents

Signed-off-by: JamesJJ <[email protected]>

Author: JamesJJ

fluent/fluent.go

@@ -356,13 +356,6 @@ func (f *Fluent) run() {
 	drainEvents := false
 	var emitEventDrainMsg sync.Once
 	for {
-		select {
-		case stopRunning, ok := <-f.stopRunning:
-			if stopRunning || !ok {
-				drainEvents = true
-			}
-		default:
-		}
 		select {
 		case entry, ok := <-f.pending:
 			if !ok {
@@ -378,6 +371,13 @@ func (f *Fluent) run() {
 				fmt.Fprintf(os.Stderr, "[%s] Unable to send logs to fluentd, reconnecting...\n", time.Now().Format(time.RFC3339))
 			}
 		}
+		select {
+		case stopRunning, ok := <-f.stopRunning:
+			if stopRunning || !ok {
+				drainEvents = true
+			}
+		default:
+		}
 	}
 }