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)
{
Sleep(10);
if( event_base_loop(sSocketManager.GetEventBase(), 0) == -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");
}