|
|
@ -2445,9 +2445,6 @@ bool ProcessMessages(CNode* pfrom, CConnman& connman, std::atomic<bool>& interru |
|
|
|
{ |
|
|
|
{ |
|
|
|
const CChainParams& chainparams = Params(); |
|
|
|
const CChainParams& chainparams = Params(); |
|
|
|
unsigned int nMaxSendBufferSize = connman.GetSendBufferSize(); |
|
|
|
unsigned int nMaxSendBufferSize = connman.GetSendBufferSize(); |
|
|
|
//if (fDebug)
|
|
|
|
|
|
|
|
// LogPrintf("%s(%u messages)\n", __func__, pfrom->vRecvMsg.size());
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//
|
|
|
|
//
|
|
|
|
// Message format
|
|
|
|
// Message format
|
|
|
|
// (4) message start
|
|
|
|
// (4) message start
|
|
|
@ -2473,11 +2470,6 @@ bool ProcessMessages(CNode* pfrom, CConnman& connman, std::atomic<bool>& interru |
|
|
|
// get next message
|
|
|
|
// get next message
|
|
|
|
CNetMessage& msg = *it; |
|
|
|
CNetMessage& msg = *it; |
|
|
|
|
|
|
|
|
|
|
|
//if (fDebug)
|
|
|
|
|
|
|
|
// LogPrintf("%s(message %u msgsz, %u bytes, complete:%s)\n", __func__,
|
|
|
|
|
|
|
|
// msg.hdr.nMessageSize, msg.vRecv.size(),
|
|
|
|
|
|
|
|
// msg.complete() ? "Y" : "N");
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// end, if an incomplete message is found
|
|
|
|
// end, if an incomplete message is found
|
|
|
|
if (!msg.complete()) |
|
|
|
if (!msg.complete()) |
|
|
|
break; |
|
|
|
break; |
|
|
|