diff --git a/src/server/master.cc b/src/server/master.cc index a6d99b1e61..88bb944ebf 100644 --- a/src/server/master.cc +++ b/src/server/master.cc @@ -729,6 +729,7 @@ Server::Server(enum Mode _mode) { gs->max_concurrency = UINT_MAX; message_bus.set_id_generator([this]() { return sw_atomic_fetch_add(&gs->pipe_packet_msg_id, 1); }); + worker_thread_start = [](const WorkerFn &fn) { fn(); }; g_server_instance = this; } diff --git a/src/server/thread.cc b/src/server/thread.cc index 72e0014b75..00a10a36db 100644 --- a/src/server/thread.cc +++ b/src/server/thread.cc @@ -29,7 +29,6 @@ Factory *Server::create_thread_factory() { } reactor_threads = new ReactorThread[reactor_num](); reactor_pipe_num = 1; - worker_thread_start = [](const WorkerFn &fn) { fn(); }; return new ThreadFactory(this); }