Skip to content

Commit

Permalink
[review] address review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
akichidis committed Dec 15, 2023
1 parent 2b4edcc commit e8b8c07
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions mysticeti-core/src/simulated_network.rs
Original file line number Diff line number Diff line change
Expand Up @@ -55,6 +55,7 @@ impl SimulatedNetwork {
pub async fn connect(&self, a: usize, b: usize) {
let (a_sender, a_receiver) = Self::latency_channel();
let (b_sender, b_receiver) = Self::latency_channel();
// the watch channels are responsible for disseminating the calculated latency for each connection.
let (_al_sender, al_receiver) = tokio::sync::watch::channel(Duration::from_secs(0));
let (_bl_sender, bl_receiver) = tokio::sync::watch::channel(Duration::from_secs(0));
let a_connection = Connection {
Expand Down

0 comments on commit e8b8c07

Please sign in to comment.