Fixed a voice issue
This commit is contained in:
parent
971a84105b
commit
3e88ae46b6
@ -38,7 +38,7 @@ std::shared_ptr<IOServerHandler> VoiceIOManager::enableIo(server::TSServer *serv
|
|||||||
threads::MutexLock l(this->serverLock);
|
threads::MutexLock l(this->serverLock);
|
||||||
this->servers.push_back(server_io);
|
this->servers.push_back(server_io);
|
||||||
}
|
}
|
||||||
this->ioExecutorNotify.notify_all();
|
this->ioExecutorNotify.notify_all();
|
||||||
|
|
||||||
return server_io;
|
return server_io;
|
||||||
}
|
}
|
||||||
@ -306,7 +306,8 @@ void VoiceIOManager::dispatchBase(shared_ptr<IOEventLoop> self) {
|
|||||||
{
|
{
|
||||||
/* wait until reschedule */
|
/* wait until reschedule */
|
||||||
unique_lock<mutex> execute_lock(this->executorLock);
|
unique_lock<mutex> execute_lock(this->executorLock);
|
||||||
this->ioExecutorNotify.wait(execute_lock);
|
if(event_base_get_num_events(self->base, EVENT_BASE_COUNT_ACTIVE | EVENT_BASE_COUNT_ADDED | EVENT_BASE_COUNT_VIRTUAL) == 0)
|
||||||
|
this->ioExecutorNotify.wait(execute_lock);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
debugMessage(LOG_INSTANCE, "Dispatching io base {} finished", (void*) self->base);
|
debugMessage(LOG_INSTANCE, "Dispatching io base {} finished", (void*) self->base);
|
||||||
|
Loading…
Reference in New Issue
Block a user