gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-04-28 02:03:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix bug with validator services exiting on error

Browse Source
This commit is contained in:
Paul Hauner
2019-11-25 18:19:41 +11:00
parent ae535ea33a
commit ebfa1f53d6
4 changed files with 4 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
validator_client/src/attestation_service.rs
View File

@@ -165,9 +165,7 @@ impl<T: SlotClock + 'static, E: EthSpec> AttestationService<T, E> {
} }
Ok(()) Ok(())
}) }),
// Prevent any errors from escaping and stopping the interval.
.then(|_| Ok(())),
) )
.map(move |_| info!(log_3, "Shutdown complete")), .map(move |_| info!(log_3, "Shutdown complete")),
); );

4
validator_client/src/block_service.rs
View File

@@ -146,9 +146,7 @@ impl<T: SlotClock + 'static, E: EthSpec> BlockService<T, E> {
"error" => format!("{}", e) "error" => format!("{}", e)
} }
}) })
.for_each(move |_| service.clone().do_update()) .for_each(move |_| service.clone().do_update().then(|_| Ok(()))),
// Prevent any errors from escaping and stopping the interval.
.then(|_| Ok(())),
) )
.map(move |_| info!(log_2, "Shutdown complete")), .map(move |_| info!(log_2, "Shutdown complete")),
); );

4
validator_client/src/duties_service.rs
View File

@@ -268,9 +268,7 @@ impl<T: SlotClock + 'static, E: EthSpec> DutiesService<T, E> {
"error" => format!("{}", e) "error" => format!("{}", e)
} }
}) })
.for_each(move |_| service.clone().do_update()) .for_each(move |_| service.clone().do_update().then(|_| Ok(()))),
// Prevent any errors from escaping and stopping the interval.
.then(|_| Ok(())),
) )
.map(move |_| info!(log_2, "Shutdown complete")), .map(move |_| info!(log_2, "Shutdown complete")),
); );

4
validator_client/src/fork_service.rs
View File

@@ -136,9 +136,7 @@ impl<T: SlotClock + 'static, E: EthSpec> ForkService<T, E> {
"error" => format!("{}", e) "error" => format!("{}", e)
} }
}) })
.for_each(move |_| service.do_update()) .for_each(move |_| service.do_update().then(|_| Ok(()))),
// Prevent any errors from escaping and stopping the interval.
.then(|_| Ok(())),
) )
.map(move |_| info!(log_2, "Shutdown complete")), .map(move |_| info!(log_2, "Shutdown complete")),
); );