READ THE CODE

Inside Bitcoin

The code behind the network, with room to understand it.

Stable release v32.1bitcoin/bitcoin · f0de87f04062 ↗3,020 source files · 47.5 MB stored on the server440 file guides

Release published 2026-10-28 · Snapshot fetched 2026-11-01. Latest stable release at fetch time; development branches and Git history are excluded. Only the selected code window and visible folders load here.

13,888 bytes · SHA-256 432b91c123750a21… · View upstream ↗

1// Copyright (c) 2020-present The Bitcoin Core developers
2// Distributed under the MIT software license, see the accompanying
3// file COPYING or http://www.opensource.org/licenses/mit-license.php.
4
5#include <test/util/net.h>
6
7#include <net.h>
8#include <net_processing.h>
9#include <netaddress.h>
10#include <netmessagemaker.h>
11#include <node/connection_types.h>
12#include <node/eviction.h>
13#include <protocol.h>
14#include <random.h>
15#include <serialize.h>
16#include <span.h>
17#include <sync.h>
18
19#include <chrono>
20#include <optional>
21#include <vector>
22
23void ConnmanTestMsg::Handshake(CNode& node,
24                               bool successfully_connected,
25                               ServiceFlags remote_services,
26                               ServiceFlags local_services,
27                               int32_t version,
28                               bool relay_txs)
29{
30    auto& peerman{static_cast<PeerManager&>(*m_msgproc)};
31    auto& connman{*this};
32
33    peerman.InitializeNode(node, local_services);
34    peerman.SendMessages(node);
35    FlushSendBuffer(node); // Drop the version message added by SendMessages.
36
37    CSerializedNetMsg msg_version{
38        NetMsg::Make(NetMsgType::VERSION,
39                version,                                        //
40                Using<CustomUintFormatter<8>>(remote_services), //
41                int64_t{},                                      // dummy time
42                int64_t{},                                      // ignored service bits
43                CNetAddr::V1(CService{}),                       // dummy
44                int64_t{},                                      // ignored service bits
45                CNetAddr::V1(CService{}),                       // ignored
46                uint64_t{1},                                    // dummy nonce
47                std::string{},                                  // dummy subver
48                int32_t{},                                      // dummy starting_height
49                relay_txs),
50    };
51
52    (void)connman.ReceiveMsgFrom(node, std::move(msg_version));
53    node.fPauseSend = false;
54    connman.ProcessMessagesOnce(node);
55    peerman.SendMessages(node);
56    FlushSendBuffer(node); // Drop the verack message added by SendMessages.
57    if (node.fDisconnect) return;
58    assert(node.nVersion == version);
59    assert(node.GetCommonVersion() == std::min(version, node.AdvertisedVersion()));
60    CNodeStateStats statestats;
61    assert(peerman.GetNodeStateStats(node.GetId(), statestats));
62    assert(statestats.m_relay_txs == (relay_txs && !node.IsBlockOnlyConn()));
63    assert(statestats.their_services == remote_services);
64    if (successfully_connected) {
65        CSerializedNetMsg msg_verack{NetMsg::Make(NetMsgType::VERACK)};
66        (void)connman.ReceiveMsgFrom(node, std::move(msg_verack));
67        node.fPauseSend = false;
68        connman.ProcessMessagesOnce(node);
69        peerman.SendMessages(node);
70        assert(node.fSuccessfullyConnected == true);
71    }
72}
73
74void ConnmanTestMsg::ResetAddrCache() { m_addr_response_caches = {}; }
75
76void ConnmanTestMsg::ResetMaxOutboundCycle()
77{
78    LOCK(m_total_bytes_sent_mutex);
79    nMaxOutboundCycleStartTime = 0s;
80    nMaxOutboundTotalBytesSentInCycle = 0;
81}
82
83void ConnmanTestMsg::Reset()
84{
85    ResetAddrCache();
86    ResetMaxOutboundCycle();
87    m_private_broadcast.m_outbound_tor_ok_at_least_once.store(false);
88    m_private_broadcast.m_num_to_open.store(0);
89}
90
91void ConnmanTestMsg::NodeReceiveMsgBytes(CNode& node, std::span<const uint8_t> msg_bytes, bool& complete) const
92{
93    assert(node.ReceiveMsgBytes(msg_bytes, complete));
94    if (complete) {
95        node.MarkReceivedMsgsForProcessing();
96    }
97}
98
99void ConnmanTestMsg::FlushSendBuffer(CNode& node) const
100{
101    LOCK(node.cs_vSend);
102    node.vSendMsg.clear();
103    node.m_send_memusage = 0;
104    while (true) {
105        const auto& [to_send, _more, _msg_type] = node.m_transport->GetBytesToSend(false);
106        if (to_send.empty()) break;
107        node.m_transport->MarkBytesSent(to_send.size());
108    }
109}
110
111bool ConnmanTestMsg::ReceiveMsgFrom(CNode& node, CSerializedNetMsg&& ser_msg) const
112{
113    bool queued = node.m_transport->SetMessageToSend(ser_msg);
114    assert(queued);
115    bool complete{false};
116    while (true) {
117        const auto& [to_send, _more, _msg_type] = node.m_transport->GetBytesToSend(false);
118        if (to_send.empty()) break;
119        NodeReceiveMsgBytes(node, to_send, complete);
120        node.m_transport->MarkBytesSent(to_send.size());
121    }
122    return complete;
123}
124
125CNode* ConnmanTestMsg::ConnectNodePublic(PeerManager& peerman, const char* pszDest, ConnectionType conn_type)
126{
127    CNode* node = ConnectNode(CAddress{}, pszDest, /*fCountFailure=*/false, conn_type, /*use_v2transport=*/true, /*proxy_override=*/std::nullopt);
128    if (!node) return nullptr;
129    node->SetCommonVersion(PROTOCOL_VERSION);
130    peerman.InitializeNode(*node, ServiceFlags(NODE_NETWORK | NODE_WITNESS));
131    node->fSuccessfullyConnected = true;
132    AddTestNode(*node);
133    return node;
134}
135
136std::vector<NodeEvictionCandidate> GetRandomNodeEvictionCandidates(int n_candidates, FastRandomContext& random_context)
137{
138    std::vector<NodeEvictionCandidate> candidates;
139    candidates.reserve(n_candidates);
140    for (int id = 0; id < n_candidates; ++id) {
141        candidates.push_back({
142            .id=id,
143            .m_connected=NodeSeconds{std::chrono::seconds{random_context.randrange(100)}},
144            .m_min_ping_time=std::chrono::microseconds{random_context.randrange(100)},
145            .m_last_block_time=std::chrono::seconds{random_context.randrange(100)},
146            .m_last_tx_time=std::chrono::seconds{random_context.randrange(100)},
147            .fRelevantServices=random_context.randbool(),
148            .m_relay_txs=random_context.randbool(),
149            .fBloomFilter=random_context.randbool(),
150            .nKeyedNetGroup=random_context.randrange(100u),
151            .prefer_evict=random_context.randbool(),
152            .m_is_local=random_context.randbool(),
153            .m_network=ALL_NETWORKS[random_context.randrange(ALL_NETWORKS.size())],
154            .m_noban=false,
155            .m_conn_type=ConnectionType::INBOUND,
156        });
157    }
158    return candidates;
159}
160
161// Have different ZeroSock (or others that inherit from it) objects have different
162// m_socket because EqualSharedPtrSock compares m_socket and we want to avoid two
163// different objects comparing as equal.
164static std::atomic<SOCKET> g_mocked_sock_fd{0};
165
166ZeroSock::ZeroSock() : Sock{g_mocked_sock_fd++} {}
167
168// Sock::~Sock() would try to close(2) m_socket if it is not INVALID_SOCKET, avoid that.
169ZeroSock::~ZeroSock() { m_socket = INVALID_SOCKET; }
170
171ssize_t ZeroSock::Send(const void*, size_t len, int) const { return len; }
172
173ssize_t ZeroSock::Recv(void* buf, size_t len, int flags) const
174{
175    memset(buf, 0x0, len);
176    return len;
177}
178
179int ZeroSock::Connect(const sockaddr*, socklen_t) const { return 0; }
180
181int ZeroSock::Bind(const sockaddr*, socklen_t) const { return 0; }
182
183int ZeroSock::Listen(int) const { return 0; }
184
185std::unique_ptr<Sock> ZeroSock::Accept(sockaddr* addr, socklen_t* addr_len) const
186{
187    if (addr != nullptr) {
188        // Pretend all connections come from 5.5.5.5:6789
189        memset(addr, 0x00, *addr_len);
190        const socklen_t write_len = static_cast<socklen_t>(sizeof(sockaddr_in));
191        if (*addr_len >= write_len) {
192            *addr_len = write_len;
193            sockaddr_in* addr_in = reinterpret_cast<sockaddr_in*>(addr);
194            addr_in->sin_family = AF_INET;
195            memset(&addr_in->sin_addr, 0x05, sizeof(addr_in->sin_addr));
196            addr_in->sin_port = htons(6789);
197        }
198    }
199    return std::make_unique<ZeroSock>();
200}
201
202int ZeroSock::GetSockOpt(int level, int opt_name, void* opt_val, socklen_t* opt_len) const
203{
204    std::memset(opt_val, 0x0, *opt_len);
205    return 0;
206}
207
208int ZeroSock::SetSockOpt(int, int, const void*, socklen_t) const { return 0; }
209
210int ZeroSock::GetSockName(sockaddr* name, socklen_t* name_len) const
211{
212    std::memset(name, 0x0, *name_len);
213    return 0;
214}
215
216bool ZeroSock::SetNonBlocking() const { return true; }
217
218bool ZeroSock::IsSelectable() const { return true; }
219
220bool ZeroSock::Wait(std::chrono::milliseconds timeout, Event requested, Event* occurred) const
221{
222    if (occurred != nullptr) {
223        *occurred = requested;
224    }
225    return true;
226}
227
228bool ZeroSock::WaitMany(std::chrono::milliseconds timeout, EventsPerSock& events_per_sock) const
229{
230    for (auto& [sock, events] : events_per_sock) {
231        (void)sock;
232        events.occurred = events.requested;
233    }
234    return true;
235}
236
237ZeroSock& ZeroSock::operator=(Sock&& other)
238{
239    assert(false && "Move of Sock into ZeroSock not allowed.");
240    return *this;
241}
242
243StaticContentsSock::StaticContentsSock(const std::string& contents)
244    : m_contents{contents}
245{
246}
247
248ssize_t StaticContentsSock::Recv(void* buf, size_t len, int flags) const
249{
250    const size_t consume_bytes{std::min(len, m_contents.size() - m_consumed)};

src/wallet/receive.cpp

src/wallet/coinselection.cpp

src/consensus/validation.h

src/primitives/transaction.cpp

src/script/descriptor.cpp

src/bitcoin-cli.cpp

src/rpc/blockchain.cpp

src/rpc/rawtransaction.cpp

src/init.cpp

src/crypto/sha256.cpp

src/consensus/merkle.h

src/consensus/tx_check.h

src/consensus/tx_verify.h

src/policy/feerate.h

src/policy/feerate.cpp

src/primitives/transaction_identifier.h

src/chainparamsbase.h

src/chainparamsbase.cpp

src/util/moneystr.cpp

src/crypto/ripemd160.h

src/crypto/sha1.h

src/crypto/sha512.h

src/crypto/hmac_sha256.h

src/crypto/hmac_sha512.h

src/crypto/hmac_sha256.cpp

src/crypto/hmac_sha512.cpp

src/crypto/hkdf_sha256_32.h

src/crypto/hkdf_sha256_32.cpp

src/support/cleanse.h

src/support/cleanse.cpp

src/crypto/siphash.cpp

src/crypto/muhash.h

src/crypto/chacha20.h

src/crypto/poly1305.h

src/crypto/chacha20poly1305.h

src/crypto/chacha20poly1305.cpp

src/util/chaintype.cpp

src/util/obfuscation.h

src/util/byte_units.h

src/util/overflow.h

src/blockencodings.cpp

src/net_permissions.cpp

src/policy/packages.cpp

src/policy/rbf.cpp

src/policy/truc_policy.cpp

src/policy/ephemeral_policy.cpp

src/policy/settings.cpp

src/policy/policy.cpp

src/node/transaction.cpp

src/node/coin.cpp

src/rpc/client.cpp

src/rpc/external_signer.cpp

src/rpc/request.cpp

src/rpc/server_util.cpp

src/rpc/fees.cpp

src/rpc/output_script.cpp

src/rpc/rawtransaction_util.cpp

src/rpc/rawtransaction_util.h

src/rpc/register.h

src/rpc/request.h

src/rpc/server_util.h

src/rpc/protocol.h

src/rpc/server.h

src/rpc/signmessage.cpp

src/rpc/txoutproof.cpp

src/rpc/util.cpp

src/rpc/util.h

src/wallet/rpc/addresses.cpp

src/wallet/rpc/backup.cpp

src/wallet/rpc/coins.cpp

src/wallet/rpc/encrypt.cpp

src/wallet/rpc/signmessage.cpp

src/wallet/rpc/util.cpp

src/wallet/rpc/util.h

src/wallet/coincontrol.cpp

src/wallet/coincontrol.h

src/wallet/context.cpp

src/wallet/context.h

src/wallet/crypter.cpp

src/wallet/crypter.h

src/wallet/db.cpp

src/wallet/export.cpp

src/wallet/external_signer_scriptpubkeyman.cpp

src/wallet/rpc/spend.cpp

src/wallet/rpc/transactions.cpp

src/wallet/rpc/wallet.cpp

src/wallet/feebumper.cpp

src/wallet/feebumper.h

src/index/base.h

src/index/base.cpp

src/index/txindex.h

src/index/txindex.cpp

src/index/txindex_key.h

src/index/txospenderindex.h

src/index/txospenderindex.cpp

src/index/blockfilterindex.h

src/index/blockfilterindex.cpp

src/index/coinstatsindex.h

src/index/coinstatsindex.cpp

src/index/db_key.h

src/index/disktxpos.h

src/kernel/chain.cpp

src/kernel/chain.h

src/kernel/checks.cpp

src/kernel/checks.h

src/kernel/context.cpp

src/kernel/context.h

src/kernel/cs_main.cpp

src/kernel/cs_main.h

src/kernel/disconnected_transactions.cpp

src/kernel/disconnected_transactions.h

src/kernel/mempool_removal_reason.cpp

src/kernel/mempool_removal_reason.h

src/kernel/coinstats.cpp

src/kernel/coinstats.h

src/kernel/chainparams.cpp

src/kernel/chainparams.h

src/wallet/sqlite.cpp

src/wallet/sqlite.h

src/wallet/transaction.cpp

src/wallet/transaction.h

src/wallet/dump.cpp

src/wallet/dump.h

src/wallet/init.cpp

src/wallet/walletutil.cpp

src/wallet/walletutil.h

src/wallet/wallettool.cpp

src/wallet/wallettool.h

src/wallet/export.h

src/wallet/migrate.cpp

src/wallet/migrate.h

src/wallet/db.h

src/wallet/walletdb.cpp

src/wallet/interfaces.cpp

src/wallet/scriptpubkeyman.cpp

src/wallet/scriptpubkeyman.h

src/kernel/bitcoinkernel.cpp

src/kernel/bitcoinkernel.h

src/kernel/bitcoinkernel_wrapper.h

src/node/chainstate.cpp

src/node/chainstate.h

src/node/blockstorage.cpp

src/node/blockstorage.h

src/node/mempool_persist.cpp

src/node/mempool_persist.h

src/node/utxo_snapshot.cpp

src/node/utxo_snapshot.h

src/node/kernel_notifications.cpp

src/node/kernel_notifications.h

src/node/blockmanager_args.cpp

src/kernel/blockmanager_opts.h

src/util/expected.cpp

src/policy/settings.h

src/util/types.h

src/kernel/messagestartchars.h

src/kernel/warning.h

src/util/exception.h

src/common/license_info.h

src/node/coins_view_args.h

src/node/database_args.h

src/util/batchpriority.h

src/util/ui_change_type.h

src/node/coins_view_args.cpp

src/node/peerman_args.h

src/util/serfloat.h

src/node/blockmanager_args.h

src/node/database_args.cpp

src/util/overloaded.h

src/interfaces/types.h

src/node/chainstatemanager_args.h

src/node/minisketchwrapper.h

src/util/macros.h

src/util/syserror.h

src/common/run_command.h

src/util/bytevectorhash.cpp

src/node/mempool_persist_args.cpp

src/util/exec.h

src/util/rbf.h

src/crypto/hex_base.h

src/node/mempool_persist_args.h

src/interfaces/echo.h

src/util/any.h

src/util/batchpriority.cpp

src/util/threadnames.h

src/node/coin.h

src/node/mempool_args.h

src/util/asmap.h

src/util/bytevectorhash.h

src/node/context.cpp

src/util/insert.h

src/util/readwritefile.h

src/node/peerman_args.cpp

src/node/interface_ui.cpp

src/interfaces/handler.h

src/node/mining_args.h

src/util/hasher.cpp

src/common/init.h

src/kernel/mempool_limits.h

src/common/system.h

src/crypto/sha3.h

src/util/threadinterrupt.cpp

src/node/protocol_version.h

src/util/exception.cpp

src/common/messages.h

src/node/connection_types.cpp

src/util/bip32.h

src/common/license_info.cpp

src/util/stdmutex.h

src/common/run_command.cpp

src/util/check.cpp

src/util/golombrice.h

src/node/types.h

src/node/timeoffsets.h

src/util/readwritefile.cpp

src/util/fastrange.h

src/util/signalinterrupt.h

src/util/task_runner.h

src/util/syserror.cpp

src/common/interfaces.cpp

src/common/types.h

src/util/threadinterrupt.h

src/kernel/chainstatemanager_opts.h

src/node/psbt.h

src/policy/ephemeral_policy.h

src/util/trace.h

src/common/url.cpp

src/kernel/mempool_options.h

src/util/serfloat.cpp

src/kernel/notifications_interface.h

src/node/timeoffsets.cpp

src/node/warnings.cpp

src/util/hash_type.h

src/crypto/hex_base.cpp

src/node/eviction.h

src/util/tokenbucket.h

src/crypto/aes.h

src/common/pcp.h

src/util/feefrac.cpp

src/node/transaction.h

src/util/threadnames.cpp

src/common/signmessage.h

src/util/exec.cpp

src/util/signalinterrupt.cpp

src/clientversion.cpp

src/common/signmessage.cpp

src/compat/assumptions.h

src/compat/byteswap.h

src/deploymentinfo.cpp

src/deploymentinfo.h

src/deploymentstatus.cpp

src/deploymentstatus.h

src/dummywallet.cpp

src/external_signer.h

src/init/bitcoin-gui.cpp

src/init/bitcoin-node.cpp

src/init/bitcoin-qt.cpp

src/init/bitcoin-wallet.cpp

src/init/bitcoind.cpp

src/init/common.h

src/interfaces/init.h

src/interfaces/ipc.h

src/key_io.h

src/logging/categories.h

src/logging/timer.h

src/mapport.h

src/musig.h

src/net_permissions.h

src/netgroup.h

src/netmessagemaker.h

src/node/chainstatemanager_args.cpp

src/node/connection_types.h

src/node/context.h

src/node/interface_ui.h

src/node/mempool_args.cpp

src/node/mining_args.cpp

src/node/minisketchwrapper.cpp

src/node/txreconciliation.h

src/policy/fees/estimator_args.cpp

src/policy/fees/estimator_args.h

src/policy/fees/estimator_man.cpp

src/policy/fees/estimator_man.h

src/policy/packages.h

src/policy/rbf.h

src/policy/truc_policy.h

src/pow.h

src/primitives/block.cpp

src/randomenv.h

src/rest.h

src/script/keyorigin.h

src/script/parsing.cpp

src/script/parsing.h

src/script/script_error.h

src/script/sigcache.cpp

src/script/sigcache.h

src/script/solver.h

src/script/verify_flags.h

src/semaphore_grant.h

src/signet.h

src/span.h

src/support/allocators/secure.h

src/support/allocators/zeroafterfree.h

src/util/tokenpipe.cpp

src/util/translation.h

src/util/vector.h

src/versionbits.h

src/versionbits_impl.h

src/wallet/external_signer_scriptpubkeyman.h

src/wallet/fees.h

src/wallet/load.h

src/wallet/receive.h

src/wallet/rpc/wallet.h

src/wallet/types.h

src/walletinitinterface.h

src/zmq/zmqabstractnotifier.cpp

Independent explanations by MyBitcoinExplorer. Not affiliated with or endorsed by Bitcoin Core. Guides are educational and do not replace the source or its tests.

Bitcoin Core source © its contributors, distributed under the MIT license. Original notices and bundled third-party licenses are retained in the source tree.