flewkey/cuberite-2a
1
0
Fork 0
Code Releases Activity

SocketThreads: Fixed sending to closed socket.

Browse Source
This commit is contained in:
madmaxoft 2014-02-03 10:38:25 +01:00
parent c2c1639af8
commit 0b384198e5
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/OSSupport/SocketThreads.cpp
View File

@ -557,6 +557,11 @@ void cSocketThreads::cSocketThread::WriteToSockets(fd_set * a_Write)
} }
} // if (outgoing data is empty) } // if (outgoing data is empty)
if (m_Slots[i].m_State == sSlot::ssRemoteClosed)
{
continue;
}
if (!SendDataThroughSocket(m_Slots[i].m_Socket, m_Slots[i].m_Outgoing)) if (!SendDataThroughSocket(m_Slots[i].m_Socket, m_Slots[i].m_Outgoing))
{ {
int Err = cSocket::GetLastError(); int Err = cSocket::GetLastError();
@ -566,7 +571,7 @@ void cSocketThreads::cSocketThread::WriteToSockets(fd_set * a_Write)
{ {
m_Slots[i].m_Client->SocketClosed(); m_Slots[i].m_Client->SocketClosed();
} }
return; continue;
} }
if (m_Slots[i].m_Outgoing.empty() && (m_Slots[i].m_State == sSlot::ssWritingRestOut)) if (m_Slots[i].m_Outgoing.empty() && (m_Slots[i].m_State == sSlot::ssWritingRestOut))