WIP

nano/lib/stats_enums.hpp

@@ -34,6 +34,7 @@ enum class type : uint8_t
 	telemetry,
 	vote_generator,
 	vote_cache,
+	vote_broadcaster,
 	hinting,
 	blockprocessor,
 	blockprocessor_source,

nano/lib/thread_roles.cpp

@@ -22,6 +22,9 @@ std::string nano::thread_role::get_string (nano::thread_role::name role)
 		case nano::thread_role::name::vote_processing:
 			thread_role_name_string = "Vote processing";
 			break;
+		case nano::thread_role::name::vote_broadcasting:
+			thread_role_name_string = "Vote broadcast";
+			break;
 		case nano::thread_role::name::block_processing:
 			thread_role_name_string = "Blck processing";
 			break;

nano/lib/thread_roles.hpp

@@ -14,6 +14,7 @@ enum class name
 	work,
 	packet_processing,
 	vote_processing,
+	vote_broadcasting,
 	block_processing,
 	request_loop,
 	wallet_actions,

nano/node/CMakeLists.txt

@@ -164,6 +164,8 @@ add_library(
   transport/transport.cpp
   unchecked_map.cpp
   unchecked_map.hpp
+  vote_processor.hpp
+  vote_processor.cpp
   vote_cache.hpp
   vote_cache.cpp
   vote_processor.hpp

nano/node/vote_broadcaster.cpp

@@ -0,0 +1,2 @@
+#include <nano/node/vote_broadcaster.hpp>
+

nano/node/vote_broadcaster.hpp

@@ -0,0 +1,61 @@
+#pragma once
+
+#include <nano/lib/locks.hpp>
+#include <nano/lib/numbers.hpp>
+#include <nano/node/rep_tiers.hpp>
+#include <nano/secure/common.hpp>
+
+#include <atomic>
+#include <chrono>
+#include <condition_variable>
+#include <thread>
+
+namespace nano
+{
+class node;
+class stats;
+}
+
+namespace nano
+{
+class vote_broadcaster_config final
+{
+public:
+	size_t max_recently_broadcasted{ 1024 * 32 };
+};
+
+class vote_broadcaster final
+{
+public:
+	explicit vote_broadcaster (nano::node &);
+	~vote_broadcaster ();
+
+	void start ();
+	void stop ();
+
+	bool rebroadcast (std::shared_ptr<nano::vote> const & vote, nano::rep_tier tier);
+	bool local (std::shared_ptr<nano::vote> const & vote);
+
+private: // Dependencies
+	nano::vote_broadcaster_config const & config;
+	nano::node & node;
+	nano::stats & stats;
+
+private:
+	void run ();
+
+private:
+	class recently_broadcasted_entry
+	{
+		std::map<nano::account, uint64_t> representatives; // <representative account, vote timestamp>
+	};
+
+	std::unordered_map<nano::block_hash, recently_broadcasted_entry> recently_broadcasted;
+
+private:
+	std::atomic<bool> stopped{ false };
+	nano::condition_variable condition;
+	mutable nano::mutex mutex;
+	std::thread thread;
+};
+}