Changeset View
Changeset View
Standalone View
Standalone View
src/net_processing.cpp
Show First 20 Lines • Show All 2,138 Lines • ▼ Show 20 Lines | while (it != pfrom.vRecvGetData.end()) { | ||||
const CInv &inv = *it; | const CInv &inv = *it; | ||||
if (it->IsMsgProof()) { | if (it->IsMsgProof()) { | ||||
const avalanche::ProofId proofid(inv.hash); | const avalanche::ProofId proofid(inv.hash); | ||||
auto proof = FindProofForGetData(pfrom, proofid, now); | auto proof = FindProofForGetData(pfrom, proofid, now); | ||||
if (proof) { | if (proof) { | ||||
connman.PushMessage( | connman.PushMessage( | ||||
&pfrom, msgMaker.Make(NetMsgType::AVAPROOF, *proof)); | &pfrom, msgMaker.Make(NetMsgType::AVAPROOF, *proof)); | ||||
g_avalanche->removeUnbroadcastProof(proofid); | g_avalanche->withPeerManager([&](avalanche::PeerManager &pm) { | ||||
pm.removeUnbroadcastProof(proofid); | |||||
}); | |||||
} else { | } else { | ||||
vNotFound.push_back(inv); | vNotFound.push_back(inv); | ||||
} | } | ||||
++it; | ++it; | ||||
continue; | continue; | ||||
} | } | ||||
▲ Show 20 Lines • Show All 3,713 Lines • Show Last 20 Lines |