Skip to content

Commit

Permalink
Cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
romac committed Feb 21, 2024
1 parent 7c284aa commit 0099fd6
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 6 deletions.
4 changes: 3 additions & 1 deletion code/driver/src/input.rs
Original file line number Diff line number Diff line change
@@ -1,9 +1,11 @@
use malachite_common::{Context, Round, Timeout};

use derive_where::derive_where;

use crate::Validity;

/// Events that can be received by the [`Driver`](crate::Driver).
#[derive(Clone, Debug, PartialEq, Eq)]
#[derive_where(Clone, Debug, PartialEq, Eq)]
pub enum Input<Ctx>
where
Ctx: Context,
Expand Down
6 changes: 1 addition & 5 deletions code/node/src/node.rs
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,6 @@ where
loop {
tokio::select! {
Some(input) = rx_input.recv() =>{
dbg!(&input);
match &input {
Input::NewRound(_, _) => {
self.timers.reset().await;
Expand Down Expand Up @@ -199,11 +198,8 @@ where
None
}

Output::GetValue(height, round, timeout) => {
Output::GetValue(height, round, _timeout) => {
info!("Requesting value at height {height} and round {round}");
info!("Scheduling {timeout}");

self.timers.schedule_timeout(timeout).await;

let value = self.get_value().await;
Some(Input::ProposeValue(round, value))
Expand Down

0 comments on commit 0099fd6

Please sign in to comment.