We're done here, don't try to send termination request.

This commit is contained in:
Bartosz Taudul 2019-06-09 16:22:48 +02:00
parent 496f866add
commit e2d42fae2f

View File

@ -1291,7 +1291,8 @@ void Profiler::Worker()
const auto serialStatus = DequeueSerial(); const auto serialStatus = DequeueSerial();
if( status == DequeueStatus::ConnectionLost || serialStatus == DequeueStatus::ConnectionLost ) if( status == DequeueStatus::ConnectionLost || serialStatus == DequeueStatus::ConnectionLost )
{ {
break; m_shutdownFinished.store( true, std::memory_order_relaxed );
return;
} }
else if( status == DequeueStatus::QueueEmpty && serialStatus == DequeueStatus::QueueEmpty ) else if( status == DequeueStatus::QueueEmpty && serialStatus == DequeueStatus::QueueEmpty )
{ {
@ -1301,7 +1302,11 @@ void Profiler::Worker()
while( m_sock->HasData() ) while( m_sock->HasData() )
{ {
if( !HandleServerQuery() ) break; if( !HandleServerQuery() )
{
m_shutdownFinished.store( true, std::memory_order_relaxed );
return;
}
} }
} }