mirror of
https://github.com/sigp/lighthouse.git
synced 2026-03-03 00:31:50 +00:00
d60c24ef1c
Tracing Integration
- [reference](5bbf1859e9/projects/project-ideas.md (L297))
- [x] replace slog & log with tracing throughout the codebase
- [x] implement custom crit log
- [x] make relevant changes in the formatter
- [x] replace sloggers
- [x] re-write SSE logging components
cc: @macladson @eserilev
66 lines
2.2 KiB
Rust
66 lines
2.2 KiB
Rust
#![cfg(any(feature = "mdbx", feature = "lmdb", feature = "redb"))]
|
|
|
|
use slasher::{
|
|
test_utils::{block as test_block, chain_spec, E},
|
|
Config, Slasher,
|
|
};
|
|
use tempfile::tempdir;
|
|
use types::{Epoch, EthSpec};
|
|
|
|
#[test]
|
|
fn empty_pruning() {
|
|
let tempdir = tempdir().unwrap();
|
|
let config = Config::new(tempdir.path().into());
|
|
let spec = chain_spec();
|
|
let slasher = Slasher::<E>::open(config, spec).unwrap();
|
|
slasher.prune_database(Epoch::new(0)).unwrap();
|
|
}
|
|
|
|
#[test]
|
|
fn block_pruning() {
|
|
let slots_per_epoch = E::slots_per_epoch();
|
|
|
|
let tempdir = tempdir().unwrap();
|
|
let mut config = Config::new(tempdir.path().into());
|
|
config.chunk_size = 2;
|
|
config.history_length = 2;
|
|
let spec = chain_spec();
|
|
|
|
let slasher = Slasher::<E>::open(config.clone(), spec).unwrap();
|
|
let current_epoch = Epoch::from(2 * config.history_length);
|
|
|
|
// Pruning the empty database should be safe.
|
|
slasher.prune_database(Epoch::new(0)).unwrap();
|
|
slasher.prune_database(current_epoch).unwrap();
|
|
|
|
// Add blocks in excess of the history length and prune them away.
|
|
let proposer_index = 100_000; // high to check sorting by slot
|
|
for slot in 1..=current_epoch.as_u64() * slots_per_epoch {
|
|
slasher.accept_block_header(test_block(slot, proposer_index, 0));
|
|
}
|
|
slasher.process_queued(current_epoch).unwrap();
|
|
slasher.prune_database(current_epoch).unwrap();
|
|
|
|
// Add more conflicting blocks, and check that only the ones within the non-pruned
|
|
// section are detected as slashable.
|
|
for slot in 1..=current_epoch.as_u64() * slots_per_epoch {
|
|
slasher.accept_block_header(test_block(slot, proposer_index, 1));
|
|
}
|
|
slasher.process_queued(current_epoch).unwrap();
|
|
|
|
let proposer_slashings = slasher.get_proposer_slashings();
|
|
|
|
// Check number of proposer slashings, accounting for single block in current epoch.
|
|
assert_eq!(
|
|
proposer_slashings.len(),
|
|
(config.history_length - 1) * slots_per_epoch as usize + 1
|
|
);
|
|
// Check epochs of all slashings are from within range.
|
|
assert!(proposer_slashings.iter().all(|slashing| slashing
|
|
.signed_header_1
|
|
.message
|
|
.slot
|
|
.epoch(slots_per_epoch)
|
|
> current_epoch - config.history_length as u64));
|
|
}
|