Skip to content

Commit

Permalink
Use start/stop patter in block_processor
Browse files Browse the repository at this point in the history
  • Loading branch information
pwojcikdev committed Mar 5, 2024
1 parent 5a775d5 commit 3e35996
Show file tree
Hide file tree
Showing 3 changed files with 26 additions and 6 deletions.
23 changes: 19 additions & 4 deletions nano/node/blockprocessor.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -45,9 +45,21 @@ nano::block_processor::block_processor (nano::node & node_a, nano::write_databas
block_processed.notify (result, context);
}
});
processing_thread = std::thread ([this] () {
}

nano::block_processor::~block_processor ()
{
// Thread must be stopped before destruction
debug_assert (!thread.joinable ());
}

void nano::block_processor::start ()
{
debug_assert (!thread.joinable ());

thread = std::thread ([this] () {
nano::thread_role::set (nano::thread_role::name::block_processing);
this->process_blocks ();
run ();
});
}

Expand All @@ -58,7 +70,10 @@ void nano::block_processor::stop ()
stopped = true;
}
condition.notify_all ();
nano::join_or_pass (processing_thread);
if (thread.joinable ())
{
thread.join ();
}
}

std::size_t nano::block_processor::size ()
Expand Down Expand Up @@ -171,7 +186,7 @@ void nano::block_processor::rollback_competitor (store::write_transaction const
}
}

void nano::block_processor::process_blocks ()
void nano::block_processor::run ()
{
nano::unique_lock<nano::mutex> lock{ mutex };
while (!stopped)
Expand Down
8 changes: 6 additions & 2 deletions nano/node/blockprocessor.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -63,8 +63,11 @@ class block_processor final

public:
block_processor (nano::node &, nano::write_database_queue &);
~block_processor ();

void start ();
void stop ();

std::size_t size ();
bool full ();
bool half_full ();
Expand All @@ -74,7 +77,7 @@ class block_processor final
bool should_log ();
bool have_blocks_ready ();
bool have_blocks ();
void process_blocks ();

std::unique_ptr<container_info_component> collect_container_info (std::string const & name);

std::atomic<bool> flushing{ false };
Expand All @@ -89,6 +92,7 @@ class block_processor final
nano::observer_set<std::shared_ptr<nano::block> const &> rolled_back;

private:
void run ();
// Roll back block in the ledger that conflicts with 'block'
void rollback_competitor (store::write_transaction const &, nano::block const & block);
nano::block_status process_one (store::write_transaction const &, context const &, bool forced = false);
Expand All @@ -111,6 +115,6 @@ class block_processor final
std::chrono::steady_clock::time_point next_log;
nano::condition_variable condition;
nano::mutex mutex{ mutex_identifier (mutexes::block_processor) };
std::thread processing_thread;
std::thread thread;
};
}
1 change: 1 addition & 0 deletions nano/node/node.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -646,6 +646,7 @@ void nano::node::start ()
port_mapping.start ();
}
wallets.start ();
block_processor.start ();
active.start ();
generator.start ();
final_generator.start ();
Expand Down

0 comments on commit 3e35996

Please sign in to comment.