rendered paste bodyvoid SocketReaderRunnable::run()
{
if(!sSocketManager.GetEventBase())
{
sLog.outError("<Socket manager> Couldn't start Socket worker thread. Event_base is wrong!");
return;
}
sLog.outString("<Socket manager> Socket worker thread is started");
while(!bStop)
{
if( event_base_loop(sSocketManager.GetEventBase(), EVLOOP_ONCE | EVLOOP_NONBLOCK) == -1 )
{
sLog.outError("<Socket manager> Critical error is occured in event_loot. Exit.");
sSocketManager.DisconnectAll();
return;
}
}
sLog.outString("<Socket manager> Socket worker thread is finished");
}