BITCOIN MAINNETLive explorer status

Explorer Mempool Feed Forum Visualizer Receipts Tools Learn Code

Inside Bitcoin

Opening the selected file…

₿MyBitcoinExplorer

Bitcoin, in focus.
Explore the network. Understand the connections.

Explore Bitcoin with clarity.

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.

bitcoin / bitcoinstable

Find a file

▤ arith_uint256.hGuide

▤ bitcoin-chainstate.cpp

▤ bitcoin-cli-res.rc

▤ bitcoin-cli.cppGuide

▤ bitcoin-res.rc

▤ bitcoin-tx-res.rc

▤ bitcoin-tx.cpp

▤ bitcoin-util-res.rc

▤ bitcoin-util.cpp

▤ bitcoin-wallet-res.rc

▤ blockencodings.cppGuide

▤ blockencodings.hGuide

▤ blockfilter.cppGuide

▤ blockfilter.hGuide

▤ chain.cppGuide

▤ chain.h

▤ chainparams.cppGuide

▤ chainparams.hGuide

▤ chainparamsbase.cppGuide

▤ chainparamsbase.hGuide

▤ chainparamsseeds.h

▤ checkqueue.hGuide

▤ clientversion.cppGuide

▤ clientversion.hGuide

▤ cluster_linearize.h

▤ CMakeLists.txt

▤ coins.cppGuide

▤ coins.hGuide

▤ compressor.cppGuide

▤ compressor.hGuide

▤ core_io.cpp

▤ core_io.hGuide

▤ core_memusage.hGuide

▤ cuckoocache.h

▤ dbwrapper.cpp

▤ dbwrapper.hGuide

▤ deploymentinfo.cppGuide

▤ deploymentinfo.hGuide

▤ deploymentstatus.cppGuide

▤ deploymentstatus.hGuide

▤ dummywallet.cppGuide

▤ external_signer.cpp

▤ external_signer.hGuide

▤ merkleblock.cppGuide

▤ merkleblock.hGuide

▤ musig.cpp

▤ musig.hGuide

▤ net_permissions.cppGuide

▤ net_permissions.hGuide

▤ net_processing.cppGuide

▤ netaddress.cppGuide

▤ netmessagemaker.hGuide

▤ noui.cppGuide

▤ noui.hGuide

▤ outputtype.cppGuide

▤ private_broadcast.cpp

▤ private_broadcast.h

▤ semaphore_grant.hGuide

▤ threadsafety.hGuide

▤ tinyformat.h

▤ torcontrol.cppGuide

▤ validation.cppGuide

▤ validation.h

▤ validationinterface.cpp

▤ validationinterface.h

▤ versionbits_impl.hGuide

▤ versionbits.cpp

▤ versionbits.hGuide

▤ walletinitinterface.hGuide

▤ CMakeLists.txtGuide

▤ libbitcoinkernel.pc.in

bitcoin / src / httpserver.cpp

Download source ↓

57,277 bytes · SHA-256 9d692896a72b887a… · View upstream ↗

