|
|
@ -1238,9 +1238,9 @@ void CConnman::ThreadSocketHandler() |
|
|
|
bool notify = false; |
|
|
|
bool notify = false; |
|
|
|
if (!pnode->ReceiveMsgBytes(pchBuf, nBytes, notify)) |
|
|
|
if (!pnode->ReceiveMsgBytes(pchBuf, nBytes, notify)) |
|
|
|
pnode->CloseSocketDisconnect(); |
|
|
|
pnode->CloseSocketDisconnect(); |
|
|
|
|
|
|
|
RecordBytesRecv(nBytes); |
|
|
|
if(notify) |
|
|
|
if(notify) |
|
|
|
condMsgProc.notify_one(); |
|
|
|
condMsgProc.notify_one(); |
|
|
|
RecordBytesRecv(nBytes); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
else if (nBytes == 0) |
|
|
|
else if (nBytes == 0) |
|
|
|
{ |
|
|
|
{ |
|
|
|