From 97dadd8bf09f202c4be5cc3cabf6fcce9cb09662 Mon Sep 17 00:00:00 2001 From: parazyd Date: Thu, 21 Apr 2022 15:43:49 +0200 Subject: [PATCH] consensus: Move proposal task into consensus/task. --- src/consensus2/task/mod.rs | 3 +++ .../src/consensus.rs => src/consensus2/task/proposal.rs | 7 ++++--- 2 files changed, 7 insertions(+), 3 deletions(-) rename bin/darkfid2/src/consensus.rs => src/consensus2/task/proposal.rs (95%) diff --git a/src/consensus2/task/mod.rs b/src/consensus2/task/mod.rs index a5061f718..a33bd6013 100644 --- a/src/consensus2/task/mod.rs +++ b/src/consensus2/task/mod.rs @@ -3,3 +3,6 @@ pub use block_sync::block_sync_task; mod fork_sync; pub use fork_sync::fork_sync_task; + +mod proposal; +pub use proposal::proposal_task; diff --git a/bin/darkfid2/src/consensus.rs b/src/consensus2/task/proposal.rs similarity index 95% rename from bin/darkfid2/src/consensus.rs rename to src/consensus2/task/proposal.rs index f353a08fd..d99cad6ad 100644 --- a/bin/darkfid2/src/consensus.rs +++ b/src/consensus2/task/proposal.rs @@ -1,12 +1,13 @@ use log::{debug, error, info}; -use darkfi::{ +use crate::{ consensus2::{state::ValidatorStatePtr, Participant}, - net::P2pPtr, + net, util::async_util::sleep, }; -pub async fn proposal_task(p2p: P2pPtr, state: ValidatorStatePtr) { +/// async task used for participating in the consensus protocol +pub async fn proposal_task(p2p: net::P2pPtr, state: ValidatorStatePtr) { // Node signals the network that it starts participating let participant = Participant::new(state.read().await.id, state.read().await.current_epoch()); state.write().await.append_participant(participant.clone());