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

▤ batchpriority.cppGuide

▤ batchpriority.hGuide

▤ bytevectorhash.cppGuide

▤ bytevectorhash.hGuide

▤ readwritefile.cppGuide

▤ readwritefile.hGuide

▤ result.hGuide

▤ serfloat.cppGuide

▤ serfloat.hGuide

▤ signalinterrupt.cppGuide

▤ signalinterrupt.hGuide

▤ threadinterrupt.cppGuide

▤ threadinterrupt.hGuide

▤ threadnames.cppGuide

▤ ui_change_type.hGuide

▤ 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 / util / sock.cpp

Download source ↓

12,666 bytes · SHA-256 a6e109f09060dfea… · View upstream ↗

251
252    return true;
253#endif /* USE_POLL */
254}
255
256void Sock::SendComplete(std::span<const unsigned char> data,
257                        std::chrono::milliseconds timeout,
258                        CThreadInterrupt& interrupt) const
259{
260    const auto deadline = GetTime<std::chrono::milliseconds>() + timeout;
261    size_t sent{0};
262
263    for (;;) {
264        const ssize_t ret{Send(data.data() + sent, data.size() - sent, MSG_NOSIGNAL)};
265
266        if (ret > 0) {
267            sent += static_cast<size_t>(ret);
268            if (sent == data.size()) {
269                break;
270            }
271        } else {
272            const int err{WSAGetLastError()};
273            if (IOErrorIsPermanent(err)) {
274                throw std::runtime_error(strprintf("send(): %s", NetworkErrorString(err)));
275            }
276        }
277
278        const auto now = GetTime<std::chrono::milliseconds>();
279
280        if (now >= deadline) {
281            throw std::runtime_error(strprintf(
282                "Send timeout (sent only %u of %u bytes before that)", sent, data.size()));
283        }
284
285        if (interrupt) {
286            throw std::runtime_error(strprintf(
287                "Send interrupted (sent only %u of %u bytes before that)", sent, data.size()));
288        }
289
290        // Wait for a short while (or the socket to become ready for sending) before retrying
291        // if nothing was sent.
292        const auto wait_time = std::min(deadline - now, std::chrono::milliseconds{MAX_WAIT_FOR_IO});
293        (void)Wait(wait_time, SendEvent);
294    }
295}
296
297void Sock::SendComplete(std::span<const char> data,
298                        std::chrono::milliseconds timeout,
299                        CThreadInterrupt& interrupt) const
300{
301    SendComplete(MakeUCharSpan(data), timeout, interrupt);
302}
303
304std::string Sock::RecvUntilTerminator(uint8_t terminator,
305                                      std::chrono::milliseconds timeout,
306                                      CThreadInterrupt& interrupt,
307                                      size_t max_data) const
308{
309    const auto deadline = GetTime<std::chrono::milliseconds>() + timeout;
310    std::string data;
311    bool terminator_found{false};
312
313    // We must not consume any bytes past the terminator from the socket.
314    // One option is to read one byte at a time and check if we have read a terminator.
315    // However that is very slow. Instead, we peek at what is in the socket and only read
316    // as many bytes as possible without crossing the terminator.
317    // Reading 64 MiB of random data with 262526 terminator chars takes 37 seconds to read
318    // one byte at a time VS 0.71 seconds with the "peek" solution below. Reading one byte
319    // at a time is about 50 times slower.
320
321    for (;;) {
322        if (data.size() >= max_data) {
323            throw std::runtime_error(
324                strprintf("Received too many bytes without a terminator (%u)", data.size()));
325        }
326
327        char buf[512];
328
329        const ssize_t peek_ret{Recv(buf, std::min(sizeof(buf), max_data - data.size()), MSG_PEEK)};
330
331        switch (peek_ret) {
332        case -1: {
333            const int err{WSAGetLastError()};
334            if (IOErrorIsPermanent(err)) {
335                throw std::runtime_error(strprintf("recv(): %s", NetworkErrorString(err)));
336            }
337            break;
338        }
339        case 0:
340            throw std::runtime_error("Connection unexpectedly closed by peer");
341        default:
342            auto end = buf + peek_ret;
343            auto terminator_pos = std::find(buf, end, terminator);
344            terminator_found = terminator_pos != end;
345
346            const size_t try_len{terminator_found ? terminator_pos - buf + 1 :
347                                                    static_cast<size_t>(peek_ret)};
348
349            const ssize_t read_ret{Recv(buf, try_len, 0)};
350
351            if (read_ret < 0 || static_cast<size_t>(read_ret) != try_len) {
352                throw std::runtime_error(
353                    strprintf("recv() returned %u bytes on attempt to read %u bytes but previous "
354                              "peek claimed %u bytes are available",
355                              read_ret, try_len, peek_ret));
356            }
357
358            // Don't include the terminator in the output.
359            const size_t append_len{terminator_found ? try_len - 1 : try_len};
360
361            data.append(buf, buf + append_len);
362
363            if (terminator_found) {
364                return data;
365            }
366        }
367
368        const auto now = GetTime<std::chrono::milliseconds>();
369
370        if (now >= deadline) {
371            throw std::runtime_error(strprintf(
372                "Receive timeout (received %u bytes without terminator before that)", data.size()));
373        }
374
375        if (interrupt) {
376            throw std::runtime_error(strprintf(
377                "Receive interrupted (received %u bytes without terminator before that)",
378                data.size()));
379        }
380
381        // Wait for a short while (or the socket to become ready for reading) before retrying.
382        const auto wait_time = std::min(deadline - now, std::chrono::milliseconds{MAX_WAIT_FOR_IO});
383        (void)Wait(wait_time, RecvEvent);
384    }
385}
386
387bool Sock::IsConnected(std::string& errmsg) const
388{
389    if (m_socket == INVALID_SOCKET) {
390        errmsg = "not connected";
391        return false;
392    }
393
394    char c;
395    switch (Recv(&c, sizeof(c), MSG_PEEK)) {
396    case -1: {
397        const int err = WSAGetLastError();
398        if (IOErrorIsPermanent(err)) {
399            errmsg = NetworkErrorString(err);
400            return false;
401        }
402        return true;
403    }
404    case 0:
405        errmsg = "closed";
406        return false;
407    default:
408        return true;
409    }
410}
411
412void Sock::Close()
413{
414    if (m_socket == INVALID_SOCKET) {
415        return;
416    }
417#ifdef WIN32
418    int ret = closesocket(m_socket);
419#else
420    int ret = close(m_socket);
421#endif
422    if (ret) {
423        LogWarning("Error closing socket %d: %s", m_socket, NetworkErrorString(WSAGetLastError()));
424    }
425    m_socket = INVALID_SOCKET;
426}
427
428bool Sock::operator==(SOCKET s) const
429{
430    return m_socket == s;
431};
432
433std::string NetworkErrorString(int err)
434{
435#if defined(WIN32)
436    return Win32ErrorString(err);
437#else
438    // On BSD sockets implementations, NetworkErrorString is the same as SysErrorString.
439    return SysErrorString(err);
440#endif
441}
442

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 2

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.