Implement reorg lock in node and pass thru chaser base.

Author: evoskuil

include/bitcoin/node/chasers/chaser.hpp

@@ -93,6 +93,9 @@ class BCN_API chaser
     /// Reset store disk full condition.
     virtual code reload(const store::event_handler& handler) NOEXCEPT;
 
+    /// Get reorganization lock.
+    virtual lock get_reorganization_lock() NOEXCEPT;
+
     /// Events.
     /// -----------------------------------------------------------------------
 

include/bitcoin/node/define.hpp

@@ -22,6 +22,7 @@
 /// Standard includes (do not include directly).
 #include <functional>
 #include <memory>
+#include <mutex>
 #include <utility>
 #include <variant>
 
@@ -57,6 +58,7 @@ typedef std::error_code code;
 typedef std::function<void(const code&, size_t)> organize_handler;
 typedef database::store<database::map> store;
 typedef database::query<store> query;
+typedef std::unique_lock<std::mutex> lock;
 
 /// Work types.
 typedef network::race_all<const code&> job;

include/bitcoin/node/full_node.hpp

@@ -139,6 +139,10 @@ class BCN_API full_node
     /// Get the memory resource.
     virtual network::memory& get_memory() NOEXCEPT;
 
+    /// Get reorganization lock.
+    /// Used to prevent candidate chain reorganization during confirmation.
+    virtual lock get_reorganization_lock() NOEXCEPT;
+
 protected:
     /// Session attachments.
     /// -----------------------------------------------------------------------
@@ -161,6 +165,7 @@ class BCN_API full_node
 
     // These are thread safe.
     const configuration& config_;
+    std::mutex reorganization_mutex_{};
     memory_controller memory_;
     query& query_;
 

src/chasers/chaser.cpp

@@ -83,6 +83,11 @@ code chaser::reload(const store::event_handler& handler) NOEXCEPT
     return node_.reload(handler);
 }
 
+lock chaser::get_reorganization_lock() NOEXCEPT
+{
+    return node_.get_reorganization_lock();
+}
+
 // Events.
 // ----------------------------------------------------------------------------
 

src/full_node.cpp

@@ -370,6 +370,11 @@ network::memory& full_node::get_memory() NOEXCEPT
     return memory_;
 }
 
+lock full_node::get_reorganization_lock() NOEXCEPT
+{
+    return lock{ reorganization_mutex_ };
+}
+
 // Session attachments.
 // ----------------------------------------------------------------------------