Merge pull request #28 from calyptia/fix-high-cpu-contention

cshared: free the input buffer in a cleanup callback.
chronosphereio · Jan 16, 2023 · f98583e · f98583e
2 parents e67c8ea + 1d7a2a4
commit f98583e
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/cshared.go b/cshared.go
@@ -170,6 +170,13 @@ func FLBPluginInputCallback(data *unsafe.Pointer, csize *C.size_t) int {
 	return input.FLB_OK
 }
 
+// FLBPluginInputCleanupCallback releases the memory used during the input callback
+//export FLBPluginInputCleanupCallback
+func FLBPluginInputCleanupCallback(data unsafe.Pointer) int {
+	C.free(data)
+	return input.FLB_OK
+}
+
 // FLBPluginFlush callback gets invoked by the fluent-bit runtime once there is data for the corresponding
 // plugin in the pipeline, a data pointer, length and a tag are passed to the plugin interface implementation.
 //export FLBPluginFlush