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 ↗

1251    } catch (...) {
1252        // Don't try to read any more data for this request
1253        req.SetState(HTTPRequest::State::Error);
1254        // Clear the memory allocated to this client, caller must disconnect
1255        m_recv_buffer.clear();
1256        throw;
1257    }
1258
1259    // Remove the bytes read out of the buffer.
1260    m_recv_buffer.erase(
1261        m_recv_buffer.begin(),
1262        m_recv_buffer.begin() + reader.Consumed());
1263}
1264
1265bool HTTPRemoteClient::MaybeSendBytesFromBuffer()
1266{
1267    // Send as much data from this client's buffer as we can
1268    LOCK(m_send_mutex);
1269    if (!m_send_buffer.empty()) {
1270        // Socket flags (See kernel docs for send(2) and tcp(7) for more details).
1271        // MSG_NOSIGNAL: If the remote end of the connection is closed,
1272        //               fail with EPIPE (an error) as opposed to triggering
1273        //               SIGPIPE which terminates the process.
1274        // MSG_DONTWAIT: Makes the send operation non-blocking regardless of socket blocking mode.
1275        // MSG_MORE:     We do not set this flag here because http responses are usually
1276        //               small and we want the kernel to send them right away. Setting MSG_MORE
1277        //               would "cork" the socket to prevent sending out partial frames.
1278        int flags{MSG_NOSIGNAL | MSG_DONTWAIT};
1279
1280        // Try to send bytes through socket
1281        ssize_t bytes_sent;
1282        {
1283            LOCK(m_sock_mutex);
1284            bytes_sent = m_sock->Send(m_send_buffer.data(),
1285                                      m_send_buffer.size(),
1286                                      flags);
1287        }
1288
1289        if (bytes_sent < 0) {
1290            // Something went wrong
1291            const int err{WSAGetLastError()};
1292            if (!IOErrorIsPermanent(err)) {
1293                // The error can be safely ignored, try the send again on the next I/O loop.
1294                m_send_ready = true;
1295                m_connection_busy = true;
1296                return true;
1297            } else {
1298                // Unrecoverable error, log and disconnect client.
1299                LogDebug(
1300                    BCLog::HTTP,
1301                    "Error sending HTTP response data to client %s (id=%llu): %s",
1302                    m_origin,
1303                    m_id,
1304                    NetworkErrorString(err));
1305                m_send_ready = false;
1306                m_disconnect = true;
1307
1308                // Do not attempt to read from this client.
1309                return false;
1310            }
1311        }
1312
1313        // Successful send, remove sent bytes from our local buffer.
1314        Assume(static_cast<size_t>(bytes_sent) <= m_send_buffer.size());
1315        m_send_buffer.erase(m_send_buffer.begin(),
1316                            m_send_buffer.begin() + bytes_sent);
1317
1318        LogDebug(
1319            BCLog::HTTP,
1320            "Sent %d bytes to client %s (id=%llu)",
1321            bytes_sent,
1322            m_origin,
1323            m_id);
1324
1325        // This check is inside the if(!empty) block meaning "there was data but now its gone".
1326        // We wouldn't want to change the flags if MaybeSendBytesFromBuffer() was called
1327        // on an already-empty m_send_buffer because the connection might have just been opened.
1328        if (m_send_buffer.empty()) {
1329            m_send_ready = false;
1330            m_connection_busy = false;
1331
1332            // Our work is done here
1333            if (!m_keep_alive) {
1334                m_disconnect = true;
1335                // Do not attempt to read from this client.
1336                return false;
1337            }
1338        } else {
1339            // The send buffer isn't flushed yet, try to push more on the next loop.
1340            m_send_ready = true;
1341            m_connection_busy = true;
1342        }
1343
1344        // Finally, reset idle timeout
1345        m_idle_since = Now<SteadySeconds>();
1346    }
1347
1348    return true;
1349}
1350
1351bool InitHTTPServer()
1352{
1353    // Create HTTPServer
1354    g_http_server = std::make_unique<HTTPServer>(MaybeDispatchRequestToWorker);
1355
1356    if (!g_http_server->InitHTTPAllowList()) {
1357        return false;
1358    }
1359
1360    g_http_server->SetServerTimeout(std::chrono::seconds(gArgs.GetIntArg("-rpcservertimeout", DEFAULT_HTTP_SERVER_TIMEOUT)));
1361    g_http_server->SetMaxConnections(std::max(gArgs.GetArg<int>("-rpcmaxconnections", DEFAULT_MAX_HTTP_CONNECTIONS), 1));
1362
1363    // Bind HTTP server to specified addresses
1364    std::vector<std::pair<std::string, uint16_t>> endpoints{GetBindAddresses()};
1365    bool bind_success{false};
1366    for (const auto& [address_string, port] : endpoints) {
1367        LogInfo("Binding RPC on address %s port %i", address_string, port);
1368        const std::optional<CService> addr{Lookup(address_string, port, false)};
1369        if (addr) {
1370            if (addr->IsBindAny()) {
1371                LogWarning("The RPC server is not safe to expose to untrusted networks such as the public internet");
1372            }
1373            auto result{g_http_server->BindAndStartListening(addr.value())};
1374            if (!result) {
1375                LogWarning("Binding RPC on address %s failed: %s", addr->ToStringAddrPort(), result.error());
1376            } else {
1377                bind_success = true;
1378            }
1379        } else {
1380            LogWarning("Could not bind RPC on address %s port %i: Address lookup failed.", address_string, port);
1381        }
1382    }
1383
1384    if (!bind_success) {
1385        LogError("Unable to bind any endpoint for RPC server");
1386        return false;
1387    }
1388
1389    LogDebug(BCLog::HTTP, "Initialized HTTP server");
1390
1391    g_max_queue_depth = std::max(gArgs.GetArg<int>("-rpcworkqueue", DEFAULT_HTTP_WORKQUEUE), 1);
1392    LogDebug(BCLog::HTTP, "set work queue of depth %d\n", g_max_queue_depth);
1393
1394    return true;
1395}
1396
1397void StartHTTPServer()
1398{
1399    auto rpcThreads{std::max(gArgs.GetArg<int>("-rpcthreads", DEFAULT_HTTP_THREADS), 1)};
1400    LogInfo("Starting HTTP server with %d worker threads", rpcThreads);
1401    g_threadpool_http.Start(rpcThreads);
1402    g_http_server->StartSocketsThreads();
1403}
1404
1405void InterruptHTTPServer()
1406{
1407    LogDebug(BCLog::HTTP, "Interrupting HTTP server");
1408    if (g_http_server) {
1409        // Reject all new requests
1410        g_http_server->SetRequestHandler(RejectRequest);
1411    }
1412
1413    // Interrupt pool after disabling requests
1414    g_threadpool_http.Interrupt();
1415}
1416
1417void StopHTTPServer()
1418{
1419    LogDebug(BCLog::HTTP, "Stopping HTTP server");
1420
1421    LogDebug(BCLog::HTTP, "Waiting for HTTP worker threads to exit\n");
1422    g_threadpool_http.Stop();
1423
1424    if (g_http_server) {
1425        // Must precede DisconnectAllClients(): a connection accepted after
1426        // GetConnectionsCount() returns 0 would survive into the destructor.
1427        g_http_server->StopAccepting();
1428        // Disconnect clients as their remaining responses are flushed
1429        g_http_server->DisconnectAllClients();
1430        // Wait 30 seconds for all disconnections
1431        LogDebug(BCLog::HTTP, "Waiting for HTTP clients to disconnect gracefully");
1432        const auto deadline{NodeClock::now() + 30s};
1433        while (g_http_server->GetConnectionsCount() != 0) {
1434            if (NodeClock::now() > deadline) {
1435                LogWarning("Timeout waiting for HTTP clients to disconnect gracefully, continuing shutdown");
1436                break;
1437            }
1438            std::this_thread::sleep_for(50ms);
1439        }
1440        // Break HTTPServer I/O loop: stop accepting connections, sending and receiving data
1441        g_http_server->InterruptNet();
1442        // Wait for HTTPServer I/O thread to exit
1443        g_http_server->JoinSocketsThreads();
1444        // Force-remove any clients that survived the graceful wait
1445        g_http_server->ClearConnectedClients();
1446        // Close all listening sockets
1447        g_http_server->StopListening();
1448    }
1449    LogDebug(BCLog::HTTP, "Stopped HTTP server");
1450}
1451

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 6

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.