From 3e5938976a831ebd2902701e7f147d4b5a3d37f7 Mon Sep 17 00:00:00 2001 From: Philipp Schafft Date: Fri, 25 Mar 2022 22:42:41 +0000 Subject: [PATCH] Fix: Start queue threads not before the config system got up --- src/connection.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/connection.c b/src/connection.c index 2d09918e..30bdcd9d 100644 --- a/src/connection.c +++ b/src/connection.c @@ -336,11 +336,6 @@ void connection_initialize(void) client_queue_init(&_body_queue); client_queue_init(&_handle_queue); - client_queue_start_thread(&_request_queue, "Request Queue", process_request_queue); - client_queue_start_thread(&_connection_queue, "Con Queue", _handle_connection); - client_queue_start_thread(&_body_queue, "Body Queue", process_request_body_queue); - client_queue_start_thread(&_handle_queue, "Client Handler", handle_client_worker); - _initialized = 1; } @@ -884,6 +879,11 @@ void connection_accept_loop(void) get_tls_certificate(config); config_release_config(); + client_queue_start_thread(&_request_queue, "Request Queue", process_request_queue); + client_queue_start_thread(&_connection_queue, "Con Queue", _handle_connection); + client_queue_start_thread(&_body_queue, "Body Queue", process_request_body_queue); + client_queue_start_thread(&_handle_queue, "Client Handler", handle_client_worker); + while (global.running == ICECAST_RUNNING) { connection_t *con = listensocket_container_accept(global.listensockets, 800);