validator_worker - leader - call heartbeat()

elpiel · elpiel · commit ae89b0176df5 · 2019-09-16T17:01:35.000+03:00
diff --git a/validator_worker/src/leader.rs b/validator_worker/src/leader.rs
@@ -4,6 +4,7 @@ use primitives::adapter::Adapter;
 use primitives::validator::{Accounting, MessageTypes, NewState};
 use primitives::BalancesMap;
 
+use crate::heartbeat::heartbeat;
 use crate::sentry_interface::SentryApi;
 use crate::{get_state_root_hash, producer};
 
@@ -14,7 +15,8 @@ pub async fn tick<A: Adapter + 'static>(iface: &SentryApi<A>) -> Result<(), Box<
         on_new_accounting(&iface, (&balances, &new_accounting))?;
     }
 
-    Ok(())
+    // TODO: Pass the heartbeat time from the Configuration
+    await!(heartbeat(&iface, balances, 250)).map(|_| ())
 }
 
 fn on_new_accounting<A: Adapter + 'static>(

Original file line number	Diff line number	Diff line change
`@@ -4,6 +4,7 @@ use primitives::adapter::Adapter;`
`4`	`4`	`use primitives::validator::{Accounting, MessageTypes, NewState};`
`5`	`5`	`use primitives::BalancesMap;`
`6`	`6`
	`7`	`+use crate::heartbeat::heartbeat;`
`7`	`8`	`use crate::sentry_interface::SentryApi;`
`8`	`9`	`use crate::{get_state_root_hash, producer};`
`9`	`10`
`@@ -14,7 +15,8 @@ pub async fn tick<A: Adapter + 'static>(iface: &SentryApi<A>) -> Result<(), Box<`
`14`	`15`	`on_new_accounting(&iface, (&balances, &new_accounting))?;`
`15`	`16`	`}`
`16`	`17`
`17`		`- Ok(())`
	`18`	`+ // TODO: Pass the heartbeat time from the Configuration`
	`19`	`+ await!(heartbeat(&iface, balances, 250)).map(\|_\| ())`
`18`	`20`	`}`
`19`	`21`
`20`	`22`	`fn on_new_accounting<A: Adapter + 'static>(`