GRIN/nym
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

validator: simplified task spawning

Browse Source
This commit is contained in:
Dave Hrycyszyn
2020-01-30 11:32:06 +00:00
parent c4c004cd9c
commit d75ac203d2
2 changed files with 22 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
validator/src/network/tendermint.rs
+2 -2
View File
@@ -21,8 +21,8 @@ impl Abci {
Abci { count: 0 }
}
pub fn run(self) {
tokio::spawn(async { abci::run_local(self) })
pub async fn run(self) {
abci::run_local(self);
}
}
validator/src/services/mixmining/health_check_runner.rs
+20 -22
View File
@@ -24,27 +24,25 @@ impl<T: MixnetIdentityKeyPair + Send + Sync + 'static> HealthCheckRunner<T> {
}
pub async fn run(self) {
tokio::spawn(async move {
let healthcheck_interval = Duration::from_secs_f64(self.interval);
debug!("healthcheck will run every {:?}", healthcheck_interval);
loop {
let full_topology =
directory_client::presence::Topology::new(self.directory_server.clone());
let version_filtered_topology = full_topology.filter_node_versions(
crate::built_info::PKG_VERSION,
crate::built_info::PKG_VERSION,
crate::built_info::PKG_VERSION,
);
match self
.health_checker
.do_check(&version_filtered_topology)
.await
{
Ok(health) => info!("current network health: \n{}", health),
Err(err) => error!("failed to perform healthcheck - {:?}", err),
};
tokio::time::delay_for(healthcheck_interval).await;
}
});
let healthcheck_interval = Duration::from_secs_f64(self.interval);
debug!("healthcheck will run every {:?}", healthcheck_interval);
loop {
let full_topology =
directory_client::presence::Topology::new(self.directory_server.clone());
let version_filtered_topology = full_topology.filter_node_versions(
crate::built_info::PKG_VERSION,
crate::built_info::PKG_VERSION,
crate::built_info::PKG_VERSION,
);
match self
.health_checker
.do_check(&version_filtered_topology)
.await
{
Ok(health) => info!("current network health: \n{}", health),
Err(err) => error!("failed to perform healthcheck - {:?}", err),
};
tokio::time::delay_for(healthcheck_interval).await;
}
}
}