gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-06-17 02:38:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Clean ups

Browse Source
This commit is contained in:
Jimmy Chen
2026-04-27 12:01:23 +02:00
parent 1543db8b87
commit 0e9107f0be
2 changed files with 19 additions and 29 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
beacon_node/operation_pool/src/lib.rs
View File

@@ -217,16 +217,20 @@ impl<E: EthSpec> OperationPool<E> {
Ok(())
}
/// Build aggregated `PayloadAttestation`s from stored messages for block production.
/// Build `PayloadAttestation`s from stored messages for block production.
///
/// `parent_block_root` is the root of the parent block (the block PTC members attested to).
/// Returns up to `MAX_PAYLOAD_ATTESTATIONS` attestations for the previous slot.
/// Returns one `PayloadAttestation` per distinct `PayloadAttestationData`. With two boolean
/// fields this yields at most 4, which equals `MAX_PAYLOAD_ATTESTATIONS`.
pub fn get_payload_attestations(
&self,
state: &BeaconState<E>,
parent_block_root: Hash256,
spec: &ChainSpec,
) -> Result<Vec<PayloadAttestation<E>>, OpPoolError> {
if state.slot() == 0 {
return Ok(vec![]);
}
let target_slot = state.slot().saturating_sub(1u64);
let ptc = state
@@ -249,13 +253,12 @@ impl<E: EthSpec> OperationPool<E> {
.0
.iter()
.position(|&idx| idx == msg.validator_index as usize)
&& !aggregation_bits.get(pos).unwrap_or(false)
{
if !aggregation_bits.get(pos).unwrap_or(false) {
aggregation_bits
.set(pos, true)
.map_err(|_| OpPoolError::PayloadAttestationBitError)?;
aggregate_sig.add_assign(&msg.signature);
}
aggregation_bits
.set(pos, true)
.map_err(|_| OpPoolError::PayloadAttestationBitError)?;
aggregate_sig.add_assign(&msg.signature);
}
}