diff --git a/src/dispatch.cc b/src/dispatch.cc index be2be0d..1d5c36a 100644 --- a/src/dispatch.cc +++ b/src/dispatch.cc @@ -86,6 +86,9 @@ void kvz_rtp::dispatcher::dispatch_runner(kvz_rtp::dispatcher *dispatcher, kvz_r std::unique_lock lk(m); kvz_rtp::transaction_t *t = nullptr; + while (!dispatcher->active()) + ; + while (dispatcher->active()) { if ((t = dispatcher->get_transaction()) == nullptr) { dispatcher->get_cvar().wait(lk);