cshared: Handle already closed case

Signed-off-by: Hiroshi Hatake <[email protected]>
chronosphereio · Oct 26, 2023 · 96c0484 · 96c0484
1 parent f3c8347
commit 96c0484
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cshared.go b/cshared.go
@@ -168,6 +168,12 @@ func FLBPluginInit(ptr unsafe.Pointer) int {
 func flbPluginReset() {
 	theInputLock.Lock()
 	defer theInputLock.Unlock()
+	defer func() {
+		if ret := recover(); ret != nil {
+			fmt.Fprintf(os.Stderr, "Channel is already closed")
+			return
+		}
+	}()
 
 	once = sync.Once{}
 	close(theChannel)