diff --git a/common/eth2/src/lib.rs b/common/eth2/src/lib.rs index 065fedf1b8..19099510c9 100644 --- a/common/eth2/src/lib.rs +++ b/common/eth2/src/lib.rs @@ -135,6 +135,7 @@ pub struct Timeouts { pub attestation: Duration, pub attester_duties: Duration, pub attestation_subscriptions: Duration, + pub attestation_aggregators: Duration, pub liveness: Duration, pub proposal: Duration, pub proposer_duties: Duration, @@ -144,7 +145,6 @@ pub struct Timeouts { pub get_debug_beacon_states: Duration, pub get_deposit_snapshot: Duration, pub get_validator_block: Duration, - pub aggregator_duties: Duration, } impl Timeouts { @@ -153,6 +153,7 @@ impl Timeouts { attestation: timeout, attester_duties: timeout, attestation_subscriptions: timeout, + attestation_aggregators: timeout, liveness: timeout, proposal: timeout, proposer_duties: timeout, @@ -162,7 +163,6 @@ impl Timeouts { get_debug_beacon_states: timeout, get_deposit_snapshot: timeout, get_validator_block: timeout, - aggregator_duties: timeout, } } } @@ -2679,8 +2679,12 @@ impl BeaconNodeHttpClient { .push("validator") .push("beacon_committee_selections"); - self.post_with_timeout_and_response(path, &selections, self.timeouts.aggregator_duties) - .await + self.post_with_timeout_and_response( + path, + &selections, + self.timeouts.attestation_aggregators, + ) + .await } } diff --git a/validator_client/src/lib.rs b/validator_client/src/lib.rs index 82cd95cfd2..f0c084bdb2 100644 --- a/validator_client/src/lib.rs +++ b/validator_client/src/lib.rs @@ -60,6 +60,7 @@ const WAITING_FOR_GENESIS_POLL_TIME: Duration = Duration::from_secs(12); const HTTP_ATTESTATION_TIMEOUT_QUOTIENT: u32 = 4; const HTTP_ATTESTER_DUTIES_TIMEOUT_QUOTIENT: u32 = 4; const HTTP_ATTESTATION_SUBSCRIPTIONS_TIMEOUT_QUOTIENT: u32 = 24; +const HTTP_ATTESTATION_AGGREGATOR_TIMEOUT_QUOTIENT: u32 = 3; const HTTP_LIVENESS_TIMEOUT_QUOTIENT: u32 = 4; const HTTP_PROPOSAL_TIMEOUT_QUOTIENT: u32 = 2; const HTTP_PROPOSER_DUTIES_TIMEOUT_QUOTIENT: u32 = 4; @@ -69,7 +70,6 @@ const HTTP_GET_BEACON_BLOCK_SSZ_TIMEOUT_QUOTIENT: u32 = 4; const HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT: u32 = 4; const HTTP_GET_DEPOSIT_SNAPSHOT_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"; @@ -313,6 +313,8 @@ impl ProductionValidatorClient { attester_duties: slot_duration / HTTP_ATTESTER_DUTIES_TIMEOUT_QUOTIENT, attestation_subscriptions: slot_duration / HTTP_ATTESTATION_SUBSCRIPTIONS_TIMEOUT_QUOTIENT, + attestation_aggregators: 2 * slot_duration + / HTTP_ATTESTATION_AGGREGATOR_TIMEOUT_QUOTIENT, liveness: slot_duration / HTTP_LIVENESS_TIMEOUT_QUOTIENT, proposal: slot_duration / HTTP_PROPOSAL_TIMEOUT_QUOTIENT, proposer_duties: slot_duration / HTTP_PROPOSER_DUTIES_TIMEOUT_QUOTIENT, @@ -324,7 +326,6 @@ impl ProductionValidatorClient { get_debug_beacon_states: slot_duration / HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT, get_deposit_snapshot: slot_duration / HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT, get_validator_block: slot_duration / HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT, - aggregator_duties: slot_duration / HTTP_AGGREGATOR_DUTIES_TIMEOUT_QUOTIENT, } } else { Timeouts::set_all(slot_duration)