From 124421bfefe8add44058caf628b8046a699b9dfe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Piotr=20Wo=CC=81jcik?= <3044353+pwojcikdev@users.noreply.github.com> Date: Thu, 8 Feb 2024 19:12:15 +0100 Subject: [PATCH] Name conflict --- nano/node/active_transactions.cpp | 2 +- nano/node/block_broadcast.cpp | 2 +- nano/node/blockprocessor.cpp | 2 +- nano/node/blockprocessor.hpp | 4 ++-- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/nano/node/active_transactions.cpp b/nano/node/active_transactions.cpp index b32a3ace..74f1ba4e 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 e3f2fc56..2fb61e6a 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 0e33234f..3130da49 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 bf3c59ef..97dbb71e 100644 --- a/nano/node/blockprocessor.hpp +++ b/nano/node/blockprocessor.hpp @@ -87,8 +87,8 @@ public: // Events using processed_t = std::tuple, context>; using processed_batch_t = std::deque; - // The batch observer feeds the processed obsever - nano::observer_set const &, context const &> processed; + // The batch observer feeds the processed observer + nano::observer_set const &, context const &> block_processed; nano::observer_set batch_processed; private: