|
|
@ -1239,8 +1239,8 @@ void CConnman::ThreadSocketHandler() |
|
|
|
if (!pnode->ReceiveMsgBytes(pchBuf, nBytes, notify)) |
|
|
|
if (!pnode->ReceiveMsgBytes(pchBuf, nBytes, notify)) |
|
|
|
pnode->CloseSocketDisconnect(); |
|
|
|
pnode->CloseSocketDisconnect(); |
|
|
|
RecordBytesRecv(nBytes); |
|
|
|
RecordBytesRecv(nBytes); |
|
|
|
if(notify) |
|
|
|
if (notify) |
|
|
|
condMsgProc.notify_one(); |
|
|
|
WakeMessageHandler(); |
|
|
|
} |
|
|
|
} |
|
|
|
else if (nBytes == 0) |
|
|
|
else if (nBytes == 0) |
|
|
|
{ |
|
|
|
{ |
|
|
@ -1315,8 +1315,10 @@ void CConnman::ThreadSocketHandler() |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
void CConnman::WakeMessageHandler() |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
condMsgProc.notify_one(); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|