dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Remove unused process_live_dispatcher (#4831)

Browse source
This commit is contained in:
Piotr Wójcik 2025-01-20 21:16:25 +01:00 • committed by GitHub
commit 19e1cc6296
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 0 additions and 78 deletions
Download patch file Download diff file Expand all files Collapse all files

2
nano/node/CMakeLists.txt
View file

@ -128,8 +128,6 @@ add_library(
peer_exclusion.cpp peer_exclusion.cpp
portmapping.hpp portmapping.hpp
portmapping.cpp portmapping.cpp
process_live_dispatcher.cpp
process_live_dispatcher.hpp
pruning.hpp pruning.hpp
pruning.cpp pruning.cpp
recently_cemented_cache.cpp recently_cemented_cache.cpp

4
nano/node/node.cpp
View file

@ -192,8 +192,6 @@ nano::node::node (std::shared_ptr<boost::asio::io_context> io_ctx_a, std::filesy
epoch_upgrader{ *epoch_upgrader_impl }, epoch_upgrader{ *epoch_upgrader_impl },
local_block_broadcaster_impl{ std::make_unique<nano::local_block_broadcaster> (config.local_block_broadcaster, *this, ledger_notifications, network, confirming_set, stats, logger, !flags.disable_block_processor_republishing) }, local_block_broadcaster_impl{ std::make_unique<nano::local_block_broadcaster> (config.local_block_broadcaster, *this, ledger_notifications, network, confirming_set, stats, logger, !flags.disable_block_processor_republishing) },
local_block_broadcaster{ *local_block_broadcaster_impl }, local_block_broadcaster{ *local_block_broadcaster_impl },
process_live_dispatcher_impl{ std::make_unique<nano::process_live_dispatcher> (ledger, scheduler.priority, vote_cache, websocket) },
process_live_dispatcher{ *process_live_dispatcher_impl },
peer_history_impl{ std::make_unique<nano::peer_history> (config.peer_history, store, network, logger, stats) }, peer_history_impl{ std::make_unique<nano::peer_history> (config.peer_history, store, network, logger, stats) },
peer_history{ *peer_history_impl }, peer_history{ *peer_history_impl },
monitor_impl{ std::make_unique<nano::monitor> (config.monitor, *this) }, monitor_impl{ std::make_unique<nano::monitor> (config.monitor, *this) },
@ -207,8 +205,6 @@ nano::node::node (std::shared_ptr<boost::asio::io_context> io_ctx_a, std::filesy
{ {
logger.debug (nano::log::type::node, "Constructing node..."); logger.debug (nano::log::type::node, "Constructing node...");
process_live_dispatcher.connect (block_processor);
vote_cache.rep_weight_query = [this] (nano::account const & rep) { vote_cache.rep_weight_query = [this] (nano::account const & rep) {
return ledger.weight (rep); return ledger.weight (rep);
}; };

3
nano/node/node.hpp
View file

@ -13,7 +13,6 @@
#include <nano/node/nodeconfig.hpp> #include <nano/node/nodeconfig.hpp>
#include <nano/node/online_reps.hpp> #include <nano/node/online_reps.hpp>
#include <nano/node/portmapping.hpp> #include <nano/node/portmapping.hpp>
#include <nano/node/process_live_dispatcher.hpp>
#include <nano/node/rep_tiers.hpp> #include <nano/node/rep_tiers.hpp>
#include <nano/node/repcrawler.hpp> #include <nano/node/repcrawler.hpp>
#include <nano/node/transport/tcp_server.hpp> #include <nano/node/transport/tcp_server.hpp>
@ -193,8 +192,6 @@ public:
nano::epoch_upgrader & epoch_upgrader; nano::epoch_upgrader & epoch_upgrader;
std::unique_ptr<nano::local_block_broadcaster> local_block_broadcaster_impl; std::unique_ptr<nano::local_block_broadcaster> local_block_broadcaster_impl;
nano::local_block_broadcaster & local_block_broadcaster; nano::local_block_broadcaster & local_block_broadcaster;
std::unique_ptr<nano::process_live_dispatcher> process_live_dispatcher_impl;
nano::process_live_dispatcher & process_live_dispatcher;
std::unique_ptr<nano::peer_history> peer_history_impl; std::unique_ptr<nano::peer_history> peer_history_impl;
nano::peer_history & peer_history; nano::peer_history & peer_history;
std::unique_ptr<nano::monitor> monitor_impl; std::unique_ptr<nano::monitor> monitor_impl;

30
nano/node/process_live_dispatcher.cpp
View file

@ -1,30 +0,0 @@
#include <nano/lib/blocks.hpp>
#include <nano/node/block_processor.hpp>
#include <nano/node/process_live_dispatcher.hpp>
#include <nano/node/scheduler/priority.hpp>
#include <nano/node/vote_cache.hpp>
#include <nano/node/websocket.hpp>
#include <nano/secure/common.hpp>
#include <nano/secure/ledger.hpp>
#include <nano/secure/transaction.hpp>
#include <nano/store/component.hpp>
nano::process_live_dispatcher::process_live_dispatcher (nano::ledger & ledger, nano::scheduler::priority & scheduler, nano::vote_cache & vote_cache, nano::websocket_server & websocket) :
ledger{ ledger },
scheduler{ scheduler },
vote_cache{ vote_cache },
websocket{ websocket }
{
}
void nano::process_live_dispatcher::connect (nano::block_processor & block_processor)
{
}
void nano::process_live_dispatcher::inspect (nano::block_status const & result, nano::block const & block, secure::transaction const & transaction)
{
}
void nano::process_live_dispatcher::process_live (nano::block const & block, secure::transaction const & transaction)
{
}

39
nano/node/process_live_dispatcher.hpp
View file

@ -1,39 +0,0 @@
#pragma once
namespace nano::secure
{
class transaction;
}
namespace nano
{
class ledger;
class vote_cache;
class websocket_server;
class block_processor;
class process_return;
class block;
namespace scheduler
{
class priority;
}
// Observes confirmed blocks and dispatches the process_live function.
class process_live_dispatcher
{
public:
process_live_dispatcher (nano::ledger &, nano::scheduler::priority &, nano::vote_cache &, nano::websocket_server &);
void connect (nano::block_processor & block_processor);
private:
// Block_processor observer
void inspect (nano::block_status const & result, nano::block const & block, secure::transaction const & transaction);
void process_live (nano::block const & block, secure::transaction const & transaction);
nano::ledger & ledger;
nano::scheduler::priority & scheduler;
nano::vote_cache & vote_cache;
nano::websocket_server & websocket;
};
}