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.

8,951 bytes · SHA-256 bea60a77807eeb7d… · View upstream ↗

1// Copyright (c) 2014 The LevelDB Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file. See the AUTHORS file for names of contributors.
4
5#include "db/db_impl.h"
6#include "db/filename.h"
7#include "db/version_set.h"
8#include "db/write_batch_internal.h"
9#include "leveldb/db.h"
10#include "leveldb/env.h"
11#include "leveldb/write_batch.h"
12#include "util/logging.h"
13#include "util/testharness.h"
14#include "util/testutil.h"
15
16namespace leveldb {
17
18class RecoveryTest {
19 public:
20  RecoveryTest() : env_(Env::Default()), db_(nullptr) {
21    dbname_ = test::TmpDir() + "/recovery_test";
22    DestroyDB(dbname_, Options());
23    Open();
24  }
25
26  ~RecoveryTest() {
27    Close();
28    DestroyDB(dbname_, Options());
29  }
30
31  DBImpl* dbfull() const { return reinterpret_cast<DBImpl*>(db_); }
32  Env* env() const { return env_; }
33
34  bool CanAppend() {
35    WritableFile* tmp;
36    Status s = env_->NewAppendableFile(CurrentFileName(dbname_), &tmp);
37    delete tmp;
38    if (s.IsNotSupportedError()) {
39      return false;
40    } else {
41      return true;
42    }
43  }
44
45  void Close() {
46    delete db_;
47    db_ = nullptr;
48  }
49
50  Status OpenWithStatus(Options* options = nullptr) {
51    Close();
52    Options opts;
53    if (options != nullptr) {
54      opts = *options;
55    } else {
56      opts.reuse_logs = true;  // TODO(sanjay): test both ways
57      opts.create_if_missing = true;
58    }
59    if (opts.env == nullptr) {
60      opts.env = env_;
61    }
62    return DB::Open(opts, dbname_, &db_);
63  }
64
65  void Open(Options* options = nullptr) {
66    ASSERT_OK(OpenWithStatus(options));
67    ASSERT_EQ(1, NumLogs());
68  }
69
70  Status Put(const std::string& k, const std::string& v) {
71    return db_->Put(WriteOptions(), k, v);
72  }
73
74  std::string Get(const std::string& k, const Snapshot* snapshot = nullptr) {
75    std::string result;
76    Status s = db_->Get(ReadOptions(), k, &result);
77    if (s.IsNotFound()) {
78      result = "NOT_FOUND";
79    } else if (!s.ok()) {
80      result = s.ToString();
81    }
82    return result;
83  }
84
85  std::string ManifestFileName() {
86    std::string current;
87    ASSERT_OK(ReadFileToString(env_, CurrentFileName(dbname_), &current));
88    size_t len = current.size();
89    if (len > 0 && current[len - 1] == '\n') {
90      current.resize(len - 1);
91    }
92    return dbname_ + "/" + current;
93  }
94
95  std::string LogName(uint64_t number) { return LogFileName(dbname_, number); }
96
97  size_t DeleteLogFiles() {
98    // Linux allows unlinking open files, but Windows does not.
99    // Closing the db allows for file deletion.
100    Close();
101    std::vector<uint64_t> logs = GetFiles(kLogFile);
102    for (size_t i = 0; i < logs.size(); i++) {
103      ASSERT_OK(env_->DeleteFile(LogName(logs[i]))) << LogName(logs[i]);
104    }
105    return logs.size();
106  }
107
108  void DeleteManifestFile() { ASSERT_OK(env_->DeleteFile(ManifestFileName())); }
109
110  uint64_t FirstLogFile() { return GetFiles(kLogFile)[0]; }
111
112  std::vector<uint64_t> GetFiles(FileType t) {
113    std::vector<std::string> filenames;
114    ASSERT_OK(env_->GetChildren(dbname_, &filenames));
115    std::vector<uint64_t> result;
116    for (size_t i = 0; i < filenames.size(); i++) {
117      uint64_t number;
118      FileType type;
119      if (ParseFileName(filenames[i], &number, &type) && type == t) {
120        result.push_back(number);
121      }
122    }
123    return result;
124  }
125
126  int NumLogs() { return GetFiles(kLogFile).size(); }
127
128  int NumTables() { return GetFiles(kTableFile).size(); }
129
130  uint64_t FileSize(const std::string& fname) {
131    uint64_t result;
132    ASSERT_OK(env_->GetFileSize(fname, &result)) << fname;
133    return result;
134  }
135
136  void CompactMemTable() { dbfull()->TEST_CompactMemTable(); }
137
138  // Directly construct a log file that sets key to val.
139  void MakeLogFile(uint64_t lognum, SequenceNumber seq, Slice key, Slice val) {
140    std::string fname = LogFileName(dbname_, lognum);
141    WritableFile* file;
142    ASSERT_OK(env_->NewWritableFile(fname, &file));
143    log::Writer writer(file);
144    WriteBatch batch;
145    batch.Put(key, val);
146    WriteBatchInternal::SetSequence(&batch, seq);
147    ASSERT_OK(writer.AddRecord(WriteBatchInternal::Contents(&batch)));
148    ASSERT_OK(file->Flush());
149    delete file;
150  }
151
152 private:
153  std::string dbname_;
154  Env* env_;
155  DB* db_;
156};
157
158TEST(RecoveryTest, ManifestReused) {
159  if (!CanAppend()) {
160    fprintf(stderr, "skipping test because env does not support appending\n");
161    return;
162  }
163  ASSERT_OK(Put("foo", "bar"));
164  Close();
165  std::string old_manifest = ManifestFileName();
166  Open();
167  ASSERT_EQ(old_manifest, ManifestFileName());
168  ASSERT_EQ("bar", Get("foo"));
169  Open();
170  ASSERT_EQ(old_manifest, ManifestFileName());
171  ASSERT_EQ("bar", Get("foo"));
172}
173
174TEST(RecoveryTest, LargeManifestCompacted) {
175  if (!CanAppend()) {
176    fprintf(stderr, "skipping test because env does not support appending\n");
177    return;
178  }
179  ASSERT_OK(Put("foo", "bar"));
180  Close();
181  std::string old_manifest = ManifestFileName();
182
183  // Pad with zeroes to make manifest file very big.
184  {
185    uint64_t len = FileSize(old_manifest);
186    WritableFile* file;
187    ASSERT_OK(env()->NewAppendableFile(old_manifest, &file));
188    std::string zeroes(3 * 1048576 - static_cast<size_t>(len), 0);
189    ASSERT_OK(file->Append(zeroes));
190    ASSERT_OK(file->Flush());
191    delete file;
192  }
193
194  Open();
195  std::string new_manifest = ManifestFileName();
196  ASSERT_NE(old_manifest, new_manifest);
197  ASSERT_GT(10000, FileSize(new_manifest));
198  ASSERT_EQ("bar", Get("foo"));
199
200  Open();
201  ASSERT_EQ(new_manifest, ManifestFileName());
202  ASSERT_EQ("bar", Get("foo"));
203}
204
205TEST(RecoveryTest, NoLogFiles) {
206  ASSERT_OK(Put("foo", "bar"));
207  ASSERT_EQ(1, DeleteLogFiles());
208  Open();
209  ASSERT_EQ("NOT_FOUND", Get("foo"));
210  Open();
211  ASSERT_EQ("NOT_FOUND", Get("foo"));
212}
213
214TEST(RecoveryTest, LogFileReuse) {
215  if (!CanAppend()) {
216    fprintf(stderr, "skipping test because env does not support appending\n");
217    return;
218  }
219  for (int i = 0; i < 2; i++) {
220    ASSERT_OK(Put("foo", "bar"));
221    if (i == 0) {
222      // Compact to ensure current log is empty
223      CompactMemTable();
224    }
225    Close();
226    ASSERT_EQ(1, NumLogs());
227    uint64_t number = FirstLogFile();
228    if (i == 0) {
229      ASSERT_EQ(0, FileSize(LogName(number)));
230    } else {
231      ASSERT_LT(0, FileSize(LogName(number)));
232    }
233    Open();
234    ASSERT_EQ(1, NumLogs());
235    ASSERT_EQ(number, FirstLogFile()) << "did not reuse log file";
236    ASSERT_EQ("bar", Get("foo"));
237    Open();
238    ASSERT_EQ(1, NumLogs());
239    ASSERT_EQ(number, FirstLogFile()) << "did not reuse log file";
240    ASSERT_EQ("bar", Get("foo"));
241  }
242}
243
244TEST(RecoveryTest, MultipleMemTables) {
245  // Make a large log.
246  const int kNum = 1000;
247  for (int i = 0; i < kNum; i++) {
248    char buf[100];
249    snprintf(buf, sizeof(buf), "%050d", i);
250    ASSERT_OK(Put(buf, buf));

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.