downstream: fixed the event loop registration detection mechanism

Leonardo Alminana · edsiper · commit 52f370bff07a · 2023-07-02T19:38:48.000-06:00
Signed-off-by: Leonardo Alminana &lt;leonardo@calyptia.com&gt;
diff --git a/src/flb_downstream.c b/src/flb_downstream.c
@@ -188,7 +188,7 @@ static int prepare_destroy_conn(struct flb_connection *connection)
     flb_trace("[downstream] destroy connection #%i to %s",
               connection->fd, flb_connection_get_remote_address(connection));
 
-    if (stream->flags & FLB_IO_ASYNC) {
+    if(MK_EVENT_IS_REGISTERED((&connection->event))) {
         mk_event_del(connection->evl, &connection->event);
     }
 

Original file line number	Diff line number	Diff line change
`@@ -188,7 +188,7 @@ static int prepare_destroy_conn(struct flb_connection *connection)`
`188`	`188`	`flb_trace("[downstream] destroy connection #%i to %s",`
`189`	`189`	`connection->fd, flb_connection_get_remote_address(connection));`
`190`	`190`
`191`		`- if (stream->flags & FLB_IO_ASYNC) {`
	`191`	`+ if(MK_EVENT_IS_REGISTERED((&connection->event))) {`
`192`	`192`	`mk_event_del(connection->evl, &connection->event);`
`193`	`193`	`}`
`194`	`194`