mirror/lighthouse-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/lighthouse-pulse.git synced 2025-01-10 21:11:22 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add the batch type to the Batch's KV

Browse Source
This commit is contained in:
Diva M 2022-12-23 10:49:46 -05:00
parent 901764b8f0
commit 24087f104d
No known key found for this signature in database
GPG Key ID: 1BAE5E01126680FE
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
beacon_node/network/src/sync/range_sync/batch.rs
View File

@ -5,6 +5,7 @@ use std::collections::HashSet;
use std::hash::{Hash, Hasher}; use std::hash::{Hash, Hasher};
use std::ops::Sub; use std::ops::Sub;
use std::sync::Arc; use std::sync::Arc;
use strum::Display;
use types::signed_block_and_blobs::BlockWrapper; use types::signed_block_and_blobs::BlockWrapper;
use types::{Epoch, EthSpec, SignedBeaconBlock, SignedBeaconBlockAndBlobsSidecar, Slot}; use types::{Epoch, EthSpec, SignedBeaconBlock, SignedBeaconBlockAndBlobsSidecar, Slot};
@ -40,7 +41,8 @@ impl<T: EthSpec> BatchTy<T> {
pub struct MixedBlockTyErr; pub struct MixedBlockTyErr;
/// Type of expected batch. /// Type of expected batch.
#[derive(Debug, Clone)] #[derive(Debug, Copy, Clone, Display)]
#[strum(serialize_all = "snake_case")]
pub enum ExpectedBatchTy { pub enum ExpectedBatchTy {
OnlyBlockBlobs, OnlyBlockBlobs,
OnlyBlock, OnlyBlock,
@ -247,7 +249,7 @@ impl<T: EthSpec, B: BatchConfig> BatchInfo<T, B> {
start_slot: self.start_slot.into(), start_slot: self.start_slot.into(),
count: self.end_slot.sub(self.start_slot).into(), count: self.end_slot.sub(self.start_slot).into(),
}, },
self.batch_type.clone(), self.batch_type,
) )
} }
@ -557,6 +559,7 @@ impl<T: EthSpec, B: BatchConfig> slog::KV for BatchInfo<T, B> {
serializer.emit_usize("processed", self.failed_processing_attempts.len())?; serializer.emit_usize("processed", self.failed_processing_attempts.len())?;
serializer.emit_u8("processed_no_penalty", self.non_faulty_processing_attempts)?; serializer.emit_u8("processed_no_penalty", self.non_faulty_processing_attempts)?;
serializer.emit_arguments("state", &format_args!("{:?}", self.state))?; serializer.emit_arguments("state", &format_args!("{:?}", self.state))?;
serializer.emit_arguments("batch_ty", &format_args!("{}", self.batch_type));
slog::Result::Ok(()) slog::Result::Ok(())
} }
} }