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 server340 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.

81,868 bytes · SHA-256 056a59bbafb97c33… · View upstream ↗

1// Copyright (c) 2009-2010 Satoshi Nakamoto
2// Copyright (c) 2009-present The Bitcoin Core developers
3// Distributed under the MIT software license, see the accompanying
4// file COPYING or http://www.opensource.org/licenses/mit-license.php.
5
6#ifndef BITCOIN_NET_H
7#define BITCOIN_NET_H
8
9#include <bip324.h>
10#include <chainparams.h>
11#include <common/bloom.h>
12#include <compat/compat.h>
13#include <consensus/amount.h>
14#include <crypto/siphash.h>
15#include <hash.h>
16#include <i2p.h>
17#include <kernel/messagestartchars.h>
18#include <net_permissions.h>
19#include <netaddress.h>
20#include <netbase.h>
21#include <netgroup.h>
22#include <node/connection_types.h>
23#include <node/protocol_version.h>
24#include <policy/feerate.h>
25#include <protocol.h>
26#include <random.h>
27#include <semaphore_grant.h>
28#include <span.h>
29#include <streams.h>
30#include <sync.h>
31#include <uint256.h>
32#include <util/check.h>
33#include <util/sock.h>
34#include <util/threadinterrupt.h>
35
36#include <atomic>
37#include <condition_variable>
38#include <cstdint>
39#include <deque>
40#include <functional>
41#include <list>
42#include <map>
43#include <memory>
44#include <optional>
45#include <queue>
46#include <string_view>
47#include <thread>
48#include <unordered_set>
49#include <vector>
50
51class AddrMan;
52class BanMan;
53class CChainParams;
54class CNode;
55class CScheduler;
56struct bilingual_str;
57
58/** Time after which to disconnect, after waiting for a ping response (or inactivity). */
59inline constexpr std::chrono::minutes TIMEOUT_INTERVAL{20};
60/** Run the feeler connection loop once every 2 minutes. **/
61inline constexpr auto FEELER_INTERVAL = 2min;
62/** Run the extra block-relay-only connection loop once every 5 minutes. **/
63inline constexpr auto EXTRA_BLOCK_RELAY_ONLY_PEER_INTERVAL = 5min;
64/** Maximum length of incoming protocol messages (no message over 4 MB is currently acceptable). */
65inline constexpr unsigned int MAX_PROTOCOL_MESSAGE_LENGTH = 4 * 1000 * 1000;
66/** Maximum length of the user agent string in `version` message */
67inline constexpr unsigned int MAX_SUBVERSION_LENGTH = 256;
68/** Maximum number of automatic outgoing nodes over which we'll relay everything (blocks, tx, addrs, etc) */
69inline constexpr int MAX_OUTBOUND_FULL_RELAY_CONNECTIONS = 8;
70/** Maximum number of addnode outgoing nodes */
71inline constexpr int MAX_ADDNODE_CONNECTIONS = 8;
72/** Maximum number of block-relay-only outgoing connections */
73inline constexpr int MAX_BLOCK_RELAY_ONLY_CONNECTIONS = 2;
74/** Maximum number of feeler connections */
75inline constexpr int MAX_FEELER_CONNECTIONS = 1;
76/** Maximum number of private broadcast connections */
77inline constexpr size_t MAX_PRIVATE_BROADCAST_CONNECTIONS{64};
78/** -listen default */
79inline constexpr bool DEFAULT_LISTEN = true;
80/** The maximum number of peer connections to maintain. */
81inline constexpr unsigned int DEFAULT_MAX_PEER_CONNECTIONS{200};
82/** Maximum value of -maxconnections */
83inline constexpr int MAX_PEER_CONNECTIONS{2'000};
84/** Default percentage of inbound connection slots that tx-relaying peers can use */
85inline constexpr int DEFAULT_FULL_RELAY_INBOUND_PCT{50};
86/** The default for -maxuploadtarget. 0 = Unlimited */
87inline const std::string DEFAULT_MAX_UPLOAD_TARGET{"0M"};
88/** Default for blocks only*/
89inline constexpr bool DEFAULT_BLOCKSONLY = false;
90/** -peertimeout default */
91inline constexpr int64_t DEFAULT_PEER_CONNECT_TIMEOUT = 60;
92/** Default for -privatebroadcast. */
93inline constexpr bool DEFAULT_PRIVATE_BROADCAST{false};
94/** Number of file descriptors required for message capture **/
95inline constexpr int NUM_FDS_MESSAGE_CAPTURE = 1;
96/** Interval for ASMap Health Check **/
97inline constexpr std::chrono::hours ASMAP_HEALTH_CHECK_INTERVAL{24};
98
99inline constexpr bool DEFAULT_FORCEDNSSEED{false};
100inline constexpr bool DEFAULT_DNSSEED{true};
101inline constexpr bool DEFAULT_FIXEDSEEDS{true};
102inline constexpr size_t DEFAULT_MAXRECEIVEBUFFER = 5 * 1000;
103inline constexpr size_t DEFAULT_MAXSENDBUFFER    = 1 * 1000;
104
105inline constexpr bool DEFAULT_V2_TRANSPORT{true};
106
107typedef int64_t NodeId;
108
109struct AddedNodeParams {
110    std::string m_added_node;
111    bool m_use_v2transport;
112};
113
114struct AddedNodeInfo {
115    AddedNodeParams m_params;
116    CService resolvedAddress;
117    bool fConnected;
118    bool fInbound;
119};
120
121class CNodeStats;
122class CClientUIInterface;
123
124struct CSerializedNetMsg {
125    CSerializedNetMsg() = default;
126    CSerializedNetMsg(CSerializedNetMsg&&) = default;
127    CSerializedNetMsg& operator=(CSerializedNetMsg&&) = default;
128    // No implicit copying, only moves.
129    CSerializedNetMsg(const CSerializedNetMsg& msg) = delete;
130    CSerializedNetMsg& operator=(const CSerializedNetMsg&) = delete;
131
132    CSerializedNetMsg Copy() const
133    {
134        CSerializedNetMsg copy;
135        copy.data = data;
136        copy.m_type = m_type;
137        return copy;
138    }
139
140    std::vector<unsigned char> data;
141    std::string m_type;
142
143    /** Compute total memory usage of this object (own memory + any dynamic memory). */
144    size_t GetMemoryUsage() const noexcept;
145};
146
147/**
148 * Look up IP addresses from all interfaces on the machine and add them to the
149 * list of local addresses to self-advertise.
150 * The loopback interface is skipped.
151 */
152void Discover();
153
154uint16_t GetListenPort();
155
156enum
157{
158    LOCAL_NONE,   // unknown
159    LOCAL_IF,     // address a local interface listens on
160    LOCAL_BIND,   // address explicit bound to
161    LOCAL_MAPPED, // address reported by PCP
162    LOCAL_MANUAL, // address explicitly specified (-externalip=)
163
164    LOCAL_MAX
165};
166
167/** Returns a local address that we should advertise to this peer. */
168std::optional<CService> GetLocalAddrForPeer(CNode& node);
169
170void ClearLocal();
171bool AddLocal(const CService& addr, int nScore = LOCAL_NONE, bool add_even_if_unreachable = false);
172bool AddLocal(const CNetAddr& addr, int nScore = LOCAL_NONE, bool add_even_if_unreachable = false);
173void RemoveLocal(const CService& addr);
174bool SeenLocal(const CService& addr);
175bool IsLocal(const CService& addr);
176CService GetLocalAddress(const CNode& peer);
177
178extern bool fDiscover;
179extern bool fListen;
180
181/** Subversion as sent to the P2P network in `version` messages */
182extern std::string strSubVersion;
183
184struct LocalServiceInfo {
185    int nScore;
186    uint16_t nPort;
187};
188
189extern GlobalMutex g_maplocalhost_mutex;
190extern std::map<CNetAddr, LocalServiceInfo> mapLocalHost GUARDED_BY(g_maplocalhost_mutex);
191
192extern const std::string NET_MESSAGE_TYPE_OTHER;
193using mapMsgTypeSize = std::map</* message type */ std::string, /* total bytes */ uint64_t>;
194
195class CNodeStats
196{
197public:
198    NodeId nodeid;
199    NodeClock::time_point m_last_send;
200    NodeClock::time_point m_last_recv;
201    std::chrono::seconds m_last_tx_time;
202    std::chrono::seconds m_last_block_time;
203    NodeClock::time_point m_connected;
204    std::string m_addr_name;
205    int nVersion;
206    std::string cleanSubVer;
207    bool fInbound;
208    // We requested high bandwidth connection to peer
209    bool m_bip152_highbandwidth_to;
210    // Peer requested high bandwidth connection
211    bool m_bip152_highbandwidth_from;
212    uint64_t nSendBytes;
213    mapMsgTypeSize mapSendBytesPerMsgType;
214    uint64_t nRecvBytes;
215    mapMsgTypeSize mapRecvBytesPerMsgType;
216    NetPermissionFlags m_permission_flags;
217    NodeClock::duration m_last_ping_time;
218    NodeClock::duration m_min_ping_time;
219    // Our address, as reported by the peer
220    std::string addrLocal;
221    // Address of this peer
222    CAddress addr;
223    // Bind address of our side of the connection
224    CService addrBind;
225    // Network the peer connected through
226    Network m_network;
227    uint32_t m_mapped_as;
228    ConnectionType m_conn_type;
229    /** Transport protocol type. */
230    TransportProtocolType m_transport_type;
231    /** BIP324 session id string in hex, if any. */
232    std::string m_session_id;
233};
234
235
236/** Transport protocol agnostic message container.
237 * Ideally it should only contain receive time, payload,
238 * type and size.
239 */
240class CNetMessage
241{
242public:
243    DataStream m_recv;                   //!< received message data
244    /// time of message receipt
245    NodeClock::time_point m_time{NodeClock::epoch};
246    uint32_t m_message_size{0};          //!< size of the payload
247    uint32_t m_raw_message_size{0};      //!< used wire size of the message (including header/checksum)
248    std::string m_type;
249
250    explicit CNetMessage(DataStream&& recv_in) : m_recv(std::move(recv_in)) {}

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

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.