Flush queues when opening listen socket fails.

This commit is contained in:
Bartosz Taudul 2018-12-21 18:14:30 +01:00
parent a4be9b51b0
commit e9ce8fdfda

View File

@ -933,7 +933,19 @@ void Profiler::Worker()
moodycamel::ConsumerToken token( s_queue ); moodycamel::ConsumerToken token( s_queue );
ListenSocket listen; ListenSocket listen;
listen.Listen( "8086", 8 ); if( !listen.Listen( "8086", 8 ) )
{
for(;;)
{
if( ShouldExit() )
{
m_shutdownFinished.store( true, std::memory_order_relaxed );
return;
}
ClearQueues( token );
}
}
for(;;) for(;;)
{ {