|
|
|
@ -752,10 +752,12 @@ void ThreadSocketHandler2(void* parg)
|
|
|
|
|
FD_ZERO(&fdsetSend);
|
|
|
|
|
FD_ZERO(&fdsetError);
|
|
|
|
|
SOCKET hSocketMax = 0;
|
|
|
|
|
bool have_fds = false;
|
|
|
|
|
|
|
|
|
|
BOOST_FOREACH(SOCKET hListenSocket, vhListenSocket) {
|
|
|
|
|
FD_SET(hListenSocket, &fdsetRecv);
|
|
|
|
|
hSocketMax = max(hSocketMax, hListenSocket);
|
|
|
|
|
have_fds = true;
|
|
|
|
|
}
|
|
|
|
|
{
|
|
|
|
|
LOCK(cs_vNodes);
|
|
|
|
@ -766,6 +768,7 @@ void ThreadSocketHandler2(void* parg)
|
|
|
|
|
FD_SET(pnode->hSocket, &fdsetRecv);
|
|
|
|
|
FD_SET(pnode->hSocket, &fdsetError);
|
|
|
|
|
hSocketMax = max(hSocketMax, pnode->hSocket);
|
|
|
|
|
have_fds = true;
|
|
|
|
|
{
|
|
|
|
|
TRY_LOCK(pnode->cs_vSend, lockSend);
|
|
|
|
|
if (lockSend && !pnode->vSend.empty())
|
|
|
|
@ -775,15 +778,16 @@ void ThreadSocketHandler2(void* parg)
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
vnThreadsRunning[THREAD_SOCKETHANDLER]--;
|
|
|
|
|
int nSelect = select(hSocketMax + 1, &fdsetRecv, &fdsetSend, &fdsetError, &timeout);
|
|
|
|
|
int nSelect = select(have_fds ? hSocketMax + 1 : 0,
|
|
|
|
|
&fdsetRecv, &fdsetSend, &fdsetError, &timeout);
|
|
|
|
|
vnThreadsRunning[THREAD_SOCKETHANDLER]++;
|
|
|
|
|
if (fShutdown)
|
|
|
|
|
return;
|
|
|
|
|
if (nSelect == SOCKET_ERROR)
|
|
|
|
|
{
|
|
|
|
|
int nErr = WSAGetLastError();
|
|
|
|
|
if (hSocketMax != INVALID_SOCKET)
|
|
|
|
|
if (have_fds)
|
|
|
|
|
{
|
|
|
|
|
int nErr = WSAGetLastError();
|
|
|
|
|
printf("socket select error %d\n", nErr);
|
|
|
|
|
for (unsigned int i = 0; i <= hSocketMax; i++)
|
|
|
|
|
FD_SET(i, &fdsetRecv);
|
|
|
|
|