Update confirmation height in another thread

nano/lib/errors.cpp

@@ -146,6 +146,8 @@ std::string nano::error_rpc_messages::message (int ev) const
 			return "Representative account and previous hash required";
 		case nano::error_rpc::block_create_requirements_send:
 			return "Destination account, previous hash, current balance and amount required";
+		case nano::error_rpc::confirmation_height_not_processing:
+			return "There are no blocks currently being processed for adding confirmation height";
 		case nano::error_rpc::confirmation_not_found:
 			return "Active confirmation not found";
 		case nano::error_rpc::difficulty_limit:

nano/lib/errors.hpp

@@ -89,6 +89,7 @@ enum class error_rpc
 	block_create_requirements_receive,
 	block_create_requirements_change,
 	block_create_requirements_send,
+	confirmation_height_not_processing,
 	confirmation_not_found,
 	difficulty_limit,
 	invalid_balance,

nano/lib/utility.cpp

@@ -102,6 +102,9 @@ namespace thread_role
 			case nano::thread_role::name::rpc_process_container:
 				thread_role_name_string = "RPC process";
 				break;
+			case nano::thread_role::name::confirmation_height_processing:
+				thread_role_name_string = "Conf height";
+				break;
 		}
 
 		/*

nano/lib/utility.hpp

@@ -87,7 +87,8 @@ namespace thread_role
 		voting,
 		signature_checking,
 		rpc_request_processor,
-		rpc_process_container
+		rpc_process_container,
+		confirmation_height_processing
 	};
 	/*
 	 * Get/Set the identifier for the current thread

nano/nano_node/entry.cpp

@@ -98,7 +98,7 @@ int main (int argc, char * const * argv)
 		("debug_random_feed", "Generates output to RNG test suites")
 		("debug_validate_blocks", "Check all blocks for correct hash, signature, work value")
 		("debug_peers", "Display peer IPv6:port connections")
-		("debug_ipc", "Read an IPC command in JSON from stdin and invoke it. Network operations will have no effect")
+		("debug_cemented_block_count", "Displays the number of cemented (confirmed) blocks")
 		("platform", boost::program_options::value<std::string> (), "Defines the <platform> for OpenCL commands")
 		("device", boost::program_options::value<std::string> (), "Defines <device> for OpenCL command")
 		("threads", boost::program_options::value<std::string> (), "Defines <threads> count for OpenCL command")
@@ -960,6 +960,19 @@ int main (int argc, char * const * argv)
 				std::cout << boost::str (boost::format ("%1%\n") % nano::endpoint (boost::asio::ip::address_v6 (i->first.address_bytes ()), i->first.port ()));
 			}
 		}
+		else if (vm.count ("debug_cemented_block_count"))
+		{
+			nano::inactive_node node (data_path);
+			auto transaction (node.node->store.tx_begin ());
+
+			uint64_t sum = 0;
+			for (auto i (node.node->store.latest_begin (transaction)), n (node.node->store.latest_end ()); i != n; ++i)
+			{
+				nano::account_info info (i->second);
+				sum += info.confirmation_height;
+			}
+			std::cout << "Total cemented block count: " << sum << std::endl;
+		}
 		else if (vm.count ("version"))
 		{
 			if (NANO_VERSION_PATCH == 0)

nano/node/CMakeLists.txt

@@ -12,6 +12,9 @@ endif ()
 
 add_library (node
 	${platform_sources}
+	active_transactions.hpp
+	active_transactions.cpp
+	blockprocessor.cpp
 	blockprocessor.hpp
 	blockprocessor.cpp
 	bootstrap.hpp
@@ -20,8 +23,10 @@ add_library (node
 	cli.cpp
 	common.hpp
 	common.cpp
-	daemonconfig.cpp
+	confirmation_height_processor.hpp
+	confirmation_height_processor.cpp
 	daemonconfig.hpp
+	daemonconfig.cpp
 	ipc.hpp
 	ipc.cpp
 	ipcconfig.hpp