|
|
|
@ -376,7 +376,7 @@ void MarkBlockAsInFlight(NodeId nodeid, const uint256& hash, const Consensus::Pa
@@ -376,7 +376,7 @@ void MarkBlockAsInFlight(NodeId nodeid, const uint256& hash, const Consensus::Pa
|
|
|
|
|
mapBlocksInFlight[hash] = std::make_pair(nodeid, it); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
/** Check whether the last unknown block a peer advertized is not yet known. */ |
|
|
|
|
/** Check whether the last unknown block a peer advertised is not yet known. */ |
|
|
|
|
void ProcessBlockAvailability(NodeId nodeid) { |
|
|
|
|
CNodeState *state = State(nodeid); |
|
|
|
|
assert(state != NULL); |
|
|
|
@ -4456,11 +4456,11 @@ bool static ProcessMessage(CNode* pfrom, string strCommand, CDataStream& vRecv,
@@ -4456,11 +4456,11 @@ bool static ProcessMessage(CNode* pfrom, string strCommand, CDataStream& vRecv,
|
|
|
|
|
CAddress addr = GetLocalAddress(&pfrom->addr); |
|
|
|
|
if (addr.IsRoutable()) |
|
|
|
|
{ |
|
|
|
|
LogPrintf("ProcessMessages: advertizing address %s\n", addr.ToString()); |
|
|
|
|
LogPrintf("ProcessMessages: advertising address %s\n", addr.ToString()); |
|
|
|
|
pfrom->PushAddress(addr); |
|
|
|
|
} else if (IsPeerAddrLocalGood(pfrom)) { |
|
|
|
|
addr.SetIP(pfrom->addrLocal); |
|
|
|
|
LogPrintf("ProcessMessages: advertizing address %s\n", addr.ToString()); |
|
|
|
|
LogPrintf("ProcessMessages: advertising address %s\n", addr.ToString()); |
|
|
|
|
pfrom->PushAddress(addr); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
@ -5469,7 +5469,7 @@ bool SendMessages(CNode* pto)
@@ -5469,7 +5469,7 @@ bool SendMessages(CNode* pto)
|
|
|
|
|
// Address refresh broadcast
|
|
|
|
|
int64_t nNow = GetTimeMicros(); |
|
|
|
|
if (!IsInitialBlockDownload() && pto->nNextLocalAddrSend < nNow) { |
|
|
|
|
AdvertizeLocal(pto); |
|
|
|
|
AdvertiseLocal(pto); |
|
|
|
|
pto->nNextLocalAddrSend = PoissonNextSend(nNow, AVG_LOCAL_ADDRESS_BROADCAST_INTERVAL); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|