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

Add timeout for aggregator

Browse Source
This commit is contained in:
Tan Chee Keong
2025-03-10 17:22:08 +08:00
parent 0d724b18a0
commit d6c7461351
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
common/eth2/src/lib.rs
View File

@@ -144,6 +144,7 @@ pub struct Timeouts {
pub get_debug_beacon_states: Duration, pub get_debug_beacon_states: Duration,
pub get_deposit_snapshot: Duration, pub get_deposit_snapshot: Duration,
pub get_validator_block: Duration, pub get_validator_block: Duration,
pub aggregator_duties: Duration,
} }
impl Timeouts { impl Timeouts {
@@ -161,6 +162,7 @@ impl Timeouts {
get_debug_beacon_states: timeout, get_debug_beacon_states: timeout,
get_deposit_snapshot: timeout, get_deposit_snapshot: timeout,
get_validator_block: timeout, get_validator_block: timeout,
aggregator_duties: timeout,
} }
} }
} }
@@ -2677,7 +2679,7 @@ impl BeaconNodeHttpClient {
.push("validator") .push("validator")
.push("beacon_committee_selections"); .push("beacon_committee_selections");
self.post_with_timeout_and_response(path, &selections, self.timeouts.attester_duties) self.post_with_timeout_and_response(path, &selections, self.timeouts.aggregator_duties)
.await .await
} }
} }

2
validator_client/src/lib.rs
View File

@@ -69,6 +69,7 @@ const HTTP_GET_BEACON_BLOCK_SSZ_TIMEOUT_QUOTIENT: u32 = 4;
const HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT: u32 = 4; const HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT: u32 = 4;
const HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT: u32 = 4; const HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT: u32 = 4;
const HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT: u32 = 4; const HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT: u32 = 4;
const HTTP_AGGREGATOR_DUTIES_TIMEOUT_QUOTIENT: u32 = 1;
const DOPPELGANGER_SERVICE_NAME: &str = "doppelganger"; const DOPPELGANGER_SERVICE_NAME: &str = "doppelganger";
@@ -323,6 +324,7 @@ impl<E: EthSpec> ProductionValidatorClient<E> {
get_debug_beacon_states: slot_duration / HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT, get_debug_beacon_states: slot_duration / HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT,
get_deposit_snapshot: slot_duration / HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT, get_deposit_snapshot: slot_duration / HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT,
get_validator_block: slot_duration / HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT, get_validator_block: slot_duration / HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT,
aggregator_duties: slot_duration / HTTP_AGGREGATOR_DUTIES_TIMEOUT_QUOTIENT,
} }
} else { } else {
Timeouts::set_all(slot_duration) Timeouts::set_all(slot_duration)