Branch data Line data Source code
1 : : // Copyright (c) 2018-2022 The Bitcoin Core developers
2 : : // Distributed under the MIT software license, see the accompanying
3 : : // file COPYING or http://www.opensource.org/licenses/mit-license.php.
4 : :
5 : : #include <addrdb.h>
6 : : #include <banman.h>
7 : : #include <blockfilter.h>
8 : : #include <chain.h>
9 : : #include <chainparams.h>
10 : : #include <common/args.h>
11 : : #include <consensus/merkle.h>
12 : : #include <consensus/validation.h>
13 : : #include <deploymentstatus.h>
14 : : #include <external_signer.h>
15 : : #include <index/blockfilterindex.h>
16 : : #include <init.h>
17 : : #include <interfaces/chain.h>
18 : : #include <interfaces/handler.h>
19 : : #include <interfaces/mining.h>
20 : : #include <interfaces/node.h>
21 : : #include <interfaces/types.h>
22 : : #include <interfaces/wallet.h>
23 : : #include <kernel/chain.h>
24 : : #include <kernel/context.h>
25 : : #include <kernel/mempool_entry.h>
26 : : #include <logging.h>
27 : : #include <mapport.h>
28 : : #include <net.h>
29 : : #include <net_processing.h>
30 : : #include <netaddress.h>
31 : : #include <netbase.h>
32 : : #include <node/blockstorage.h>
33 : : #include <node/coin.h>
34 : : #include <node/context.h>
35 : : #include <node/interface_ui.h>
36 : : #include <node/mini_miner.h>
37 : : #include <node/miner.h>
38 : : #include <node/kernel_notifications.h>
39 : : #include <node/transaction.h>
40 : : #include <node/types.h>
41 : : #include <node/warnings.h>
42 : : #include <policy/feerate.h>
43 : : #include <policy/fees/block_policy_estimator.h>
44 : : #include <policy/policy.h>
45 : : #include <policy/rbf.h>
46 : : #include <policy/settings.h>
47 : : #include <primitives/block.h>
48 : : #include <primitives/transaction.h>
49 : : #include <rpc/blockchain.h>
50 : : #include <rpc/protocol.h>
51 : : #include <rpc/server.h>
52 : : #include <support/allocators/secure.h>
53 : : #include <sync.h>
54 : : #include <txmempool.h>
55 : : #include <uint256.h>
56 : : #include <univalue.h>
57 : : #include <util/check.h>
58 : : #include <util/result.h>
59 : : #include <util/signalinterrupt.h>
60 : : #include <util/string.h>
61 : : #include <util/translation.h>
62 : : #include <validation.h>
63 : : #include <validationinterface.h>
64 : :
65 : : #include <bitcoin-build-config.h> // IWYU pragma: keep
66 : :
67 : : #include <any>
68 : : #include <memory>
69 : : #include <optional>
70 : : #include <utility>
71 : :
72 : : #include <boost/signals2/signal.hpp>
73 : :
74 : : using interfaces::BlockRef;
75 : : using interfaces::BlockTemplate;
76 : : using interfaces::BlockTip;
77 : : using interfaces::Chain;
78 : : using interfaces::FoundBlock;
79 : : using interfaces::Handler;
80 : : using interfaces::MakeSignalHandler;
81 : : using interfaces::Mining;
82 : : using interfaces::Node;
83 : : using interfaces::WalletLoader;
84 : : using node::BlockAssembler;
85 : : using node::BlockWaitOptions;
86 : : using util::Join;
87 : :
88 : : namespace node {
89 : : // All members of the classes in this namespace are intentionally public, as the
90 : : // classes themselves are private.
91 : : namespace {
92 : : #ifdef ENABLE_EXTERNAL_SIGNER
93 : : class ExternalSignerImpl : public interfaces::ExternalSigner
94 : : {
95 : : public:
96 : 0 : ExternalSignerImpl(::ExternalSigner signer) : m_signer(std::move(signer)) {}
97 [ # # ]: 0 : std::string getName() override { return m_signer.m_name; }
98 : : ::ExternalSigner m_signer;
99 : : };
100 : : #endif
101 : :
102 : : class NodeImpl : public Node
103 : : {
104 : : public:
105 : 0 : explicit NodeImpl(NodeContext& context) { setContext(&context); }
106 : 0 : void initLogging() override { InitLogging(args()); }
107 : 0 : void initParameterInteraction() override { InitParameterInteraction(args()); }
108 [ # # # # : 0 : bilingual_str getWarnings() override { return Join(Assert(m_context->warnings)->GetMessages(), Untranslated("<hr />")); }
# # # # ]
109 [ # # ]: 0 : int getExitStatus() override { return Assert(m_context)->exit_status.load(); }
110 : 0 : BCLog::CategoryMask getLogCategories() override { return LogInstance().GetCategoryMask(); }
111 : 0 : bool baseInitialize() override
112 : : {
113 [ # # # # ]: 0 : if (!AppInitBasicSetup(args(), Assert(context())->exit_status)) return false;
114 [ # # ]: 0 : if (!AppInitParameterInteraction(args())) return false;
115 : :
116 : 0 : m_context->warnings = std::make_unique<node::Warnings>();
117 : 0 : m_context->kernel = std::make_unique<kernel::Context>();
118 : 0 : m_context->ecc_context = std::make_unique<ECC_Context>();
119 [ # # ]: 0 : if (!AppInitSanityChecks(*m_context->kernel)) return false;
120 : :
121 [ # # ]: 0 : if (!AppInitLockDirectories()) return false;
122 [ # # ]: 0 : if (!AppInitInterfaces(*m_context)) return false;
123 : :
124 : : return true;
125 : : }
126 : 0 : bool appInitMain(interfaces::BlockAndHeaderTipInfo* tip_info) override
127 : : {
128 [ # # ]: 0 : if (AppInitMain(*m_context, tip_info)) return true;
129 : : // Error during initialization, set exit status before continue
130 : 0 : m_context->exit_status.store(EXIT_FAILURE);
131 : 0 : return false;
132 : : }
133 : 0 : void appShutdown() override
134 : : {
135 : 0 : Shutdown(*m_context);
136 : 0 : }
137 : 0 : void startShutdown() override
138 : : {
139 [ # # ]: 0 : NodeContext& ctx{*Assert(m_context)};
140 [ # # # # ]: 0 : if (!(Assert(ctx.shutdown_request))()) {
141 : 0 : LogError("Failed to send shutdown signal\n");
142 : : }
143 : 0 : Interrupt(*m_context);
144 : 0 : }
145 [ # # ]: 0 : bool shutdownRequested() override { return ShutdownRequested(*Assert(m_context)); };
146 : 0 : bool isSettingIgnored(const std::string& name) override
147 : : {
148 : 0 : bool ignored = false;
149 : 0 : args().LockSettings([&](common::Settings& settings) {
150 [ # # ]: 0 : if (auto* options = common::FindKey(settings.command_line_options, name)) {
151 : 0 : ignored = !options->empty();
152 : : }
153 : 0 : });
154 : 0 : return ignored;
155 : : }
156 : 0 : common::SettingsValue getPersistentSetting(const std::string& name) override { return args().GetPersistentSetting(name); }
157 : 0 : void updateRwSetting(const std::string& name, const common::SettingsValue& value) override
158 : : {
159 : 0 : args().LockSettings([&](common::Settings& settings) {
160 [ # # ]: 0 : if (value.isNull()) {
161 : 0 : settings.rw_settings.erase(name);
162 : : } else {
163 : 0 : settings.rw_settings[name] = value;
164 : : }
165 : 0 : });
166 : 0 : args().WriteSettingsFile();
167 : 0 : }
168 : 0 : void forceSetting(const std::string& name, const common::SettingsValue& value) override
169 : : {
170 : 0 : args().LockSettings([&](common::Settings& settings) {
171 [ # # ]: 0 : if (value.isNull()) {
172 : 0 : settings.forced_settings.erase(name);
173 : : } else {
174 : 0 : settings.forced_settings[name] = value;
175 : : }
176 : 0 : });
177 : 0 : }
178 : 0 : void resetSettings() override
179 : : {
180 : 0 : args().WriteSettingsFile(/*errors=*/nullptr, /*backup=*/true);
181 : 0 : args().LockSettings([&](common::Settings& settings) {
182 [ # # ]: 0 : settings.rw_settings.clear();
183 : : });
184 : 0 : args().WriteSettingsFile();
185 : 0 : }
186 : 0 : void mapPort(bool enable) override { StartMapPort(enable); }
187 : 0 : bool getProxy(Network net, Proxy& proxy_info) override { return GetProxy(net, proxy_info); }
188 : 0 : size_t getNodeCount(ConnectionDirection flags) override
189 : : {
190 [ # # ]: 0 : return m_context->connman ? m_context->connman->GetNodeCount(flags) : 0;
191 : : }
192 : 0 : bool getNodesStats(NodesStats& stats) override
193 : : {
194 : 0 : stats.clear();
195 : :
196 [ # # ]: 0 : if (m_context->connman) {
197 : 0 : std::vector<CNodeStats> stats_temp;
198 [ # # ]: 0 : m_context->connman->GetNodeStats(stats_temp);
199 : :
200 [ # # # # ]: 0 : stats.reserve(stats_temp.size());
201 [ # # ]: 0 : for (auto& node_stats_temp : stats_temp) {
202 [ # # ]: 0 : stats.emplace_back(std::move(node_stats_temp), false, CNodeStateStats());
203 : : }
204 : :
205 : : // Try to retrieve the CNodeStateStats for each node.
206 [ # # ]: 0 : if (m_context->peerman) {
207 [ # # ]: 0 : TRY_LOCK(::cs_main, lockMain);
208 [ # # ]: 0 : if (lockMain) {
209 [ # # ]: 0 : for (auto& node_stats : stats) {
210 : 0 : std::get<1>(node_stats) =
211 [ # # ]: 0 : m_context->peerman->GetNodeStateStats(std::get<0>(node_stats).nodeid, std::get<2>(node_stats));
212 : : }
213 : : }
214 : 0 : }
215 : 0 : return true;
216 : 0 : }
217 : : return false;
218 : : }
219 : 0 : bool getBanned(banmap_t& banmap) override
220 : : {
221 [ # # ]: 0 : if (m_context->banman) {
222 : 0 : m_context->banman->GetBanned(banmap);
223 : 0 : return true;
224 : : }
225 : : return false;
226 : : }
227 : 0 : bool ban(const CNetAddr& net_addr, int64_t ban_time_offset) override
228 : : {
229 [ # # ]: 0 : if (m_context->banman) {
230 : 0 : m_context->banman->Ban(net_addr, ban_time_offset);
231 : 0 : return true;
232 : : }
233 : : return false;
234 : : }
235 : 0 : bool unban(const CSubNet& ip) override
236 : : {
237 [ # # ]: 0 : if (m_context->banman) {
238 : 0 : m_context->banman->Unban(ip);
239 : 0 : return true;
240 : : }
241 : : return false;
242 : : }
243 : 0 : bool disconnectByAddress(const CNetAddr& net_addr) override
244 : : {
245 [ # # ]: 0 : if (m_context->connman) {
246 : 0 : return m_context->connman->DisconnectNode(net_addr);
247 : : }
248 : : return false;
249 : : }
250 : 0 : bool disconnectById(NodeId id) override
251 : : {
252 [ # # ]: 0 : if (m_context->connman) {
253 : 0 : return m_context->connman->DisconnectNode(id);
254 : : }
255 : : return false;
256 : : }
257 : 0 : std::vector<std::unique_ptr<interfaces::ExternalSigner>> listExternalSigners() override
258 : : {
259 : : #ifdef ENABLE_EXTERNAL_SIGNER
260 : 0 : std::vector<ExternalSigner> signers = {};
261 [ # # # # : 0 : const std::string command = args().GetArg("-signer", "");
# # # # ]
262 [ # # ]: 0 : if (command == "") return {};
263 [ # # # # : 0 : ExternalSigner::Enumerate(command, signers, Params().GetChainTypeString());
# # ]
264 : 0 : std::vector<std::unique_ptr<interfaces::ExternalSigner>> result;
265 [ # # # # ]: 0 : result.reserve(signers.size());
266 [ # # ]: 0 : for (auto& signer : signers) {
267 [ # # # # ]: 0 : result.emplace_back(std::make_unique<ExternalSignerImpl>(std::move(signer)));
268 : : }
269 : 0 : return result;
270 : : #else
271 : : // This result is indistinguishable from a successful call that returns
272 : : // no signers. For the current GUI this doesn't matter, because the wallet
273 : : // creation dialog disables the external signer checkbox in both
274 : : // cases. The return type could be changed to std::optional<std::vector>
275 : : // (or something that also includes error messages) if this distinction
276 : : // becomes important.
277 : : return {};
278 : : #endif // ENABLE_EXTERNAL_SIGNER
279 : 0 : }
280 [ # # ]: 0 : int64_t getTotalBytesRecv() override { return m_context->connman ? m_context->connman->GetTotalBytesRecv() : 0; }
281 [ # # ]: 0 : int64_t getTotalBytesSent() override { return m_context->connman ? m_context->connman->GetTotalBytesSent() : 0; }
282 [ # # ]: 0 : size_t getMempoolSize() override { return m_context->mempool ? m_context->mempool->size() : 0; }
283 [ # # ]: 0 : size_t getMempoolDynamicUsage() override { return m_context->mempool ? m_context->mempool->DynamicMemoryUsage() : 0; }
284 [ # # ]: 0 : size_t getMempoolMaxUsage() override { return m_context->mempool ? m_context->mempool->m_opts.max_size_bytes : 0; }
285 : 0 : bool getHeaderTip(int& height, int64_t& block_time) override
286 : : {
287 : 0 : LOCK(::cs_main);
288 [ # # ]: 0 : auto best_header = chainman().m_best_header;
289 [ # # ]: 0 : if (best_header) {
290 : 0 : height = best_header->nHeight;
291 : 0 : block_time = best_header->GetBlockTime();
292 : 0 : return true;
293 : : }
294 : : return false;
295 : 0 : }
296 : 0 : std::map<CNetAddr, LocalServiceInfo> getNetLocalAddresses() override
297 : : {
298 [ # # ]: 0 : if (m_context->connman)
299 : 0 : return m_context->connman->getNetLocalAddresses();
300 : : else
301 : 0 : return {};
302 : : }
303 : 0 : int getNumBlocks() override
304 : : {
305 : 0 : LOCK(::cs_main);
306 [ # # # # : 0 : return chainman().ActiveChain().Height();
# # # # ]
307 : 0 : }
308 : 0 : uint256 getBestBlockHash() override
309 : : {
310 [ # # # # : 0 : const CBlockIndex* tip = WITH_LOCK(::cs_main, return chainman().ActiveChain().Tip());
# # # # ]
311 [ # # ]: 0 : return tip ? tip->GetBlockHash() : chainman().GetParams().GenesisBlock().GetHash();
312 : : }
313 : 0 : int64_t getLastBlockTime() override
314 : : {
315 : 0 : LOCK(::cs_main);
316 [ # # # # : 0 : if (chainman().ActiveChain().Tip()) {
# # # # ]
317 [ # # # # : 0 : return chainman().ActiveChain().Tip()->GetBlockTime();
# # ]
318 : : }
319 [ # # ]: 0 : return chainman().GetParams().GenesisBlock().GetBlockTime(); // Genesis block's time of current network
320 : 0 : }
321 : 0 : double getVerificationProgress() override
322 : : {
323 : 0 : LOCK(chainman().GetMutex());
324 [ # # # # : 0 : return chainman().GuessVerificationProgress(chainman().ActiveTip());
# # # # #
# ]
325 : 0 : }
326 : 0 : bool isInitialBlockDownload() override
327 : : {
328 : 0 : return chainman().IsInitialBlockDownload();
329 : : }
330 : 0 : bool isLoadingBlocks() override { return chainman().m_blockman.LoadingBlocks(); }
331 : 0 : void setNetworkActive(bool active) override
332 : : {
333 [ # # ]: 0 : if (m_context->connman) {
334 : 0 : m_context->connman->SetNetworkActive(active);
335 : : }
336 : 0 : }
337 [ # # # # ]: 0 : bool getNetworkActive() override { return m_context->connman && m_context->connman->GetNetworkActive(); }
338 : 0 : CFeeRate getDustRelayFee() override
339 : : {
340 [ # # ]: 0 : if (!m_context->mempool) return CFeeRate{DUST_RELAY_TX_FEE};
341 : 0 : return m_context->mempool->m_opts.dust_relay_feerate;
342 : : }
343 : 0 : UniValue executeRpc(const std::string& command, const UniValue& params, const std::string& uri) override
344 : : {
345 : 0 : JSONRPCRequest req;
346 : 0 : req.context = m_context;
347 [ # # ]: 0 : req.params = params;
348 [ # # ]: 0 : req.strMethod = command;
349 [ # # ]: 0 : req.URI = uri;
350 [ # # ]: 0 : return ::tableRPC.execute(req);
351 : 0 : }
352 : 0 : std::vector<std::string> listRpcCommands() override { return ::tableRPC.listCommands(); }
353 : 0 : std::optional<Coin> getUnspentOutput(const COutPoint& output) override
354 : : {
355 : 0 : LOCK(::cs_main);
356 [ # # # # : 0 : return chainman().ActiveChainstate().CoinsTip().GetCoin(output);
# # # # ]
357 : 0 : }
358 : 0 : TransactionError broadcastTransaction(CTransactionRef tx, CAmount max_tx_fee, std::string& err_string) override
359 : : {
360 [ # # # # ]: 0 : return BroadcastTransaction(*m_context,
361 : : std::move(tx),
362 : : err_string,
363 : : max_tx_fee,
364 : : TxBroadcast::MEMPOOL_AND_BROADCAST_TO_ALL,
365 : 0 : /*wait_callback=*/false);
366 : : }
367 : 0 : WalletLoader& walletLoader() override
368 : : {
369 [ # # ]: 0 : return *Assert(m_context->wallet_loader);
370 : : }
371 : 0 : std::unique_ptr<Handler> handleInitMessage(InitMessageFn fn) override
372 : : {
373 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.InitMessage_connect(fn));
374 : : }
375 : 0 : std::unique_ptr<Handler> handleMessageBox(MessageBoxFn fn) override
376 : : {
377 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.ThreadSafeMessageBox_connect(fn));
378 : : }
379 : 0 : std::unique_ptr<Handler> handleQuestion(QuestionFn fn) override
380 : : {
381 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.ThreadSafeQuestion_connect(fn));
382 : : }
383 : 0 : std::unique_ptr<Handler> handleShowProgress(ShowProgressFn fn) override
384 : : {
385 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.ShowProgress_connect(fn));
386 : : }
387 : 0 : std::unique_ptr<Handler> handleInitWallet(InitWalletFn fn) override
388 : : {
389 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.InitWallet_connect(fn));
390 : : }
391 : 0 : std::unique_ptr<Handler> handleNotifyNumConnectionsChanged(NotifyNumConnectionsChangedFn fn) override
392 : : {
393 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.NotifyNumConnectionsChanged_connect(fn));
394 : : }
395 : 0 : std::unique_ptr<Handler> handleNotifyNetworkActiveChanged(NotifyNetworkActiveChangedFn fn) override
396 : : {
397 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.NotifyNetworkActiveChanged_connect(fn));
398 : : }
399 : 0 : std::unique_ptr<Handler> handleNotifyAlertChanged(NotifyAlertChangedFn fn) override
400 : : {
401 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.NotifyAlertChanged_connect(fn));
402 : : }
403 : 0 : std::unique_ptr<Handler> handleBannedListChanged(BannedListChangedFn fn) override
404 : : {
405 [ # # # # ]: 0 : return MakeSignalHandler(::uiInterface.BannedListChanged_connect(fn));
406 : : }
407 : 0 : std::unique_ptr<Handler> handleNotifyBlockTip(NotifyBlockTipFn fn) override
408 : : {
409 [ # # # # : 0 : return MakeSignalHandler(::uiInterface.NotifyBlockTip_connect([fn](SynchronizationState sync_state, const CBlockIndex& block, double verification_progress) {
# # ]
410 : 0 : fn(sync_state, BlockTip{block.nHeight, block.GetBlockTime(), block.GetBlockHash()}, verification_progress);
411 [ # # ]: 0 : }));
412 : : }
413 : 0 : std::unique_ptr<Handler> handleNotifyHeaderTip(NotifyHeaderTipFn fn) override
414 : : {
415 : 0 : return MakeSignalHandler(
416 [ # # # # : 0 : ::uiInterface.NotifyHeaderTip_connect([fn](SynchronizationState sync_state, int64_t height, int64_t timestamp, bool presync) {
# # ]
417 : 0 : fn(sync_state, BlockTip{(int)height, timestamp, uint256{}}, presync);
418 [ # # ]: 0 : }));
419 : : }
420 : 0 : NodeContext* context() override { return m_context; }
421 : 0 : void setContext(NodeContext* context) override
422 : : {
423 : 0 : m_context = context;
424 : 0 : }
425 [ # # # # ]: 0 : ArgsManager& args() { return *Assert(Assert(m_context)->args); }
426 [ # # ]: 0 : ChainstateManager& chainman() { return *Assert(m_context->chainman); }
427 : : NodeContext* m_context{nullptr};
428 : : };
429 : :
430 : : // NOLINTNEXTLINE(misc-no-recursion)
431 : 261756 : bool FillBlock(const CBlockIndex* index, const FoundBlock& block, UniqueLock<RecursiveMutex>& lock, const CChain& active, const BlockManager& blockman) EXCLUSIVE_LOCKS_REQUIRED(cs_main)
432 : : {
433 [ + + ]: 261756 : if (!index) return false;
434 [ + + ]: 260557 : if (block.m_hash) *block.m_hash = index->GetBlockHash();
435 [ + + ]: 260557 : if (block.m_height) *block.m_height = index->nHeight;
436 [ + + ]: 260557 : if (block.m_time) *block.m_time = index->GetBlockTime();
437 [ + + ]: 260557 : if (block.m_max_time) *block.m_max_time = index->GetBlockTimeMax();
438 [ + + ]: 260557 : if (block.m_mtp_time) *block.m_mtp_time = index->GetMedianTimePast();
439 [ + + + - ]: 411266 : if (block.m_in_active_chain) *block.m_in_active_chain = active[index->nHeight] == index;
440 [ + + ]: 260557 : if (block.m_locator) { *block.m_locator = GetLocator(index); }
441 [ + + + - : 403555 : if (block.m_next_block) FillBlock(active[index->nHeight] == index ? active[index->nHeight + 1] : nullptr, *block.m_next_block, lock, active, blockman);
+ - + - ]
442 [ + + ]: 260557 : if (block.m_data) {
443 : 70957 : REVERSE_LOCK(lock, cs_main);
444 [ + - + + ]: 70957 : if (!blockman.ReadBlock(*block.m_data, *index)) block.m_data->SetNull();
445 : 70957 : }
446 : 260557 : block.found = true;
447 : 260557 : return true;
448 : : }
449 : :
450 : : class NotificationsProxy : public CValidationInterface
451 : : {
452 : : public:
453 : 879 : explicit NotificationsProxy(std::shared_ptr<Chain::Notifications> notifications)
454 : 879 : : m_notifications(std::move(notifications)) {}
455 [ + - ]: 879 : virtual ~NotificationsProxy() = default;
456 : 6093 : void TransactionAddedToMempool(const NewMempoolTransactionInfo& tx, uint64_t mempool_sequence) override
457 : : {
458 : 6093 : m_notifications->transactionAddedToMempool(tx.info.m_tx);
459 : 6093 : }
460 : 243 : void TransactionRemovedFromMempool(const CTransactionRef& tx, MemPoolRemovalReason reason, uint64_t mempool_sequence) override
461 : : {
462 : 243 : m_notifications->transactionRemovedFromMempool(tx, reason);
463 : 243 : }
464 : 41377 : void BlockConnected(ChainstateRole role, const std::shared_ptr<const CBlock>& block, const CBlockIndex* index) override
465 : : {
466 : 41377 : m_notifications->blockConnected(role, kernel::MakeBlockInfo(index, block.get()));
467 : 41377 : }
468 : 3436 : void BlockDisconnected(const std::shared_ptr<const CBlock>& block, const CBlockIndex* index) override
469 : : {
470 : 3436 : m_notifications->blockDisconnected(kernel::MakeBlockInfo(index, block.get()));
471 : 3436 : }
472 : 39155 : void UpdatedBlockTip(const CBlockIndex* index, const CBlockIndex* fork_index, bool is_ibd) override
473 : : {
474 : 39155 : m_notifications->updatedBlockTip();
475 : 39155 : }
476 : 77 : void ChainStateFlushed(ChainstateRole role, const CBlockLocator& locator) override {
477 : 77 : m_notifications->chainStateFlushed(role, locator);
478 : 77 : }
479 : : std::shared_ptr<Chain::Notifications> m_notifications;
480 : : };
481 : :
482 : : class NotificationsHandlerImpl : public Handler
483 : : {
484 : : public:
485 : 879 : explicit NotificationsHandlerImpl(ValidationSignals& signals, std::shared_ptr<Chain::Notifications> notifications)
486 [ + - ]: 879 : : m_signals{signals}, m_proxy{std::make_shared<NotificationsProxy>(std::move(notifications))}
487 : : {
488 [ + - + - ]: 1758 : m_signals.RegisterSharedValidationInterface(m_proxy);
489 [ - - ]: 879 : }
490 [ - + ]: 1758 : ~NotificationsHandlerImpl() override { disconnect(); }
491 : 879 : void disconnect() override
492 : : {
493 [ + - ]: 879 : if (m_proxy) {
494 [ + - + - ]: 1758 : m_signals.UnregisterSharedValidationInterface(m_proxy);
495 : 879 : m_proxy.reset();
496 : : }
497 : 879 : }
498 : : ValidationSignals& m_signals;
499 : : std::shared_ptr<NotificationsProxy> m_proxy;
500 : : };
501 : :
502 : : class RpcHandlerImpl : public Handler
503 : : {
504 : : public:
505 [ + - ]: 23883 : explicit RpcHandlerImpl(const CRPCCommand& command) : m_command(command), m_wrapped_command(&command)
506 : : {
507 : 44462 : m_command.actor = [this](const JSONRPCRequest& request, UniValue& result, bool last_handler) {
508 [ + - ]: 20579 : if (!m_wrapped_command) return false;
509 : 20579 : try {
510 [ + + ]: 20579 : return m_wrapped_command->actor(request, result, last_handler);
511 [ - + ]: 706 : } catch (const UniValue& e) {
512 : : // If this is not the last handler and a wallet not found
513 : : // exception was thrown, return false so the next handler can
514 : : // try to handle the request. Otherwise, reraise the exception.
515 [ - + ]: 706 : if (!last_handler) {
516 [ - - - - ]: 0 : const UniValue& code = e["code"];
517 [ - - - - : 0 : if (code.isNum() && code.getInt<int>() == RPC_WALLET_NOT_FOUND) {
- - ]
518 : 0 : return false;
519 : : }
520 : : }
521 : 706 : throw;
522 : 706 : }
523 : 23883 : };
524 [ + - ]: 23883 : ::tableRPC.appendCommand(m_command.name, &m_command);
525 : 23883 : }
526 : :
527 : 23883 : void disconnect() final
528 : : {
529 [ + - ]: 23883 : if (m_wrapped_command) {
530 : 23883 : m_wrapped_command = nullptr;
531 : 23883 : ::tableRPC.removeCommand(m_command.name, &m_command);
532 : : }
533 : 23883 : }
534 : :
535 : 47766 : ~RpcHandlerImpl() override { disconnect(); }
536 : :
537 : : CRPCCommand m_command;
538 : : const CRPCCommand* m_wrapped_command;
539 : : };
540 : :
541 : : class ChainImpl : public Chain
542 : : {
543 : : public:
544 : 1900 : explicit ChainImpl(NodeContext& node) : m_node(node) {}
545 : 2286 : std::optional<int> getHeight() override
546 : : {
547 [ + - + - : 6858 : const int height{WITH_LOCK(::cs_main, return chainman().ActiveChain().Height())};
- + + - ]
548 [ + + ]: 2286 : return height >= 0 ? std::optional{height} : std::nullopt;
549 : : }
550 : 2395 : uint256 getBlockHash(int height) override
551 : : {
552 : 2395 : LOCK(::cs_main);
553 [ + - + - : 4790 : return Assert(chainman().ActiveChain()[height])->GetBlockHash();
+ - - + +
- ]
554 : 2395 : }
555 : 705 : bool haveBlockOnDisk(int height) override
556 : : {
557 : 705 : LOCK(::cs_main);
558 [ + - + - : 706 : const CBlockIndex* block{chainman().ActiveChain()[height]};
+ - ]
559 [ + - + + : 706 : return block && ((block->nStatus & BLOCK_HAVE_DATA) != 0) && block->nTx > 0;
- + + - ]
560 : 705 : }
561 : 861 : std::optional<int> findLocatorFork(const CBlockLocator& locator) override
562 : : {
563 : 861 : LOCK(::cs_main);
564 [ + - + - : 861 : if (const CBlockIndex* fork = chainman().ActiveChainstate().FindForkInGlobalIndex(locator)) {
+ - + + ]
565 : 853 : return fork->nHeight;
566 : : }
567 : 8 : return std::nullopt;
568 : 861 : }
569 : 662 : bool hasBlockFilterIndex(BlockFilterType filter_type) override
570 : : {
571 : 662 : return GetBlockFilterIndex(filter_type) != nullptr;
572 : : }
573 : 616 : std::optional<bool> blockFilterMatchesAny(BlockFilterType filter_type, const uint256& block_hash, const GCSFilter::ElementSet& filter_set) override
574 : : {
575 : 616 : const BlockFilterIndex* block_filter_index{GetBlockFilterIndex(filter_type)};
576 [ - + ]: 616 : if (!block_filter_index) return std::nullopt;
577 : :
578 : 616 : BlockFilter filter;
579 [ + - + - : 1848 : const CBlockIndex* index{WITH_LOCK(::cs_main, return chainman().m_blockman.LookupBlockIndex(block_hash))};
+ - + - ]
580 [ + - + - : 616 : if (index == nullptr || !block_filter_index->LookupFilter(index, filter)) return std::nullopt;
- + ]
581 [ + - ]: 616 : return filter.GetFilter().MatchAny(filter_set);
582 : 616 : }
583 : 189496 : bool findBlock(const uint256& hash, const FoundBlock& block) override
584 : : {
585 : 189496 : WAIT_LOCK(cs_main, lock);
586 [ + - + - : 189496 : return FillBlock(chainman().m_blockman.LookupBlockIndex(hash), block, lock, chainman().ActiveChain(), chainman().m_blockman);
+ - + - +
- + - +
- ]
587 : 189496 : }
588 : 647 : bool findFirstBlockWithTimeAndHeight(int64_t min_time, int min_height, const FoundBlock& block) override
589 : : {
590 : 647 : WAIT_LOCK(cs_main, lock);
591 [ + - + - ]: 647 : const CChain& active = chainman().ActiveChain();
592 [ + - + - : 647 : return FillBlock(active.FindEarliestAtLeast(min_time, min_height), block, lock, active, chainman().m_blockman);
+ - + - ]
593 : 647 : }
594 : 41 : bool findAncestorByHeight(const uint256& block_hash, int ancestor_height, const FoundBlock& ancestor_out) override
595 : : {
596 : 41 : WAIT_LOCK(cs_main, lock);
597 [ + - + - ]: 41 : const CChain& active = chainman().ActiveChain();
598 [ + - + - : 41 : if (const CBlockIndex* block = chainman().m_blockman.LookupBlockIndex(block_hash)) {
+ - ]
599 [ + - + + ]: 41 : if (const CBlockIndex* ancestor = block->GetAncestor(ancestor_height)) {
600 [ + - + - ]: 40 : return FillBlock(ancestor, ancestor_out, lock, active, chainman().m_blockman);
601 : : }
602 : : }
603 [ + - + - ]: 1 : return FillBlock(nullptr, ancestor_out, lock, active, chainman().m_blockman);
604 : 41 : }
605 : 7 : bool findAncestorByHash(const uint256& block_hash, const uint256& ancestor_hash, const FoundBlock& ancestor_out) override
606 : : {
607 : 7 : WAIT_LOCK(cs_main, lock);
608 [ + - + - ]: 7 : const CBlockIndex* block = chainman().m_blockman.LookupBlockIndex(block_hash);
609 [ + - + - ]: 7 : const CBlockIndex* ancestor = chainman().m_blockman.LookupBlockIndex(ancestor_hash);
610 [ + + + - : 7 : if (block && ancestor && block->GetAncestor(ancestor->nHeight) != ancestor) ancestor = nullptr;
+ + ]
611 [ + - + - : 7 : return FillBlock(ancestor, ancestor_out, lock, chainman().ActiveChain(), chainman().m_blockman);
+ - + - +
- ]
612 : 7 : }
613 : 22 : bool findCommonAncestor(const uint256& block_hash1, const uint256& block_hash2, const FoundBlock& ancestor_out, const FoundBlock& block1_out, const FoundBlock& block2_out) override
614 : : {
615 : 22 : WAIT_LOCK(cs_main, lock);
616 [ + - + - ]: 22 : const CChain& active = chainman().ActiveChain();
617 [ + - + - ]: 22 : const CBlockIndex* block1 = chainman().m_blockman.LookupBlockIndex(block_hash1);
618 [ + - + - ]: 22 : const CBlockIndex* block2 = chainman().m_blockman.LookupBlockIndex(block_hash2);
619 [ + + + - ]: 22 : const CBlockIndex* ancestor = block1 && block2 ? LastCommonAncestor(block1, block2) : nullptr;
620 : : // Using & instead of && below to avoid short circuiting and leaving
621 : : // output uninitialized. Cast bool to int to avoid -Wbitwise-instead-of-logical
622 : : // compiler warnings.
623 [ + - + - ]: 22 : return int{FillBlock(ancestor, ancestor_out, lock, active, chainman().m_blockman)} &
624 [ + - + - ]: 22 : int{FillBlock(block1, block1_out, lock, active, chainman().m_blockman)} &
625 [ + - + - : 22 : int{FillBlock(block2, block2_out, lock, active, chainman().m_blockman)};
+ - ]
626 : 22 : }
627 : 990 : void findCoins(std::map<COutPoint, Coin>& coins) override { return FindCoins(m_node, coins); }
628 : 72160 : double guessVerificationProgress(const uint256& block_hash) override
629 : : {
630 : 72160 : LOCK(chainman().GetMutex());
631 [ + - + - : 72160 : return chainman().GuessVerificationProgress(chainman().m_blockman.LookupBlockIndex(block_hash));
+ - + - +
- ]
632 : 72160 : }
633 : 35 : bool hasBlocks(const uint256& block_hash, int min_height, std::optional<int> max_height) override
634 : : {
635 : : // hasBlocks returns true if all ancestors of block_hash in specified
636 : : // range have block data (are not pruned), false if any ancestors in
637 : : // specified range are missing data.
638 : : //
639 : : // For simplicity and robustness, min_height and max_height are only
640 : : // used to limit the range, and passing min_height that's too low or
641 : : // max_height that's too high will not crash or change the result.
642 : 35 : LOCK(::cs_main);
643 [ + - + - : 35 : if (const CBlockIndex* block = chainman().m_blockman.LookupBlockIndex(block_hash)) {
+ - ]
644 [ + + + + : 35 : if (max_height && block->nHeight >= *max_height) block = block->GetAncestor(*max_height);
+ - ]
645 [ + + ]: 3389 : for (; block->nStatus & BLOCK_HAVE_DATA; block = block->pprev) {
646 : : // Check pprev to not segfault if min_height is too low
647 [ + + + + ]: 3373 : if (block->nHeight <= min_height || !block->pprev) return true;
648 : : }
649 : : }
650 : : return false;
651 : 35 : }
652 : 666 : RBFTransactionState isRBFOptIn(const CTransaction& tx) override
653 : : {
654 [ - + ]: 666 : if (!m_node.mempool) return IsRBFOptInEmptyMempool(tx);
655 : 666 : LOCK(m_node.mempool->cs);
656 [ + - + - ]: 666 : return IsRBFOptIn(tx, *m_node.mempool);
657 : 666 : }
658 : 18754 : bool isInMempool(const Txid& txid) override
659 : : {
660 [ + - ]: 18754 : if (!m_node.mempool) return false;
661 : 18754 : return m_node.mempool->exists(txid);
662 : : }
663 : 223 : bool hasDescendantsInMempool(const Txid& txid) override
664 : : {
665 [ + - ]: 223 : if (!m_node.mempool) return false;
666 : 223 : return m_node.mempool->HasDescendants(txid);
667 : : }
668 : 1646 : bool broadcastTransaction(const CTransactionRef& tx,
669 : : const CAmount& max_tx_fee,
670 : : TxBroadcast broadcast_method,
671 : : std::string& err_string) override
672 : : {
673 [ + - + - : 3292 : const TransactionError err = BroadcastTransaction(m_node, tx, err_string, max_tx_fee, broadcast_method, /*wait_callback=*/false);
+ - ]
674 : : // Chain clients only care about failures to accept the tx to the mempool. Disregard non-mempool related failures.
675 : : // Note: this will need to be updated if BroadcastTransactions() is updated to return other non-mempool failures
676 : : // that Chain clients do not need to know about.
677 : 1646 : return TransactionError::OK == err;
678 : : }
679 : 580356 : void getTransactionAncestry(const Txid& txid, size_t& ancestors, size_t& cluster_count, size_t* ancestorsize, CAmount* ancestorfees) override
680 : : {
681 : 580356 : ancestors = cluster_count = 0;
682 [ + - ]: 580356 : if (!m_node.mempool) return;
683 : 580356 : m_node.mempool->GetTransactionAncestry(txid, ancestors, cluster_count, ancestorsize, ancestorfees);
684 : : }
685 : :
686 : 4037 : std::map<COutPoint, CAmount> calculateIndividualBumpFees(const std::vector<COutPoint>& outpoints, const CFeeRate& target_feerate) override
687 : : {
688 [ - + ]: 4037 : if (!m_node.mempool) {
689 : 0 : std::map<COutPoint, CAmount> bump_fees;
690 [ # # ]: 0 : for (const auto& outpoint : outpoints) {
691 [ # # ]: 0 : bump_fees.emplace(outpoint, 0);
692 : : }
693 : : return bump_fees;
694 : 0 : }
695 [ + - ]: 4037 : return MiniMiner(*m_node.mempool, outpoints).CalculateBumpFees(target_feerate);
696 : : }
697 : :
698 : 9162 : std::optional<CAmount> calculateCombinedBumpFee(const std::vector<COutPoint>& outpoints, const CFeeRate& target_feerate) override
699 : : {
700 [ - + ]: 9162 : if (!m_node.mempool) {
701 : 0 : return 0;
702 : : }
703 [ + - ]: 9162 : return MiniMiner(*m_node.mempool, outpoints).CalculateTotalBumpFees(target_feerate);
704 : : }
705 : 3211 : void getPackageLimits(unsigned int& limit_ancestor_count, unsigned int& limit_descendant_count) override
706 : : {
707 : 3211 : const CTxMemPool::Limits default_limits{};
708 : :
709 [ + - ]: 3211 : const CTxMemPool::Limits& limits{m_node.mempool ? m_node.mempool->m_opts.limits : default_limits};
710 : :
711 : 3211 : limit_ancestor_count = limits.ancestor_count;
712 : 3211 : limit_descendant_count = limits.descendant_count;
713 : 3211 : }
714 : 3385 : util::Result<void> checkChainLimits(const CTransactionRef& tx) override
715 : : {
716 [ - + ]: 3385 : if (!m_node.mempool) return {};
717 [ + + ]: 3385 : if (!m_node.mempool->CheckPolicyLimits(tx)) {
718 [ + - ]: 3 : return util::Error{Untranslated("too many unconfirmed transactions in cluster")};
719 : : }
720 : 3384 : return {};
721 : : }
722 : 6271 : CFeeRate estimateSmartFee(int num_blocks, bool conservative, FeeCalculation* calc) override
723 : : {
724 [ + + ]: 6271 : if (!m_node.fee_estimator) return {};
725 : 6249 : return m_node.fee_estimator->estimateSmartFee(num_blocks, calc, conservative);
726 : : }
727 : 3584 : unsigned int estimateMaxBlocks() override
728 : : {
729 [ + + ]: 3584 : if (!m_node.fee_estimator) return 0;
730 : 3569 : return m_node.fee_estimator->HighestTargetTracked(FeeEstimateHorizon::LONG_HALFLIFE);
731 : : }
732 : 2741 : CFeeRate mempoolMinFee() override
733 : : {
734 [ - + ]: 2741 : if (!m_node.mempool) return {};
735 : 2741 : return m_node.mempool->GetMinFee();
736 : : }
737 : 4432 : CFeeRate relayMinFee() override
738 : : {
739 [ - + ]: 4432 : if (!m_node.mempool) return CFeeRate{DEFAULT_MIN_RELAY_TX_FEE};
740 : 4432 : return m_node.mempool->m_opts.min_relay_feerate;
741 : : }
742 : 121 : CFeeRate relayIncrementalFee() override
743 : : {
744 [ - + ]: 121 : if (!m_node.mempool) return CFeeRate{DEFAULT_INCREMENTAL_RELAY_FEE};
745 : 121 : return m_node.mempool->m_opts.incremental_relay_feerate;
746 : : }
747 : 44773 : CFeeRate relayDustFee() override
748 : : {
749 [ - + ]: 44773 : if (!m_node.mempool) return CFeeRate{DUST_RELAY_TX_FEE};
750 : 44773 : return m_node.mempool->m_opts.dust_relay_feerate;
751 : : }
752 : 59 : bool havePruned() override
753 : : {
754 : 59 : LOCK(::cs_main);
755 [ + - + - ]: 59 : return chainman().m_blockman.m_have_pruned;
756 : 59 : }
757 : 1 : std::optional<int> getPruneHeight() override
758 : : {
759 : 1 : LOCK(chainman().GetMutex());
760 [ + - + - : 1 : return GetPruneHeight(chainman().m_blockman, chainman().ActiveChain());
+ - + - ]
761 : 1 : }
762 [ + - + + ]: 214 : bool isReadyToBroadcast() override { return !chainman().m_blockman.LoadingBlocks() && !isInitialBlockDownload(); }
763 : 3098 : bool isInitialBlockDownload() override
764 : : {
765 : 3098 : return chainman().IsInitialBlockDownload();
766 : : }
767 : 71956 : bool shutdownRequested() override { return ShutdownRequested(m_node); }
768 : 1313 : void initMessage(const std::string& message) override { ::uiInterface.InitMessage(message); }
769 : 4 : void initWarning(const bilingual_str& message) override { InitWarning(message); }
770 : 26 : void initError(const bilingual_str& message) override { InitError(message); }
771 : 0 : void showProgress(const std::string& title, int progress, bool resume_possible) override
772 : : {
773 : 0 : ::uiInterface.ShowProgress(title, progress, resume_possible);
774 : 0 : }
775 : 879 : std::unique_ptr<Handler> handleNotifications(std::shared_ptr<Notifications> notifications) override
776 : : {
777 : 879 : return std::make_unique<NotificationsHandlerImpl>(validation_signals(), std::move(notifications));
778 : : }
779 : 6301 : void waitForNotificationsIfTipChanged(const uint256& old_tip) override
780 : : {
781 [ + + + + : 31493 : if (!old_tip.IsNull() && old_tip == WITH_LOCK(::cs_main, return chainman().ActiveChain().Tip()->GetBlockHash())) return;
+ - + - -
+ + - ]
782 : 217 : validation_signals().SyncWithValidationInterfaceQueue();
783 : : }
784 : 23883 : std::unique_ptr<Handler> handleRpc(const CRPCCommand& command) override
785 : : {
786 : 23883 : return std::make_unique<RpcHandlerImpl>(command);
787 : : }
788 : 19 : bool rpcEnableDeprecated(const std::string& method) override { return IsDeprecatedRPCEnabled(method); }
789 : 0 : common::SettingsValue getSetting(const std::string& name) override
790 : : {
791 : 0 : return args().GetSetting(name);
792 : : }
793 : 749 : std::vector<common::SettingsValue> getSettingsList(const std::string& name) override
794 : : {
795 : 749 : return args().GetSettingsList(name);
796 : : }
797 : 3 : common::SettingsValue getRwSetting(const std::string& name) override
798 : : {
799 [ + - ]: 3 : common::SettingsValue result;
800 [ + - + - ]: 3 : args().LockSettings([&](const common::Settings& settings) {
801 [ + + ]: 3 : if (const common::SettingsValue* value = common::FindKey(settings.rw_settings, name)) {
802 : 2 : result = *value;
803 : : }
804 : 3 : });
805 : 3 : return result;
806 : 0 : }
807 : 199 : bool updateRwSetting(const std::string& name,
808 : : const interfaces::SettingsUpdate& update_settings_func) override
809 : : {
810 : 199 : std::optional<interfaces::SettingsAction> action;
811 : 199 : args().LockSettings([&](common::Settings& settings) {
812 [ + + ]: 199 : if (auto* value = common::FindKey(settings.rw_settings, name)) {
813 : 45 : action = update_settings_func(*value);
814 [ - + ]: 45 : if (value->isNull()) settings.rw_settings.erase(name);
815 : : } else {
816 [ + - ]: 154 : UniValue new_value;
817 [ + - ]: 154 : action = update_settings_func(new_value);
818 [ + + + - ]: 154 : if (!new_value.isNull()) settings.rw_settings[name] = std::move(new_value);
819 : 154 : }
820 : 199 : });
821 [ + - ]: 199 : if (!action) return false;
822 : : // Now dump value to disk if requested
823 [ + + + - ]: 199 : return *action != interfaces::SettingsAction::WRITE || args().WriteSettingsFile();
824 : : }
825 : 1 : bool overwriteRwSetting(const std::string& name, common::SettingsValue value, interfaces::SettingsAction action) override
826 : : {
827 [ + - ]: 1 : return updateRwSetting(name, [&](common::SettingsValue& settings) {
828 : 1 : settings = std::move(value);
829 : 1 : return action;
830 : 1 : });
831 : : }
832 : 0 : bool deleteRwSettings(const std::string& name, interfaces::SettingsAction action) override
833 : : {
834 [ # # ]: 0 : return overwriteRwSetting(name, {}, action);
835 : : }
836 : 1521 : void requestMempoolTransactions(Notifications& notifications) override
837 : : {
838 [ + - ]: 1521 : if (!m_node.mempool) return;
839 [ + - ]: 1521 : LOCK2(::cs_main, m_node.mempool->cs);
840 [ + - + - : 1958 : for (const CTxMemPoolEntry& entry : m_node.mempool->entryAll()) {
+ + ]
841 [ + - + - ]: 1311 : notifications.transactionAddedToMempool(entry.GetSharedTx());
842 [ + - ]: 1521 : }
843 [ + - ]: 3042 : }
844 : 56 : bool hasAssumedValidChain() override
845 : : {
846 : 56 : return chainman().IsSnapshotActive();
847 : : }
848 : :
849 : 816 : NodeContext* context() override { return &m_node; }
850 [ - + ]: 1143 : ArgsManager& args() { return *Assert(m_node.args); }
851 [ - + ]: 803170 : ChainstateManager& chainman() { return *Assert(m_node.chainman); }
852 [ - + ]: 1096 : ValidationSignals& validation_signals() { return *Assert(m_node.validation_signals); }
853 : : NodeContext& m_node;
854 : : };
855 : :
856 : : class BlockTemplateImpl : public BlockTemplate
857 : : {
858 : : public:
859 : 39728 : explicit BlockTemplateImpl(BlockAssembler::Options assemble_options,
860 : : std::unique_ptr<CBlockTemplate> block_template,
861 : 39728 : NodeContext& node) : m_assemble_options(std::move(assemble_options)),
862 [ - + ]: 39728 : m_block_template(std::move(block_template)),
863 : 39728 : m_node(node)
864 : : {
865 [ - + ]: 39728 : assert(m_block_template);
866 : 39728 : }
867 : :
868 : 1 : CBlockHeader getBlockHeader() override
869 : : {
870 : 1 : return m_block_template->block;
871 : : }
872 : :
873 : 41730 : CBlock getBlock() override
874 : : {
875 : 41730 : return m_block_template->block;
876 : : }
877 : :
878 : 2079 : std::vector<CAmount> getTxFees() override
879 : : {
880 : 2079 : return m_block_template->vTxFees;
881 : : }
882 : :
883 : 2079 : std::vector<int64_t> getTxSigops() override
884 : : {
885 : 2079 : return m_block_template->vTxSigOpsCost;
886 : : }
887 : :
888 : 0 : CTransactionRef getCoinbaseTx() override
889 : : {
890 [ # # ]: 0 : return m_block_template->block.vtx[0];
891 : : }
892 : :
893 : 4158 : std::vector<unsigned char> getCoinbaseCommitment() override
894 : : {
895 : 4158 : return m_block_template->vchCoinbaseCommitment;
896 : : }
897 : :
898 : 0 : int getWitnessCommitmentIndex() override
899 : : {
900 : 0 : return GetWitnessCommitmentIndex(m_block_template->block);
901 : : }
902 : :
903 : 0 : std::vector<uint256> getCoinbaseMerklePath() override
904 : : {
905 : 0 : return TransactionMerklePath(m_block_template->block, 0);
906 : : }
907 : :
908 : 55 : bool submitSolution(uint32_t version, uint32_t timestamp, uint32_t nonce, CTransactionRef coinbase) override
909 : : {
910 [ + - ]: 55 : AddMerkleRootAndCoinbase(m_block_template->block, std::move(coinbase), version, timestamp, nonce);
911 [ + - + - ]: 110 : return chainman().ProcessNewBlock(std::make_shared<const CBlock>(m_block_template->block), /*force_processing=*/true, /*min_pow_checked=*/true, /*new_block=*/nullptr);
912 : : }
913 : :
914 : 62 : std::unique_ptr<BlockTemplate> waitNext(BlockWaitOptions options) override
915 : : {
916 : 62 : auto new_template = WaitAndCreateNewBlock(chainman(), notifications(), m_node.mempool.get(), m_block_template, options, m_assemble_options, m_interrupt_wait);
917 [ + + + - ]: 62 : if (new_template) return std::make_unique<BlockTemplateImpl>(m_assemble_options, std::move(new_template), m_node);
918 : 4 : return nullptr;
919 : 62 : }
920 : :
921 : 0 : void interruptWait() override
922 : : {
923 : 0 : InterruptWait(notifications(), m_interrupt_wait);
924 : 0 : }
925 : :
926 : : const BlockAssembler::Options m_assemble_options;
927 : :
928 : : const std::unique_ptr<CBlockTemplate> m_block_template;
929 : :
930 : : bool m_interrupt_wait{false};
931 [ - + ]: 117 : ChainstateManager& chainman() { return *Assert(m_node.chainman); }
932 [ - + ]: 62 : KernelNotifications& notifications() { return *Assert(m_node.notifications); }
933 : : NodeContext& m_node;
934 : : };
935 : :
936 : : class MinerImpl : public Mining
937 : : {
938 : : public:
939 : 1139 : explicit MinerImpl(NodeContext& node) : m_node(node) {}
940 : :
941 : 2080 : bool isTestChain() override
942 : : {
943 : 2080 : return chainman().GetParams().IsTestChain();
944 : : }
945 : :
946 : 0 : bool isInitialBlockDownload() override
947 : : {
948 : 0 : return chainman().IsInitialBlockDownload();
949 : : }
950 : :
951 : 2215 : std::optional<BlockRef> getTip() override
952 : : {
953 : 2215 : return GetTip(chainman());
954 : : }
955 : :
956 : 39751 : std::optional<BlockRef> waitTipChanged(uint256 current_tip, MillisecondsDouble timeout) override
957 : : {
958 : 39751 : return WaitTipChanged(chainman(), notifications(), current_tip, timeout);
959 : : }
960 : :
961 : 39675 : std::unique_ptr<BlockTemplate> createNewBlock(const BlockCreateOptions& options) override
962 : : {
963 : : // Ensure m_tip_block is set so consumers of BlockTemplate can rely on that.
964 [ - + ]: 39675 : if (!waitTipChanged(uint256::ZERO, MillisecondsDouble::max())) return {};
965 : :
966 [ - + ]: 39675 : BlockAssembler::Options assemble_options{options};
967 [ - + + - ]: 39675 : ApplyArgsManOptions(*Assert(m_node.args), assemble_options);
968 [ + - + - : 79350 : return std::make_unique<BlockTemplateImpl>(assemble_options, BlockAssembler{chainman().ActiveChainstate(), context()->mempool.get(), assemble_options}.CreateNewBlock(), m_node);
+ - + - +
+ + - ]
969 : 39670 : }
970 : :
971 : 3 : bool checkBlock(const CBlock& block, const node::BlockCheckOptions& options, std::string& reason, std::string& debug) override
972 : : {
973 : 3 : LOCK(chainman().GetMutex());
974 [ + - + - : 3 : BlockValidationState state{TestBlockValidity(chainman().ActiveChainstate(), block, /*check_pow=*/options.check_pow, /*=check_merkle_root=*/options.check_merkle_root)};
+ - ]
975 [ - + ]: 6 : reason = state.GetRejectReason();
976 [ - + ]: 6 : debug = state.GetDebugMessage();
977 : 3 : return state.IsValid();
978 [ + - ]: 6 : }
979 : :
980 : 39675 : NodeContext* context() override { return &m_node; }
981 [ - + ]: 83727 : ChainstateManager& chainman() { return *Assert(m_node.chainman); }
982 [ - + ]: 39751 : KernelNotifications& notifications() { return *Assert(m_node.notifications); }
983 : : NodeContext& m_node;
984 : : };
985 : : } // namespace
986 : : } // namespace node
987 : :
988 : : namespace interfaces {
989 : 0 : std::unique_ptr<Node> MakeNode(node::NodeContext& context) { return std::make_unique<node::NodeImpl>(context); }
990 : 1900 : std::unique_ptr<Chain> MakeChain(node::NodeContext& context) { return std::make_unique<node::ChainImpl>(context); }
991 : 1139 : std::unique_ptr<Mining> MakeMining(node::NodeContext& context) { return std::make_unique<node::MinerImpl>(context); }
992 : : } // namespace interfaces
|
