wip

sparrc · sparrc · commit dbfba041b860 · 2025-11-05T14:57:20.000-08:00
diff --git a/plugins/in_forward/fw_prot.c b/plugins/in_forward/fw_prot.c
@@ -1551,6 +1551,13 @@ int fw_prot_process(struct flb_input_instance *ins, struct fw_conn *conn)
                         flb_sds_destroy(out_tag);
                         return 0;
                     }
+                    if (conn->being_deleted) {
+                        pthread_mutex_unlock(&ctx->conn_mutex);
+                        msgpack_unpacked_destroy(&result);
+                        msgpack_unpacker_free(unp);
+                        flb_sds_destroy(out_tag);
+                        return 0;
+                    }
                     pthread_mutex_unlock(&ctx->conn_mutex);
                 }
             }

Original file line number	Diff line number	Diff line change
`@@ -1551,6 +1551,13 @@ int fw_prot_process(struct flb_input_instance ins, struct fw_conn conn)`
`1551`	`1551`	`flb_sds_destroy(out_tag);`
`1552`	`1552`	`return 0;`
`1553`	`1553`	`}`
	`1554`	`+ if (conn->being_deleted) {`
	`1555`	`+ pthread_mutex_unlock(&ctx->conn_mutex);`
	`1556`	`+ msgpack_unpacked_destroy(&result);`
	`1557`	`+ msgpack_unpacker_free(unp);`
	`1558`	`+ flb_sds_destroy(out_tag);`
	`1559`	`+ return 0;`
	`1560`	`+ }`
`1554`	`1561`	`pthread_mutex_unlock(&ctx->conn_mutex);`
`1555`	`1562`	`}`
`1556`	`1563`	`}`