diff --git a/nano/node/active_transactions.cpp b/nano/node/active_transactions.cpp index b32a3aced2..74f1ba4e9f 100644 --- a/nano/node/active_transactions.cpp +++ b/nano/node/active_transactions.cpp @@ -34,7 +34,7 @@ nano::active_transactions::active_transactions (nano::node & node_a, nano::confi }); // Notify elections about alternative (forked) blocks - block_processor.processed.add ([this] (auto const & result, auto const & block, auto const & context) { + block_processor.block_processed.add ([this] (auto const & result, auto const & block, auto const & context) { switch (result.code) { case nano::process_result::fork: diff --git a/nano/node/block_broadcast.cpp b/nano/node/block_broadcast.cpp index e3f2fc561c..2fb61e6a17 100644 --- a/nano/node/block_broadcast.cpp +++ b/nano/node/block_broadcast.cpp @@ -14,7 +14,7 @@ void nano::block_broadcast::connect (nano::block_processor & block_processor) { return; } - block_processor.processed.add ([this] (auto const & result, auto const & block, auto const & context) { + block_processor.block_processed.add ([this] (auto const & result, auto const & block, auto const & context) { switch (result.code) { case nano::process_result::progress: diff --git a/nano/node/blockprocessor.cpp b/nano/node/blockprocessor.cpp index 0e33234fd3..3130da4997 100644 --- a/nano/node/blockprocessor.cpp +++ b/nano/node/blockprocessor.cpp @@ -41,7 +41,7 @@ nano::block_processor::block_processor (nano::node & node_a, nano::write_databas // For every batch item: notify the 'processed' observer. for (auto const & [result, block, context] : items) { - processed.notify (result, block, context); + block_processed.notify (result, block, context); } }); processing_thread = std::thread ([this] () { diff --git a/nano/node/blockprocessor.hpp b/nano/node/blockprocessor.hpp index bf3c59ef04..ed882352aa 100644 --- a/nano/node/blockprocessor.hpp +++ b/nano/node/blockprocessor.hpp @@ -88,7 +88,7 @@ class block_processor final using processed_batch_t = std::deque; // The batch observer feeds the processed obsever - nano::observer_set const &, context const &> processed; + nano::observer_set const &, context const &> block_processed; nano::observer_set batch_processed; private: