mirror of
https://github.com/debauchee/barrier.git
synced 2024-12-28 13:43:37 +03:00
Fixed bug in TCP socket that caused a busy loop in the socket
multiplexer. That caused a lock up on windows when quitting the server with a client connected.
This commit is contained in:
parent
fdf4b2604d
commit
ab0a693891
@ -334,16 +334,22 @@ CTCPSocket::newJob()
|
|||||||
{
|
{
|
||||||
// note -- must have m_mutex locked on entry
|
// note -- must have m_mutex locked on entry
|
||||||
|
|
||||||
if (m_socket == NULL || !(m_readable || m_writable)) {
|
if (m_socket == NULL) {
|
||||||
return NULL;
|
return NULL;
|
||||||
}
|
}
|
||||||
else if (!m_connected) {
|
else if (!m_connected) {
|
||||||
assert(!m_readable);
|
assert(!m_readable);
|
||||||
|
if (!(m_readable || m_writable)) {
|
||||||
|
return NULL;
|
||||||
|
}
|
||||||
return new TSocketMultiplexerMethodJob<CTCPSocket>(
|
return new TSocketMultiplexerMethodJob<CTCPSocket>(
|
||||||
this, &CTCPSocket::serviceConnecting,
|
this, &CTCPSocket::serviceConnecting,
|
||||||
m_socket, m_readable, m_writable);
|
m_socket, m_readable, m_writable);
|
||||||
}
|
}
|
||||||
else {
|
else {
|
||||||
|
if (!(m_readable || (m_writable && (m_outputBuffer.getSize() > 0)))) {
|
||||||
|
return NULL;
|
||||||
|
}
|
||||||
return new TSocketMultiplexerMethodJob<CTCPSocket>(
|
return new TSocketMultiplexerMethodJob<CTCPSocket>(
|
||||||
this, &CTCPSocket::serviceConnected,
|
this, &CTCPSocket::serviceConnected,
|
||||||
m_socket, m_readable,
|
m_socket, m_readable,
|
||||||
|
Loading…
Reference in New Issue
Block a user