diff --git a/src/proxy/logging/Log.cc b/src/proxy/logging/Log.cc index 2bcaba9815b..6e72ac408b2 100644 --- a/src/proxy/logging/Log.cc +++ b/src/proxy/logging/Log.cc @@ -1242,7 +1242,11 @@ void Log::create_threads() { char desc[64]; - preproc_notify = new EventNotify[preproc_threads]; + preproc_notify = new EventNotify[preproc_threads]; + flush_notify = new EventNotify; + flush_data_list = new InkAtomicList; + + ink_atomiclist_init(flush_data_list, "Logging flush buffer list", 0); size_t stacksize; stacksize = RecGetRecordInt("proxy.config.thread.default.stacksize").value_or(0); @@ -1261,10 +1265,6 @@ Log::create_threads() // TODO: Enable multiple flush threads, such as // one flush thread per file. // - flush_notify = new EventNotify; - flush_data_list = new InkAtomicList; - - ink_atomiclist_init(flush_data_list, "Logging flush buffer list", 0); Continuation *flush_cont = new LoggingFlushContinuation(0); eventProcessor.spawn_thread(flush_cont, "[LOG_FLUSH]", stacksize); }