Method ProcessAddrs

src/net_processing.cpp:5729–5814

}

void PeerManagerImpl::ProcessAddrs(std::string_view msg_type, CNode& pfrom, Peer& peer, std::vector<CAddress>&& vAddr, const std::atomic<bool>& interruptMsgProc)
{
    AssertLockNotHeld(m_peer_mutex);
    AssertLockHeld(g_msgproc_mutex);

    if (!SetupAddressRelay(pfrom, peer)) {
        LogDebug(BCLog::NET, "ignoring %s message from %s peer=%d\n", msg_type, pfrom.ConnectionTypeAsString(), pfrom.GetId());
        return;
    }

    if (vAddr.size() > MAX_ADDR_TO_SEND)
    {
        Misbehaving(peer, strprintf("%s message size = %u", msg_type, vAddr.size()));
        return;
    }

    // Store the new addresses
    std::vector<CAddress> vAddrOk;

    // Update/increment addr rate limiting bucket.
    const auto current_time{NodeClock::now()};
    if (peer.m_addr_token_bucket < MAX_ADDR_PROCESSING_TOKEN_BUCKET) {
        // Don't increment bucket if it's already full
        const auto time_diff{current_time - peer.m_addr_token_timestamp};
        const double increment{std::max(Ticks<SecondsDouble>(time_diff), 0.0) * MAX_ADDR_RATE_PER_SECOND};
        peer.m_addr_token_bucket = std::min<double>(peer.m_addr_token_bucket + increment, MAX_ADDR_PROCESSING_TOKEN_BUCKET);
    }
    peer.m_addr_token_timestamp = current_time;

    const bool rate_limited = !pfrom.HasPermission(NetPermissionFlags::Addr);
    uint64_t num_proc = 0;
    uint64_t num_rate_limit = 0;
    std::shuffle(vAddr.begin(), vAddr.end(), m_rng);
    for (CAddress& addr : vAddr)
    {
        if (interruptMsgProc)
            return;

        // Apply rate limiting.
        if (peer.m_addr_token_bucket < 1.0) {
            if (rate_limited) {
                ++num_rate_limit;
                continue;
            }
        } else {
            peer.m_addr_token_bucket -= 1.0;
        }
        // We only bother storing full nodes, though this may include
        // things which we would not make an outbound connection to, in
        // part because we may make feeler connections to them.
        if (!MayHaveUsefulAddressDB(addr.nServices) && !HasAllDesirableServiceFlags(addr.nServices))
            continue;

        if (addr.nTime <= NodeSeconds{100000000s} || addr.nTime > current_time + 10min) {
            addr.nTime = std::chrono::time_point_cast<std::chrono::seconds>(current_time - 5 * 24h);
        }
        AddAddressKnown(peer, addr);
        if (m_banman && (m_banman->IsDiscouraged(addr) || m_banman->IsBanned(addr))) {