diff --git a/server/core/worker.cc b/server/core/worker.cc index b699e740b..14cc7df3a 100644 --- a/server/core/worker.cc +++ b/server/core/worker.cc @@ -719,17 +719,8 @@ size_t Worker::execute_concurrently(Task& task) bool Worker::post_message(uint32_t msg_id, intptr_t arg1, intptr_t arg2) { // NOTE: No logging here, this function must be signal safe. - bool rval = false; - // TODO: Fix this, it will be hit - // ss_dassert(state() != Worker::STOPPED); - - if (state() != Worker::STOPPED) - { - MessageQueue::Message message(msg_id, arg1, arg2); - rval = m_pQueue->post(message); - } - - return rval; + MessageQueue::Message message(msg_id, arg1, arg2); + return m_pQueue->post(message); } bool mxs_worker_post_message(MXS_WORKER* pWorker, uint32_t msg_id, intptr_t arg1, intptr_t arg2)