Method ThreadPrivateBroadcast

src/net.cpp:3279–3346

}

void CConnman::ThreadPrivateBroadcast()
{
    AssertLockNotHeld(m_nodes_mutex);
    AssertLockNotHeld(m_unused_i2p_sessions_mutex);

    size_t addrman_num_bad_addresses{0};
    while (!m_interrupt_net->interrupted()) {

        if (!fNetworkActive) {
            m_interrupt_net->sleep_for(5s);
            continue;
        }

        CountingSemaphoreGrant<> conn_max_grant{m_private_broadcast.m_sem_conn_max}; // Would block if too many are opened.

        m_private_broadcast.NumToOpenWait();

        if (m_interrupt_net->interrupted()) {
            break;
        }

        std::optional<Proxy> proxy;
        const std::optional<Network> net{m_private_broadcast.PickNetwork(proxy)};
        if (!net.has_value()) {
            LogWarning("Unable to open -privatebroadcast connections: neither Tor nor I2P is reachable");
            m_interrupt_net->sleep_for(5s);
            continue;
        }

        const auto [addr, _] = addrman.get().Select(/*new_only=*/false, {net.value()});

        if (!addr.IsValid() || IsLocal(addr)) {
            ++addrman_num_bad_addresses;
            if (addrman_num_bad_addresses > 100) {
                LogDebug(BCLog::PRIVBROADCAST, "Connections needed but addrman keeps returning bad addresses, will retry");
                m_interrupt_net->sleep_for(500ms);
            }
            continue;
        }
        addrman_num_bad_addresses = 0;

        auto target_str{addr.ToStringAddrPort()};
        if (proxy.has_value()) {
            target_str += " through the proxy at " + proxy->ToString();
        }

        const bool use_v2transport(addr.nServices & GetLocalServices() & NODE_P2P_V2);

        if (OpenNetworkConnection(addr,
                                  /*fCountFailure=*/true,
                                  std::move(conn_max_grant),
                                  /*pszDest=*/nullptr,
                                  ConnectionType::PRIVATE_BROADCAST,
                                  use_v2transport,
                                  proxy)) {
            const size_t remaining{m_private_broadcast.NumToOpenSub(1)};
            LogDebug(BCLog::PRIVBROADCAST, "Socket connected to %s; remaining connections to open: %d", target_str, remaining);
        } else {