Add error log when negative refCount is detected

dricross · dricross · commit 28f8316b2c7f · 2025-09-10T08:20:17.000-04:00
diff --git a/plugins/outputs/cloudwatchlogs/cloudwatchlogs.go b/plugins/outputs/cloudwatchlogs/cloudwatchlogs.go
@@ -279,6 +279,10 @@ func (cd *cwDest) NotifySourceStopped() {
 	if cd.refCount <= 0 {
 		cd.stop()
 	}
+
+	if cd.refCount < 0 {
+		fmt.Printf("E! Negative refCount on cwDest detected. refCount: %d, logGroup: %s, logStream: %s", cd.refCount, cd.pusher.Group, cd.pusher.Stream)
+	}
 }
 
 func (cd *cwDest) Stop() {

Original file line number	Diff line number	Diff line change
`@@ -279,6 +279,10 @@ func (cd *cwDest) NotifySourceStopped() {`
`279`	`279`	`if cd.refCount <= 0 {`
`280`	`280`	`cd.stop()`
`281`	`281`	`}`
	`282`	`+`
	`283`	`+ if cd.refCount < 0 {`
	`284`	`+ fmt.Printf("E! Negative refCount on cwDest detected. refCount: %d, logGroup: %s, logStream: %s", cd.refCount, cd.pusher.Group, cd.pusher.Stream)`
	`285`	`+ }`
`282`	`286`	`}`
`283`	`287`
`284`	`288`	`func (cd *cwDest) Stop() {`