neobytes-project/neobytes
neobytes-project/neobytes
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

Merge #9535: Split CNode::cs_vSend: message processing and message sending

Browse Source 
376b3c2 Make the cs_sendProcessing a LOCK instead of a TRY_LOCK (Matt Corallo)
d7c58ad Split CNode::cs_vSend: message processing and message sending (Matt Corallo)
This commit is contained in:
Wladimir J. van der Laan 2017-01-19 20:19:29 +01:00 committed by Alexander Block
parent a84f8da136
commit f8b880f4d8
2 changed files with 12 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
src/net.cpp
View File

@ -1190,12 +1190,10 @@ void CConnman::ThreadSocketHandler()
// * Hand off all complete messages to the processor, to be handled without // * Hand off all complete messages to the processor, to be handled without
// blocking here. // blocking here.
{ {
TRY_LOCK(pnode->cs_vSend, lockSend); LOCK(pnode->cs_vSend);
if (lockSend) { if (!pnode->vSendMsg.empty()) {
if (!pnode->vSendMsg.empty()) { FD_SET(pnode->hSocket, &fdsetSend);
FD_SET(pnode->hSocket, &fdsetSend); continue;
continue;
}
} }
} }
{ {
@ -1309,12 +1307,10 @@ void CConnman::ThreadSocketHandler()
continue; continue;
if (FD_ISSET(pnode->hSocket, &fdsetSend)) if (FD_ISSET(pnode->hSocket, &fdsetSend))
{ {
TRY_LOCK(pnode->cs_vSend, lockSend); LOCK(pnode->cs_vSend);
if (lockSend) { size_t nBytes = SocketSendData(pnode);
size_t nBytes = SocketSendData(pnode); if (nBytes) {
if (nBytes) { RecordBytesSent(nBytes);
RecordBytesSent(nBytes);
}
} }
} }
@ -1948,9 +1944,8 @@ void CConnman::ThreadMessageHandler()
// Send messages // Send messages
{ {
TRY_LOCK(pnode->cs_vSend, lockSend); LOCK(pnode->cs_sendProcessing);
if (lockSend) GetNodeSignals().SendMessages(pnode, *this, flagInterruptMsgProc);
GetNodeSignals().SendMessages(pnode, *this, flagInterruptMsgProc);
} }
if (flagInterruptMsgProc) if (flagInterruptMsgProc)
return; return;

2
src/net.h
View File

@ -687,6 +687,8 @@ public:
std::list<CNetMessage> vProcessMsg; std::list<CNetMessage> vProcessMsg;
size_t nProcessQueueSize; size_t nProcessQueueSize;
CCriticalSection cs_sendProcessing;
std::deque<CInv> vRecvGetData; std::deque<CInv> vRecvGetData;
uint64_t nRecvBytes; uint64_t nRecvBytes;
std::atomic<int> nRecvVersion; std::atomic<int> nRecvVersion;