gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-05-30 20:57:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add gossip verified il test coverage

Browse Source
This commit is contained in:
Eitan Seri-Levi
2025-02-10 00:36:54 +02:00
parent 51984ab54d
commit 30136ad571
3 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
validator_client/validator_services/src/inclusion_list_service.rs
View File

@@ -77,7 +77,7 @@ impl<T: SlotClock + 'static, E: EthSpec> InclusionListService<T, E> {
);
let executor = self.context.executor.clone();
let chain_spec = spec.clone();
let interval_fut = async move {
loop {
if let Some(duration_to_next_slot) = self.slot_clock.duration_to_next_slot() {
@@ -85,7 +85,7 @@ impl<T: SlotClock + 'static, E: EthSpec> InclusionListService<T, E> {
sleep(duration_to_next_slot + (slot_duration * 3 / 4)).await;
let log = self.context.log();
if let Err(e) = self.spawn_inclusion_list_task(slot_duration) {
if let Err(e) = self.spawn_inclusion_list_task(slot_duration, &chain_spec) {
crit!(
log,
"Failed to spawn inclusion list task";
@@ -113,9 +113,13 @@ impl<T: SlotClock + 'static, E: EthSpec> InclusionListService<T, E> {
/// Spawn a new task that downloads, signs and uploads the inclusion lists to the beacon node.
// TODO(focil) I don't think we need `slot_duration` here, unless we need to make some calculation
// related to the freeze deadline.
fn spawn_inclusion_list_task(&self, _slot_duration: Duration) -> Result<(), String> {
fn spawn_inclusion_list_task(&self, _slot_duration: Duration, spec: &ChainSpec) -> Result<(), String> {
let slot = self.slot_clock.now().ok_or("Failed to read slot clock")?;
if !spec.is_focil_enabled_for_epoch(slot.epoch(E::slots_per_epoch())) {
return Ok(())
}
// TODO(focil) unused variable
let _duration_to_next_slot = self
.slot_clock