Changeset View
Changeset View
Standalone View
Standalone View
src/net_processing.cpp
Show First 20 Lines • Show All 2,224 Lines • ▼ Show 20 Lines | while (!done && !orphan_work_set.empty()) { | ||||
EraseOrphanTx(orphanTxId); | EraseOrphanTx(orphanTxId); | ||||
done = true; | done = true; | ||||
} | } | ||||
g_mempool.check(&::ChainstateActive().CoinsTip()); | g_mempool.check(&::ChainstateActive().CoinsTip()); | ||||
} | } | ||||
} | } | ||||
static bool ProcessMessage(const Config &config, CNode *pfrom, | bool ProcessMessage(const Config &config, CNode *pfrom, | ||||
const std::string &strCommand, CDataStream &vRecv, | const std::string &strCommand, CDataStream &vRecv, | ||||
int64_t nTimeReceived, CConnman *connman, | int64_t nTimeReceived, CConnman *connman, BanMan *banman, | ||||
BanMan *banman, | |||||
const std::atomic<bool> &interruptMsgProc) { | const std::atomic<bool> &interruptMsgProc) { | ||||
const CChainParams &chainparams = config.GetChainParams(); | const CChainParams &chainparams = config.GetChainParams(); | ||||
LogPrint(BCLog::NET, "received: %s (%u bytes) peer=%d\n", | LogPrint(BCLog::NET, "received: %s (%u bytes) peer=%d\n", | ||||
SanitizeString(strCommand), vRecv.size(), pfrom->GetId()); | SanitizeString(strCommand), vRecv.size(), pfrom->GetId()); | ||||
if (gArgs.IsArgSet("-dropmessagestest") && | if (gArgs.IsArgSet("-dropmessagestest") && | ||||
GetRand(gArgs.GetArg("-dropmessagestest", 0)) == 0) { | GetRand(gArgs.GetArg("-dropmessagestest", 0)) == 0) { | ||||
LogPrintf("dropmessagestest DROPPING RECV MESSAGE\n"); | LogPrintf("dropmessagestest DROPPING RECV MESSAGE\n"); | ||||
return true; | return true; | ||||
} | } | ||||
▲ Show 20 Lines • Show All 2,764 Lines • Show Last 20 Lines |