From 5138f8aee0701b3b43c52ceb9affb103ff976a4b Mon Sep 17 00:00:00 2001 From: Hiroshi Hatake Date: Mon, 9 Dec 2024 20:33:48 +0900 Subject: [PATCH] in_forward: Remove a needless add event for handling sockets Signed-off-by: Hiroshi Hatake --- plugins/in_forward/fw.c | 17 ----------------- 1 file changed, 17 deletions(-) diff --git a/plugins/in_forward/fw.c b/plugins/in_forward/fw.c index faefc4d82a8..6618d948323 100644 --- a/plugins/in_forward/fw.c +++ b/plugins/in_forward/fw.c @@ -388,30 +388,13 @@ static void in_fw_pause(void *data, struct flb_config *config) } static void in_fw_resume(void *data, struct flb_config *config) { - struct flb_connection *connection; - struct fw_conn *conn; struct flb_in_fw_config *ctx = data; if (config->is_running == FLB_TRUE) { if (pthread_mutex_lock(&ctx->conn_mutex)) { - connection = flb_downstream_conn_get(ctx->downstream); - if (connection == NULL) { - flb_plg_error(ctx->ins, "could not accept new connection"); - - return; - } - - conn = fw_conn_add(connection, ctx); - if (!conn) { - flb_plg_error(ctx->ins, "could not add connection"); - - return; - } - flb_input_collector_resume(ctx->coll_fd, ctx->ins); ctx->is_paused = FLB_FALSE; } pthread_mutex_unlock(&ctx->conn_mutex); - } }