Release 0.9.4

CHANGELOG.md

@@ -1,3 +1,8 @@
+## Diamond Node Software 3.3.5-hbbft-0.9.4
+
+- [Fixed: is major syncing information is wrong.] (https://github.com/DMDcoin/diamond-node/issues/73)
+- [Improvements for HBBFT Message Tracking] (https://github.com/DMDcoin/openethereum-3.x/issues/17)
+
 ## Diamond Node Software 3.3.5-hbbft-0.9.3
 
 [Autoshutdown after a period without block import] https://github.com/DMDcoin/diamond-node/issues/78

Cargo.toml

@@ -2,7 +2,7 @@
 description = "Diamond Node"
 name = "diamond-node"
 # NOTE Make sure to update util/version/Cargo.toml as well
-version = "3.3.5-hbbft-0.9.3"
+version = "3.3.5-hbbft-0.9.4"
 license = "GPL-3.0"
 authors = [
 	"bit.diamonds developers",

bin/oe/run.rs

@@ -59,6 +59,7 @@ use node_filter::NodeFilter;
 use parity_rpc::{informant, is_major_importing, NetworkSettings};
 use parity_runtime::Runtime;
 use parity_version::version;
+use sync::SyncState;
 
 // How often we attempt to take a snapshot: only snapshot on blocknumbers that are multiples of this.
 const SNAPSHOT_PERIOD: u64 = 20000;
@@ -160,6 +161,17 @@ impl ChainSyncing for SyncProviderWrapper {
             None => true,
         }
     }
+
+    /// are we syncing in any means ?
+    fn is_syncing(&self) -> bool {
+        match self.sync_provider.upgrade() {
+            Some(sync_arc) => {
+                return sync_arc.status().state != SyncState::Idle;
+            }
+            // We also indicate the "syncing" state when the SyncProvider has already been destroyed.
+            None => true,
+        }
+    }
 }
 
 /// Executes the given run command.

crates/ethcore/src/client/client.rs

@@ -2886,6 +2886,16 @@ impl BlockChainClient for Client {
         }
     }
 
+    fn is_syncing(&self) -> bool {
+        // so far we know, this lock cannot result into a deadlock.
+        match &*self.sync_provider.lock() {
+            Some(sync_provider) => sync_provider.is_syncing(),
+            // We also indicate the "syncing" state when the SyncProvider has not been set,
+            // which usually only happens when the client is not fully configured yet.
+            None => true,
+        }
+    }
+
     fn next_nonce(&self, address: &Address) -> U256 {
         self.importer.miner.next_nonce(self, address)
     }
@@ -3652,9 +3662,14 @@ impl PrometheusMetrics for Client {
             chain.best_block_number as i64,
         );
 
-        let is_syncing_val: i64 = self.is_major_syncing() as i64;
-        // 0 or 1 if we are syncing.
-        r.register_gauge("is_major_syncing", "syncing, boolean", is_syncing_val);
+        // 0 or 1 if we are major syncing.
+        r.register_gauge(
+            "is_major_syncing",
+            "syncing, boolean",
+            self.is_major_syncing() as i64,
+        );
+
+        r.register_gauge("is_syncing", "syncing, boolean", self.is_syncing() as i64);
 
         // prunning info
         let prunning = self.pruning_info();

crates/ethcore/src/client/test_client.rs

@@ -422,7 +422,7 @@
         self.disabled.load(AtomicOrder::SeqCst)
     }
 
     pub fn set_new_transaction_hashes_producer(
         &self,
         new_transaction_hashes: crossbeam_channel::Sender<H256>,
     ) {
@@ -1114,6 +1114,10 @@
         false
     }
 
+    fn is_syncing(&self) -> bool {
+        false
+    }
+
     fn next_nonce(&self, address: &Address) -> U256 {
         self.miner.next_nonce(self, address)
     }

crates/ethcore/src/client/traits.rs

@@ -215,6 +215,9 @@ pub trait EngineInfo {
 
 /// Provides information about the chain sync state.
 pub trait ChainSyncing: Send + Sync {
+    /// are we syncing?
+    fn is_syncing(&self) -> bool;
+
     /// are we in the middle of a major sync?
     fn is_major_syncing(&self) -> bool;
 }
@@ -524,9 +527,12 @@ pub trait BlockChainClient:
     /// Used by engines to queue transactions without causing deadlocks due to re-entrant calls.
     fn transact_silently(&self, tx_request: TransactionRequest) -> Result<(), transaction::Error>;
 
-    /// Returns true if the chain is currently syncing.
+    /// Returns true if the chain is currently syncing in major states.
     fn is_major_syncing(&self) -> bool;
 
+    /// Returns true if the chain is currently syncing.
+    fn is_syncing(&self) -> bool;
+
     /// Returns the next nonce for the given address, taking the transaction queue into account.
     fn next_nonce(&self, address: &Address) -> U256;
 

crates/ethcore/src/engines/hbbft/hbbft_engine.rs

@@ -374,9 +374,7 @@ impl IoHandler<()> for TransitionHandler {
                                     }
 
                                     let id: usize = std::process::id() as usize;
-
                                     let thread_id = std::thread::current().id();
-
                                     info!(target: "engine", "Waiting for Signaling shutdown to process ID: {id} thread: {:?}", thread_id);
 
                                     if let Some(ref weak) = *self.client.read() {
@@ -1153,7 +1151,7 @@ impl HoneyBadgerBFT {
 
     fn is_syncing(&self, client: &Arc<dyn EngineClient>) -> bool {
         match client.as_full_client() {
-            Some(full_client) => full_client.is_major_syncing(),
+            Some(full_client) => full_client.is_syncing(),
             // We only support full clients at this point.
             None => true,
         }