751            LogDebug(BCLog::HTTP,
752                     "Cannot set IPV6_V6ONLY on %s listen socket: %s, continuing anyway",
753                     to.ToStringAddrPort(),
754                     NetworkErrorString(WSAGetLastError()));
755        }
756#endif
757#ifdef WIN32
758        int prot_level{PROTECTION_LEVEL_UNRESTRICTED};
759        if (sock->SetSockOpt(IPPROTO_IPV6,
760                             IPV6_PROTECTION_LEVEL,
761                             &prot_level,
762                             sizeof(prot_level)) == SOCKET_ERROR) {
763            LogDebug(BCLog::HTTP,
764                     "Cannot set IPV6_PROTECTION_LEVEL on %s listen socket: %s, continuing anyway",
765                     to.ToStringAddrPort(),
766                     NetworkErrorString(WSAGetLastError()));
767        }
768#endif
769    }
770
771    if (sock->Bind(sa, len) == SOCKET_ERROR) {
772        const int err{WSAGetLastError()};
773        if (err == WSAEADDRINUSE) {
774            return util::Unexpected{strprintf("Unable to bind to %s on this computer. %s is probably already running.",
775                                              to.ToStringAddrPort(),
776                                              CLIENT_NAME)};
777        } else {
778            return util::Unexpected{strprintf("Unable to bind to %s on this computer (bind returned error %s)",
779                                              to.ToStringAddrPort(),
780                                              NetworkErrorString(err))};
781        }
782    }
783
784    // Listen for incoming connections
785    if (sock->Listen(SOMAXCONN) == SOCKET_ERROR) {
786        return util::Unexpected{strprintf("Cannot listen on %s: %s",
787                                          to.ToStringAddrPort(),
788                                          NetworkErrorString(WSAGetLastError()))};
789    }
790
791    m_listen.emplace_back(std::move(sock));
792
793    return {};
794}
795
796void HTTPServer::StopListening()
797{
798    m_listen.clear();
799}
800
801void HTTPServer::StartSocketsThreads()
802{
803    // The socket handler reads m_allow_subnets in ClientAllowed(). InitHTTPAllowList()
804    // must have populated it first; localhost entries are always added, so an empty
805    // list means it was never called and every connection is rejected.
806    Assume(!m_allow_subnets.empty());
807
808    m_thread_socket_handler = std::thread(&util::TraceThread,
809                                          "http",
810                                          [this] { ThreadSocketHandler(); });
811}
812
813void HTTPServer::JoinSocketsThreads()
814{
815    if (m_thread_socket_handler.joinable()) {
816        m_thread_socket_handler.join();
817    }
818}
819
820std::unique_ptr<Sock> HTTPServer::AcceptConnection(const Sock& listen_sock, CService& addr)
821{
822    // Make sure we only operate on our own listening sockets
823    Assume(std::ranges::any_of(m_listen, [&](const auto& sock) { return sock.get() == &listen_sock; }));
824
825    sockaddr_storage storage;
826    socklen_t len{sizeof(storage)};
827    auto sa = reinterpret_cast<sockaddr*>(&storage);
828
829    auto sock{listen_sock.Accept(sa, &len)};
830
831    if (!sock) {
832        const int err{WSAGetLastError()};
833        if (err != WSAEWOULDBLOCK) {
834            LogDebug(BCLog::HTTP,
835                     "Cannot accept new connection: %s",
836                     NetworkErrorString(err));
837        }
838        return {};
839    }
840
841    // The OS handed us a valid socket but we can't determine its source address.
842    if (!addr.SetSockAddr(sa, len)) {
843        LogDebug(BCLog::HTTP,
844                 "Unknown socket family");
845    }
846
847    // Early address-based allow check
848    if (!ClientAllowed(addr)) {
849        LogDebug(BCLog::HTTP, "Connection from %s rejected: Client network is not allowed HTTP access\n",
850                 addr.ToStringAddrPort());
851        // Socket destroyed, connection aborted
852        return {};
853    }
854
855    return sock;
856}
857
858HTTPServer::Id HTTPServer::GetNewId()
859{
860    return m_next_id.fetch_add(1, std::memory_order_relaxed);
861}
862
863void HTTPServer::NewSockAccepted(std::unique_ptr<Sock>&& sock, const CService& addr)
864{
865    if (!sock->IsSelectable()) {
866        LogDebug(BCLog::HTTP,
867                 "connection from %s dropped: non-selectable socket",
868                 addr.ToStringAddrPort());
869        return;
870    }
871
872    // According to the internet TCP_NODELAY is not carried into accepted sockets
873    // on all platforms.  Set it again here just to be sure.
874    if (sock->SetSockOpt(IPPROTO_TCP, TCP_NODELAY, &SOCKET_OPTION_TRUE, sizeof(SOCKET_OPTION_TRUE)) == SOCKET_ERROR) {
875        LogDebug(BCLog::HTTP, "connection from %s: unable to set TCP_NODELAY, continuing anyway",
876                 addr.ToStringAddrPort());
877    }
878
879    const Id id{GetNewId()};
880
881    m_connected.push_back(std::make_shared<HTTPRemoteClient>(id, addr, std::move(sock)));
882    // Report back to the main thread
883    m_connected_size.fetch_add(1, std::memory_order_relaxed);
884
885    LogDebug(BCLog::HTTP,
886             "HTTP Connection accepted from %s (id=%llu)",
887             addr.ToStringAddrPort(), id);
888}
889
890void HTTPServer::SocketHandlerConnected(const IOReadiness& io_readiness) const
891{
892    for (const auto& [sock, events] : io_readiness.events_per_sock) {
893        if (m_interrupt_net) {
894            return;
895        }
896
897        auto it{io_readiness.httpclients_per_sock.find(sock)};
898        if (it == io_readiness.httpclients_per_sock.end()) {
899            continue;
900        }
901        const std::shared_ptr<HTTPRemoteClient>& client{it->second};
902
903        bool send_ready = events.occurred & Sock::SendEvent;
904        bool recv_ready = events.occurred & Sock::RecvEvent;
905        bool err_ready = events.occurred & Sock::ErrorEvent;
906
907        if (send_ready) {
908            // Try to send as much data as is ready for this client.
909            // If there's an error we can skip the receive phase for this client
910            // because we need to disconnect.
911            if (!client->MaybeSendBytesFromBuffer()) {
912                recv_ready = false;
913            }
914        }
915
916        if (recv_ready || err_ready) {
917            client->Receive();
918        }
919        // Process as much received data as we can.
920        // This executes for every client whether or not reading or writing
921        // took place because it also (might) parse a request we have already
922        // received and pass it to a worker thread.
923        if (std::unique_ptr<HTTPRequest> request{HTTPRemoteClient::TryReadRequest(client)})
924        {
925            LOCK(m_request_dispatcher_mutex);
926            m_request_dispatcher(std::move(request));
927        }
928    }
929}
930
931void HTTPRemoteClient::Receive()
932{
933    char buf[0x10000]; // typical socket buffer is 8K-64K
934
935    const ssize_t nrecv{WITH_LOCK(
936        m_sock_mutex,
937        return m_sock->Recv(buf, sizeof(buf), MSG_DONTWAIT);)};
938
939    if (nrecv < 0) {
940        const int err = WSAGetLastError();
941        if (IOErrorIsPermanent(err)) {
942            LogDebug(
943                BCLog::HTTP,
944                "Permanent read error from %s (id=%llu): %s",
945                m_origin,
946                m_id,
947                NetworkErrorString(err));
948            m_disconnect = true;
949        }
950    } else if (nrecv == 0) {
951        LogDebug(
952            BCLog::HTTP,
953            "Received EOF from %s (id=%llu)",
954            m_origin,
955            m_id);
956        m_disconnect = true;
957    } else {
958        // Reset idle timeout
959        m_idle_since = Now<SteadySeconds>();
960
961        // Prevent disconnect until all requests are completely handled.
962        m_connection_busy = true;
963
964        // Copy data from socket buffer to client receive buffer
965        m_recv_buffer.insert(
966            m_recv_buffer.end(),
967            buf,
968            buf + nrecv);
969
970        m_total_bytes_received += static_cast<uint64_t>(nrecv);
971        LogDebug(
972            BCLog::HTTP,
973            "Received %d bytes from %s (id=%llu): total=%llu buffered=%zu",
974            nrecv,
975            m_origin,
976            m_id,
977            m_total_bytes_received,
978            m_recv_buffer.size());
979    }
980}
981
982void HTTPServer::SocketHandlerListening(const Sock::EventsPerSock& events_per_sock)
983{
984    if (m_stop_accepting) return;
985    for (const auto& sock : m_listen) {
986        if (m_interrupt_net) {
987            return;
988        }
989        const auto it = events_per_sock.find(sock);
990        if (it != events_per_sock.end() && it->second.occurred & Sock::RecvEvent) {
991            // Drain all pending connections from this socket up to the limit.
992            // Stop early if the kernel queue is empty (AcceptConnection returns null)
993            // or if accepting the last connection brought us to the limit.
994            while (GetConnectionsCount() < static_cast<size_t>(m_rpcmaxconnections)) {
995                CService addr_accepted;
996                auto sock_accepted{AcceptConnection(*sock, addr_accepted)};
997                if (!sock_accepted) break;
998                NewSockAccepted(std::move(sock_accepted), addr_accepted);
999            }
1000        }

A READING COMPANION

Source available. Guide coming next.

This file is included in the stable source snapshot. A file-specific guide has not been published yet.

440 guided files · 2,580 pending. Guides cover key sections, not every line.

cmake/bitcoin-build-config.h.in src/consensus/amount.h src/consensus/consensus.h src/primitives/block.h src/primitives/transaction.h src/crypto/sha256.h src/util/moneystr.h src/clientversion.h src/uint256.h src/script/script.h src/policy/policy.h CMakeLists.txt README.md COPYING src/consensus/tx_check.cpp src/consensus/tx_verify.cpp src/consensus/merkle.cpp src/pow.cpp src/validation.cpp src/script/interpreter.cpp src/script/solver.cpp src/script/sign.cpp src/key_io.cpp src/net.cpp src/net_processing.cpp src/netaddress.cpp src/protocol.h src/wallet/wallet.cpp src/wallet/spend.cpp

← Previous 250 linesCode page 4Next 250 lines →

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.