log snapshot time (#5996)
This commit is contained in:
parent
8eab673b1c
commit
c9be9acd14
|
@ -203,7 +203,7 @@ impl BankForks {
|
||||||
// Cleanup outdated snapshots
|
// Cleanup outdated snapshots
|
||||||
self.purge_old_snapshots();
|
self.purge_old_snapshots();
|
||||||
snapshot_time.stop();
|
snapshot_time.stop();
|
||||||
inc_new_counter_info!("total-snapshot-setup-ms", snapshot_time.as_ms() as usize);
|
inc_new_counter_info!("total-snapshot-ms", snapshot_time.as_ms() as usize);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -254,7 +254,11 @@ impl BankForks {
|
||||||
.get(root)
|
.get(root)
|
||||||
.cloned()
|
.cloned()
|
||||||
.expect("root must exist in BankForks");
|
.expect("root must exist in BankForks");
|
||||||
|
|
||||||
|
let mut add_snapshot_time = Measure::start("add-snapshot-ms");
|
||||||
snapshot_utils::add_snapshot(&config.snapshot_path, &bank, slots_since_snapshot)?;
|
snapshot_utils::add_snapshot(&config.snapshot_path, &bank, slots_since_snapshot)?;
|
||||||
|
add_snapshot_time.stop();
|
||||||
|
inc_new_counter_info!("add-snapshot-ms", add_snapshot_time.as_ms() as usize);
|
||||||
|
|
||||||
// Package the relevant snapshots
|
// Package the relevant snapshots
|
||||||
let slot_snapshot_paths = snapshot_utils::get_snapshot_paths(&config.snapshot_path);
|
let slot_snapshot_paths = snapshot_utils::get_snapshot_paths(&config.snapshot_path);
|
||||||
|
|
|
@ -5,6 +5,7 @@ use crate::snapshot_package::{TAR_ACCOUNTS_DIR, TAR_SNAPSHOTS_DIR};
|
||||||
use bincode::{deserialize_from, serialize_into};
|
use bincode::{deserialize_from, serialize_into};
|
||||||
use bzip2::bufread::BzDecoder;
|
use bzip2::bufread::BzDecoder;
|
||||||
use fs_extra::dir::CopyOptions;
|
use fs_extra::dir::CopyOptions;
|
||||||
|
use solana_measure::measure::Measure;
|
||||||
use solana_runtime::bank::Bank;
|
use solana_runtime::bank::Bank;
|
||||||
use solana_runtime::status_cache::SlotDelta;
|
use solana_runtime::status_cache::SlotDelta;
|
||||||
use solana_sdk::transaction;
|
use solana_sdk::transaction;
|
||||||
|
@ -160,12 +161,19 @@ pub fn add_snapshot<P: AsRef<Path>>(
|
||||||
// Create the snapshot
|
// Create the snapshot
|
||||||
serialize_into(&mut snapshot_stream, &*bank).map_err(|e| get_io_error(&e.to_string()))?;
|
serialize_into(&mut snapshot_stream, &*bank).map_err(|e| get_io_error(&e.to_string()))?;
|
||||||
serialize_into(&mut snapshot_stream, &bank.rc).map_err(|e| get_io_error(&e.to_string()))?;
|
serialize_into(&mut snapshot_stream, &bank.rc).map_err(|e| get_io_error(&e.to_string()))?;
|
||||||
|
|
||||||
|
let mut status_cache_serialize = Measure::start("status_cache_serialize-ms");
|
||||||
// write the status cache
|
// write the status cache
|
||||||
serialize_into(
|
serialize_into(
|
||||||
&mut status_cache_stream,
|
&mut status_cache_stream,
|
||||||
&bank.src.slot_deltas(slots_since_snapshot),
|
&bank.src.slot_deltas(slots_since_snapshot),
|
||||||
)
|
)
|
||||||
.map_err(|_| get_io_error("serialize bank status cache error"))?;
|
.map_err(|_| get_io_error("serialize bank status cache error"))?;
|
||||||
|
status_cache_serialize.stop();
|
||||||
|
inc_new_counter_info!(
|
||||||
|
"serialize-status-cache-ms",
|
||||||
|
status_cache_serialize.as_ms() as usize
|
||||||
|
);
|
||||||
|
|
||||||
info!(
|
info!(
|
||||||
"successfully created snapshot {}, path: {:?} status_cache: {:?}",
|
"successfully created snapshot {}, path: {:?} status_cache: {:?}",
|
||||||
|
|
Loading…
Reference in New Issue