Hotstuff

README.md

@@ -4,10 +4,10 @@ This project provides a fast & deterministic simulation framework for testing an
 
 ## Usage
 
-To use the DScale, you need to implement the `ProcessHandle` trait for your distributed system and the `Message` trait for the data exchanged between processes.
-
 ### 1. Install
 
+In your project
+
 ```shell
 cargo add dscale
 ```
@@ -30,6 +30,9 @@ impl Message for MyMessage {
         1000
     }
 }
+
+// Or (if there is no need in bandwidth)
+impl Message for MyMessage {}
 ```
 
 ### 3. Implement Process Logic
@@ -59,7 +62,7 @@ impl ProcessHandle for MyProcess {
 
     fn on_timer(&mut self, _id: TimerId) {
         // Handle timeouts
-        broadcasst(MyMessage { data: 42 });
+        broadcast(MyMessage { data: 42 });
     }
 }
 ```

systems/hotstuff/Cargo.toml

@@ -0,0 +1,9 @@
+[package]
+name = "hotstuff"
+version = "0.1.0"
+edition = "2024"
+
+[dependencies]
+log = "0.4.29"
+dscale = {path = "../../dscale"}
+rand = "0.9.2"

systems/hotstuff/src/bin/hotstuff.rs

@@ -0,0 +1,33 @@
+use std::rc::Rc;
+
+use dscale::{Distributions, Jiffies, LatencyDescription, SimulationBuilder, global::anykv};
+use hotstuff::{B0, ChainedHotstuff, HOTSTUFF_POOL, Node};
+
+fn main() {
+    let genesis = Rc::new(Node {
+        id: 0,
+        parent: None,
+        height: 0,
+        creator: 0,
+        creation_time: Jiffies(0),
+    });
+
+    anykv::set::<Rc<Node>>(B0, genesis);
+    anykv::set::<(f64, usize)>("avg_latency", (0.0, 0));
+
+    let mut sim = SimulationBuilder::default()
+        .add_pool::<ChainedHotstuff>(HOTSTUFF_POOL, 53)
+        .latency_topology(&[LatencyDescription::WithinPool(
+            HOTSTUFF_POOL,
+            Distributions::Normal(Jiffies(50), Jiffies(10)),
+        )])
+        .seed(123)
+        .time_budget(Jiffies(3600_000))
+        .build();
+
+    sim.run();
+
+    let ordered = anykv::get::<(f64, usize)>("avg_latency").1;
+    let avg_latency = anykv::get::<(f64, usize)>("avg_latency").0;
+    println!("ordered: {ordered}, avg_latency: {avg_latency}")
+}