consensus wip

Cargo.toml

@@ -30,6 +30,7 @@ tokio = { version = "1.39.2", features = [
 tracing = "0.1.40"
 git-version = "0.3.9"
 target_info = "0.1.0"
+tracing-subscriber = "0.3.18"
 
 [profile.maxperf]
 inherits = "release"

anchor/Cargo.toml

@@ -11,12 +11,12 @@ sensitive_url = { workspace = true }
 async-channel = { workspace = true }
 clap = { workspace = true }
 dirs = { workspace = true }
-ethereum_hashing =  { workspace = true }
-futures =  { workspace = true }
-serde =  { workspace = true }
-tokio =  { workspace = true }
-tracing =  { workspace = true }
-git-version =  { workspace = true }
+ethereum_hashing = { workspace = true }
+futures = { workspace = true }
+serde = { workspace = true }
+tokio = { workspace = true }
+tracing = { workspace = true }
+git-version = { workspace = true }
 target_info = { workspace = true }
 client = { workspace = true }
 

anchor/qbft/Cargo.toml

@@ -9,6 +9,7 @@ name = "qbft"
 path = "src/lib.rs"
 
 [dependencies]
-tokio = { workspace = true }
+tokio = { workspace = true, features = ["sync"] }
 tracing = { workspace = true }
 futures = { workspace = true }
+tracing-subscriber = { workspace = true }

anchor/qbft/src/config.rs

@@ -14,6 +14,7 @@ where
     pub instance_height: usize,
     pub round: usize,
     pub committee_size: usize,
+    pub committee_members: Vec<usize>,
     pub quorum_size: usize,
     pub round_time: Duration,
     pub leader_fn: F,
@@ -46,6 +47,10 @@ impl<F: Clone + LeaderFunction> Config<F> {
         self.committee_size
     }
 
+    pub fn commmittee_members(&self) -> Vec<usize> {
+        self.committee_members.clone()
+    }
+
     /// The quorum size required for the committee to reach consensus
     pub fn quorum_size(&self) -> usize {
         self.quorum_size
@@ -91,6 +96,7 @@ impl Default for ConfigBuilder<DefaultLeaderFunction> {
                 instance_id: 0,
                 instance_height: 0,
                 committee_size: 5,
+                committee_members: vec![0, 1, 2, 3, 4],
                 quorum_size: 4,
                 round: 0,
                 round_time: Duration::new(2, 0),