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

▤ autocompact_test.cc

▤ fault_injection_test.cc

▤ version_edit_test.cc

▤ version_edit.cc

▤ version_edit.h

▤ version_set_test.cc

▤ version_set.cc

▤ version_set.h

▤ write_batch_internal.h

▤ write_batch_test.cc

▤ 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 / leveldb / db / fault_injection_test.cc

Download source ↓

15,807 bytes · SHA-256 484b92479720d1a0… · View upstream ↗

251  WritableFile* actual_writable_file;
252  Status s = target()->NewAppendableFile(fname, &actual_writable_file);
253  if (s.ok()) {
254    FileState state(fname);
255    state.pos_ = 0;
256    {
257      MutexLock l(&mutex_);
258      if (db_file_state_.count(fname) == 0) {
259        new_files_since_last_dir_sync_.insert(fname);
260      } else {
261        state = db_file_state_[fname];
262      }
263    }
264    *result = new TestWritableFile(state, actual_writable_file, this);
265  }
266  return s;
267}
268
269Status FaultInjectionTestEnv::DropUnsyncedFileData() {
270  Status s;
271  MutexLock l(&mutex_);
272  for (const auto& kvp : db_file_state_) {
273    if (!s.ok()) {
274      break;
275    }
276    const FileState& state = kvp.second;
277    if (!state.IsFullySynced()) {
278      s = state.DropUnsyncedData();
279    }
280  }
281  return s;
282}
283
284void FaultInjectionTestEnv::DirWasSynced() {
285  MutexLock l(&mutex_);
286  new_files_since_last_dir_sync_.clear();
287}
288
289bool FaultInjectionTestEnv::IsFileCreatedSinceLastDirSync(
290    const std::string& filename) {
291  MutexLock l(&mutex_);
292  return new_files_since_last_dir_sync_.find(filename) !=
293         new_files_since_last_dir_sync_.end();
294}
295
296void FaultInjectionTestEnv::UntrackFile(const std::string& f) {
297  MutexLock l(&mutex_);
298  db_file_state_.erase(f);
299  new_files_since_last_dir_sync_.erase(f);
300}
301
302Status FaultInjectionTestEnv::DeleteFile(const std::string& f) {
303  Status s = EnvWrapper::DeleteFile(f);
304  ASSERT_OK(s);
305  if (s.ok()) {
306    UntrackFile(f);
307  }
308  return s;
309}
310
311Status FaultInjectionTestEnv::RenameFile(const std::string& s,
312                                         const std::string& t) {
313  Status ret = EnvWrapper::RenameFile(s, t);
314
315  if (ret.ok()) {
316    MutexLock l(&mutex_);
317    if (db_file_state_.find(s) != db_file_state_.end()) {
318      db_file_state_[t] = db_file_state_[s];
319      db_file_state_.erase(s);
320    }
321
322    if (new_files_since_last_dir_sync_.erase(s) != 0) {
323      assert(new_files_since_last_dir_sync_.find(t) ==
324             new_files_since_last_dir_sync_.end());
325      new_files_since_last_dir_sync_.insert(t);
326    }
327  }
328
329  return ret;
330}
331
332void FaultInjectionTestEnv::ResetState() {
333  // Since we are not destroying the database, the existing files
334  // should keep their recorded synced/flushed state. Therefore
335  // we do not reset db_file_state_ and new_files_since_last_dir_sync_.
336  SetFilesystemActive(true);
337}
338
339Status FaultInjectionTestEnv::DeleteFilesCreatedAfterLastDirSync() {
340  // Because DeleteFile access this container make a copy to avoid deadlock
341  mutex_.Lock();
342  std::set<std::string> new_files(new_files_since_last_dir_sync_.begin(),
343                                  new_files_since_last_dir_sync_.end());
344  mutex_.Unlock();
345  Status status;
346  for (const auto& new_file : new_files) {
347    Status delete_status = DeleteFile(new_file);
348    if (!delete_status.ok() && status.ok()) {
349      status = std::move(delete_status);
350    }
351  }
352  return status;
353}
354
355void FaultInjectionTestEnv::WritableFileClosed(const FileState& state) {
356  MutexLock l(&mutex_);
357  db_file_state_[state.filename_] = state;
358}
359
360Status FileState::DropUnsyncedData() const {
361  int64_t sync_pos = pos_at_last_sync_ == -1 ? 0 : pos_at_last_sync_;
362  return Truncate(filename_, sync_pos);
363}
364
365class FaultInjectionTest {
366 public:
367  enum ExpectedVerifResult { VAL_EXPECT_NO_ERROR, VAL_EXPECT_ERROR };
368  enum ResetMethod { RESET_DROP_UNSYNCED_DATA, RESET_DELETE_UNSYNCED_FILES };
369
370  FaultInjectionTestEnv* env_;
371  std::string dbname_;
372  Cache* tiny_cache_;
373  Options options_;
374  DB* db_;
375
376  FaultInjectionTest()
377      : env_(new FaultInjectionTestEnv),
378        tiny_cache_(NewLRUCache(100)),
379        db_(nullptr) {
380    dbname_ = test::TmpDir() + "/fault_test";
381    DestroyDB(dbname_, Options());  // Destroy any db from earlier run
382    options_.reuse_logs = true;
383    options_.env = env_;
384    options_.paranoid_checks = true;
385    options_.block_cache = tiny_cache_;
386    options_.create_if_missing = true;
387  }
388
389  ~FaultInjectionTest() {
390    CloseDB();
391    DestroyDB(dbname_, Options());
392    delete tiny_cache_;
393    delete env_;
394  }
395
396  void ReuseLogs(bool reuse) { options_.reuse_logs = reuse; }
397
398  void Build(int start_idx, int num_vals) {
399    std::string key_space, value_space;
400    WriteBatch batch;
401    for (int i = start_idx; i < start_idx + num_vals; i++) {
402      Slice key = Key(i, &key_space);
403      batch.Clear();
404      batch.Put(key, Value(i, &value_space));
405      WriteOptions options;
406      ASSERT_OK(db_->Write(options, &batch));
407    }
408  }
409
410  Status ReadValue(int i, std::string* val) const {
411    std::string key_space, value_space;
412    Slice key = Key(i, &key_space);
413    Value(i, &value_space);
414    ReadOptions options;
415    return db_->Get(options, key, val);
416  }
417
418  Status Verify(int start_idx, int num_vals,
419                ExpectedVerifResult expected) const {
420    std::string val;
421    std::string value_space;
422    Status s;
423    for (int i = start_idx; i < start_idx + num_vals && s.ok(); i++) {
424      Value(i, &value_space);
425      s = ReadValue(i, &val);
426      if (expected == VAL_EXPECT_NO_ERROR) {
427        if (s.ok()) {
428          ASSERT_EQ(value_space, val);
429        }
430      } else if (s.ok()) {
431        fprintf(stderr, "Expected an error at %d, but was OK\n", i);
432        s = Status::IOError(dbname_, "Expected value error:");
433      } else {
434        s = Status::OK();  // An expected error
435      }
436    }
437    return s;
438  }
439
440  // Return the ith key
441  Slice Key(int i, std::string* storage) const {
442    char buf[100];
443    snprintf(buf, sizeof(buf), "%016d", i);
444    storage->assign(buf, strlen(buf));
445    return Slice(*storage);
446  }
447
448  // Return the value to associate with the specified key
449  Slice Value(int k, std::string* storage) const {
450    Random r(k);
451    return test::RandomString(&r, kValueSize, storage);
452  }
453
454  Status OpenDB() {
455    delete db_;
456    db_ = nullptr;
457    env_->ResetState();
458    return DB::Open(options_, dbname_, &db_);
459  }
460
461  void CloseDB() {
462    delete db_;
463    db_ = nullptr;
464  }
465
466  void DeleteAllData() {
467    Iterator* iter = db_->NewIterator(ReadOptions());
468    for (iter->SeekToFirst(); iter->Valid(); iter->Next()) {
469      ASSERT_OK(db_->Delete(WriteOptions(), iter->key()));
470    }
471
472    delete iter;
473  }
474
475  void ResetDBState(ResetMethod reset_method) {
476    switch (reset_method) {
477      case RESET_DROP_UNSYNCED_DATA:
478        ASSERT_OK(env_->DropUnsyncedFileData());
479        break;
480      case RESET_DELETE_UNSYNCED_FILES:
481        ASSERT_OK(env_->DeleteFilesCreatedAfterLastDirSync());
482        break;
483      default:
484        assert(false);
485    }
486  }
487
488  void PartialCompactTestPreFault(int num_pre_sync, int num_post_sync) {
489    DeleteAllData();
490    Build(0, num_pre_sync);
491    db_->CompactRange(nullptr, nullptr);
492    Build(num_pre_sync, num_post_sync);
493  }
494
495  void PartialCompactTestReopenWithFault(ResetMethod reset_method,
496                                         int num_pre_sync, int num_post_sync) {
497    env_->SetFilesystemActive(false);
498    CloseDB();
499    ResetDBState(reset_method);
500    ASSERT_OK(OpenDB());

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 2Next 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.