Merge pull request #890 from evoskuil/master

Refactor settings for uniform treatment of services.

Author: evoskuil

console/executor_runner.cpp

@@ -139,7 +139,7 @@ bool executor::do_run()
     logger(BN_NODE_INTERRUPT);
 
     // Create node.
-    metadata_.configured.network.initialize();
+    metadata_.configured.network.manual.initialize();
     node_ = std::make_shared<full_node>(query_, metadata_.configured, log_);
 
     // Subscribe node.

include/bitcoin/node/channels/channel.hpp

@@ -36,8 +36,8 @@ class BCN_API channel
     DELETE_COPY_MOVE_DESTRUCT(channel);
 
 protected:
-    channel(const network::logger&, const network::socket::ptr&,
-        const node::configuration&, uint64_t=zero) NOEXCEPT
+    channel(const network::logger&, const network::socket::ptr&, uint64_t,
+        const node::configuration&) NOEXCEPT
     {
     }
 };

include/bitcoin/node/channels/channel_http.hpp

@@ -34,13 +34,12 @@ class BCN_API channel_http
 {
 public:
     typedef std::shared_ptr<node::channel_http> ptr;
-    using options_t = network::channel_http::options_t;
 
-    channel_http(const network::logger& log, const network::socket::ptr& socket,
-        const node::configuration& config, uint64_t identifier=zero,
-        const options_t& options={}) NOEXCEPT
-      : network::channel_http(log, socket, config.network, identifier, options),
-        node::channel(log, socket, config, identifier)
+    channel_http(const network::logger& log,
+        const network::socket::ptr& socket, uint64_t identifier,
+        const node::configuration& config, const options_t& options) NOEXCEPT
+      : network::channel_http(log, socket, identifier, config.network, options),
+        node::channel(log, socket, identifier, config)
     {
     }
 };

include/bitcoin/node/channels/channel_peer.hpp

@@ -35,11 +35,12 @@ class BCN_API channel_peer
 public:
     typedef std::shared_ptr<node::channel_peer> ptr;
 
-    channel_peer(network::memory& memory, const network::logger& log,
-        const network::socket::ptr& socket, const node::configuration& config,
-        uint64_t identifier=zero) NOEXCEPT
-      : network::channel_peer(memory, log, socket, config.network, identifier),
-        node::channel(log, socket, config, identifier),
+    channel_peer(network::memory& allocator, const network::logger& log,
+        const network::socket::ptr& socket, uint64_t identifier,
+        const node::configuration& config, const options_t& options) NOEXCEPT
+      : network::channel_peer(allocator, log, socket, identifier,
+          config.network, options),
+        node::channel(log, socket, identifier, config),
         announced_(config.node.announcement_cache)
     {
     }

include/bitcoin/node/channels/channel_tcp.hpp

@@ -34,13 +34,12 @@ class BCN_API channel_tcp
 {
 public:
     typedef std::shared_ptr<node::channel_tcp> ptr;
-    using options_t = network::channel_tcp::options_t;
 
     channel_tcp(const network::logger& log, const network::socket::ptr& socket,
-        const node::configuration& config, uint64_t identifier=zero,
-        const options_t& options={}) NOEXCEPT
-      : network::channel_tcp(log, socket, config.network, identifier, options),
-        node::channel(log, socket, config, identifier)
+        uint64_t identifier, const node::configuration& config,
+        const options_t& options) NOEXCEPT
+      : network::channel_tcp(log, socket, identifier, config.network, options),
+        node::channel(log, socket, identifier, config)
     {
     }
 };

include/bitcoin/node/channels/channel_ws.hpp

@@ -35,15 +35,12 @@ class BCN_API channel_ws
 {
 public:
     typedef std::shared_ptr<node::channel_ws> ptr;
-    using options_t = network::channel_ws::options_t;
 
-    channel_ws(const network::logger& log,
-        const network::socket::ptr& socket,
-        const node::configuration& config, uint64_t identifier=zero,
-        const options_t& options={}) NOEXCEPT
-      : network::channel_ws(log, socket, config.network, identifier,
-          options),
-        node::channel(log, socket, config, identifier)
+    channel_ws(const network::logger& log, const network::socket::ptr& socket,
+        uint64_t identifier, const node::configuration& config,
+        const options_t& options) NOEXCEPT
+      : network::channel_ws(log, socket, identifier, config.network, options),
+        node::channel(log, socket, identifier, config)
     {
     }
 };

include/bitcoin/node/chase.hpp

@@ -61,11 +61,11 @@ enum class chase
     /// Issued by 'session_outbound' and handled by 'block_in_31800'.
     split,
 
-    /// Channels (all with work) directed to split work and stop (channel_t).
+    /// Channels (all with work) directed to split work and stop (peer_t).
     /// Issued by 'session_outbound' and handled by 'block_in_31800'.
     stall,
 
-    /// Channels (all with work) directed to drop work and stop (channel_t).
+    /// Channels (all with work) directed to drop work and stop (peer_t).
     /// Issued by 'check' and handled by 'block_in_31800'.
     purge,
 

include/bitcoin/node/define.hpp

@@ -70,7 +70,7 @@ using object_key = uint64_t;
 /// Event value types.
 using count_t = size_t;
 using height_t = size_t;
-using channel_t = uint64_t;
+using peer_t = uint64_t;
 using object_t = object_key;
 using header_t = database::header_link::integer;
 using transaction_t = database::tx_link::integer;

include/bitcoin/node/protocols/protocol_block_in_31800.hpp

@@ -65,8 +65,8 @@ class BCN_API protocol_block_in_31800
 
     /// Manage work splitting.
     bool is_idle() const NOEXCEPT override;
-    virtual void do_purge(channel_t) NOEXCEPT;
-    virtual void do_split(channel_t) NOEXCEPT;
+    virtual void do_purge(peer_t) NOEXCEPT;
+    virtual void do_split(peer_t) NOEXCEPT;
     virtual void do_report(count_t count) NOEXCEPT;
 
     /// Check incoming block message.

include/bitcoin/node/protocols/protocol_block_out_70012.hpp

@@ -50,8 +50,8 @@ class BCN_API protocol_block_out_70012
         const network::messages::peer::send_headers::cptr& message) NOEXCEPT;
 
 private:
-    // This is protected by strand.
-    bool superseded_{};
+    // This is thread safe.
+    std::atomic_bool superseded_{};
 };
 
 } // namespace node