From b6efeb699ad4329c1b4824d96f2dadab60fa0b7b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Wo=CC=81jcik?=
 <3044353+pwojcikdev@users.noreply.github.com>
Date: Fri, 18 Oct 2024 13:57:58 +0200
Subject: [PATCH] Cleanup

---
 nano/node/active_elections.cpp | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/nano/node/active_elections.cpp b/nano/node/active_elections.cpp
index c161038e..6536b2c4 100644
--- a/nano/node/active_elections.cpp
+++ b/nano/node/active_elections.cpp
@@ -29,6 +29,7 @@ nano::active_elections::active_elections (nano::node & node_a, nano::confirming_
 {
 	count_by_behavior.fill (0); // Zero initialize array
 
+	// Cementing blocks might implicitly confirm dependent elections
 	confirming_set.batch_cemented.add ([this] (auto const & cemented) {
 		auto transaction = node.ledger.tx_begin_read ();
 		for (auto const & [block, confirmation_root, source_election] : cemented)
@@ -39,10 +40,13 @@ nano::active_elections::active_elections (nano::node & node_a, nano::confirming_
 	});
 
 	// Notify elections about alternative (forked) blocks
-	block_processor.block_processed.add ([this] (auto const & result, auto const & context) {
-		if (result == nano::block_status::fork)
+	block_processor.batch_processed.add ([this] (auto const & batch) {
+		for (auto const & [result, context] : batch)
 		{
-			publish (context.block);
+			if (result == nano::block_status::fork)
+			{
+				publish (context.block);
+			}
 		}
 	});
 }