Changeset View
Changeset View
Standalone View
Standalone View
src/net_processing.cpp
- This file is larger than 256 KB, so syntax highlighting is disabled by default.
Show First 20 Lines • Show All 5,302 Lines • ▼ Show 20 Lines | if (msg_type == NetMsgType::AVAPROOFS) { | ||||
for (size_t i = 0; i < compactProofs.size(); i++) { | for (size_t i = 0; i < compactProofs.size(); i++) { | ||||
if (shortIdProcessor.getItem(i) == nullptr) { | if (shortIdProcessor.getItem(i) == nullptr) { | ||||
req.indices.push_back(i); | req.indices.push_back(i); | ||||
} | } | ||||
} | } | ||||
m_connman.PushMessage(&pfrom, | m_connman.PushMessage(&pfrom, | ||||
msgMaker.Make(NetMsgType::AVAPROOFSREQ, req)); | msgMaker.Make(NetMsgType::AVAPROOFSREQ, req)); | ||||
// We want to keep a count of how many nodes we successfully requested | |||||
// avaproofs from as this is used to determine when we are confident our | |||||
// quorum is close enough to the other participants. | |||||
g_avalanche->avaproofsSent(pfrom.GetId()); | |||||
return; | return; | ||||
} | } | ||||
if (msg_type == NetMsgType::AVAPROOFSREQ) { | if (msg_type == NetMsgType::AVAPROOFSREQ) { | ||||
if (pfrom.m_proof_relay == nullptr) { | if (pfrom.m_proof_relay == nullptr) { | ||||
return; | return; | ||||
} | } | ||||
▲ Show 20 Lines • Show All 1,770 Lines • Show Last 20 Lines |