cerc-io/lighthouse
10
0
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Log info loaded from disk

Browse Source
This commit is contained in:
Emilia Hane 2023-01-14 16:40:38 +01:00
parent a2b8c6ee69
commit 94aa2cef67
No known key found for this signature in database
GPG Key ID: E73394F9C09206FA
1 changed files with 16 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
beacon_node/store/src/hot_cold_store.rs
View File

@ -166,7 +166,11 @@ impl<E: EthSpec> HotColdDB<E, LevelDB<E>, LevelDB<E>> {
let mut db = HotColdDB { let mut db = HotColdDB {
split: RwLock::new(Split::default()), split: RwLock::new(Split::default()),
anchor_info: RwLock::new(None), anchor_info: RwLock::new(None),
blob_info: RwLock::new(None), blob_info: RwLock::new(
spec.eip4844_fork_epoch
.is_some()
.then(|| BlobInfo::default()),
),
cold_db: LevelDB::open(cold_path)?, cold_db: LevelDB::open(cold_path)?,
hot_db: LevelDB::open(hot_path)?, hot_db: LevelDB::open(hot_path)?,
block_cache: Mutex::new(LruCache::new(config.block_cache_size)), block_cache: Mutex::new(LruCache::new(config.block_cache_size)),
@ -212,8 +216,17 @@ impl<E: EthSpec> HotColdDB<E, LevelDB<E>, LevelDB<E>> {
); );
} }
if db.spec.eip4844_fork_epoch.is_some() { if let Some(blob_info) = db.load_blob_info()? {
*db.blob_info.write() = db.load_blob_info()?.or(Some(BlobInfo::default())); let dab_slot = blob_info.data_availability_boundary.slot;
let dab_state_root = blob_info.data_availability_boundary.state_root;
*db.blob_info.write() = Some(blob_info);
info!(
db.log,
"Blob info loaded from disk";
"data_availability_boundary_slot" => dab_slot,
"data_availability_boundary_state" => ?dab_state_root,
);
} }
// Ensure that the schema version of the on-disk database matches the software. // Ensure that the schema version of the on-disk database matches the software.