Skip to content

Commit ef7b5ec

Browse files
committed
net: Add a simple function for waking the message handler
This may be used publicly in the future
1 parent f5c36d1 commit ef7b5ec

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

src/net.cpp

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1239,8 +1239,8 @@ void CConnman::ThreadSocketHandler()
12391239
if (!pnode->ReceiveMsgBytes(pchBuf, nBytes, notify))
12401240
pnode->CloseSocketDisconnect();
12411241
RecordBytesRecv(nBytes);
1242-
if(notify)
1243-
condMsgProc.notify_one();
1242+
if (notify)
1243+
WakeMessageHandler();
12441244
}
12451245
else if (nBytes == 0)
12461246
{
@@ -1315,8 +1315,10 @@ void CConnman::ThreadSocketHandler()
13151315
}
13161316
}
13171317

1318-
1319-
1318+
void CConnman::WakeMessageHandler()
1319+
{
1320+
condMsgProc.notify_one();
1321+
}
13201322

13211323

13221324

src/net.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -341,6 +341,8 @@ class CConnman
341341
void ThreadSocketHandler();
342342
void ThreadDNSAddressSeed();
343343

344+
void WakeMessageHandler();
345+
344346
uint64_t CalculateKeyedNetGroup(const CAddress& ad);
345347

346348
CNode* FindNode(const CNetAddr& ip);

0 commit comments

Comments
 (0)