io: use connection flags when setting async in flb_io_net_connect.

pwhelan · AndrewChubatiuk · commit 49b466ae00fa · 2024-09-24T15:42:18.000+03:00
Signed-off-by: Phillip Adair Stewart Whelan &lt;phillip.whelan@chronosphere.io&gt;
diff --git a/src/flb_io.c b/src/flb_io.c
@@ -109,6 +109,7 @@ int flb_io_net_connect(struct flb_connection *connection,
     int ret;
     int async = FLB_FALSE;
     flb_sockfd_t fd = -1;
+    int flags = flb_connection_get_flags(connection);
     // struct flb_upstream *u = u_conn->u;
 
     if (connection->fd > 0) {
@@ -119,7 +120,7 @@ int flb_io_net_connect(struct flb_connection *connection,
     }
 
     /* Check which connection mode must be done */
-    if (coro) {
+    if (coro && (flags & FLB_IO_ASYNC)) {
         async = flb_upstream_is_async(connection->upstream);
     }
     else {

Original file line number	Diff line number	Diff line change
`@@ -109,6 +109,7 @@ int flb_io_net_connect(struct flb_connection *connection,`
`109`	`109`	`int ret;`
`110`	`110`	`int async = FLB_FALSE;`
`111`	`111`	`flb_sockfd_t fd = -1;`
	`112`	`+ int flags = flb_connection_get_flags(connection);`
`112`	`113`	`// struct flb_upstream *u = u_conn->u;`
`113`	`114`
`114`	`115`	`if (connection->fd > 0) {`
`@@ -119,7 +120,7 @@ int flb_io_net_connect(struct flb_connection *connection,`
`119`	`120`	`}`
`120`	`121`
`121`	`122`	`/* Check which connection mode must be done */`
`122`		`- if (coro) {`
	`123`	`+ if (coro && (flags & FLB_IO_ASYNC)) {`
`123`	`124`	`async = flb_upstream_is_async(connection->upstream);`
`124`	`125`	`}`
`125`	`126`	`else {`