|
|
@ -476,12 +476,15 @@ void ServerMainImpl::threadFn(std::promise<bool> promise, int port)
|
|
|
|
CActiveSocket *client = nullptr;
|
|
|
|
CActiveSocket *client = nullptr;
|
|
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
while ((client = server.socket.Accept()) != NULL)
|
|
|
|
while (server.socket.IsSocketValid())
|
|
|
|
|
|
|
|
{
|
|
|
|
|
|
|
|
if ((client = server.socket.Accept()) != NULL)
|
|
|
|
{
|
|
|
|
{
|
|
|
|
BlockGuard lock;
|
|
|
|
BlockGuard lock;
|
|
|
|
ServerConnection::Accepted(client);
|
|
|
|
ServerConnection::Accepted(client);
|
|
|
|
client = nullptr;
|
|
|
|
client = nullptr;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
} catch(BlockedException &) {
|
|
|
|
} catch(BlockedException &) {
|
|
|
|
if (client)
|
|
|
|
if (client)
|
|
|
|
client->Close();
|
|
|
|
client->Close();
|
|
|
|