blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

More granular timings in shred generation (#6900)

This commit is contained in:
sakridge 2019-11-13 16:30:12 -08:00 committed by GitHub
parent f116cdeed9
commit 6009801c5f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
ledger/src/shred.rs
View File

@ -400,6 +400,8 @@ impl Shredder {
bincode::serialize(entries).expect("Expect to serialize all entries"); bincode::serialize(entries).expect("Expect to serialize all entries");
let serialize_time = now.elapsed().as_millis(); let serialize_time = now.elapsed().as_millis();
let now = Instant::now();
let no_header_size = SIZE_OF_DATA_SHRED_PAYLOAD; let no_header_size = SIZE_OF_DATA_SHRED_PAYLOAD;
let num_shreds = (serialized_shreds.len() + no_header_size - 1) / no_header_size; let num_shreds = (serialized_shreds.len() + no_header_size - 1) / no_header_size;
let last_shred_index = next_shred_index + num_shreds as u32 - 1; let last_shred_index = next_shred_index + num_shreds as u32 - 1;
@ -437,7 +439,9 @@ impl Shredder {
.collect() .collect()
}) })
}); });
let gen_data_time = now.elapsed().as_millis();
let now = Instant::now();
// 2) Generate coding shreds // 2) Generate coding shreds
let mut coding_shreds: Vec<_> = PAR_THREAD_POOL.with(|thread_pool| { let mut coding_shreds: Vec<_> = PAR_THREAD_POOL.with(|thread_pool| {
thread_pool.borrow().install(|| { thread_pool.borrow().install(|| {
@ -449,7 +453,9 @@ impl Shredder {
.collect() .collect()
}) })
}); });
let gen_coding_time = now.elapsed().as_millis();
let now = Instant::now();
// 3) Sign coding shreds // 3) Sign coding shreds
PAR_THREAD_POOL.with(|thread_pool| { PAR_THREAD_POOL.with(|thread_pool| {
thread_pool.borrow().install(|| { thread_pool.borrow().install(|| {
@ -458,16 +464,17 @@ impl Shredder {
}) })
}) })
}); });
let sign_coding_time = now.elapsed().as_millis();
let elapsed = now.elapsed().as_millis();
datapoint_debug!( datapoint_debug!(
"shredding-stats", "shredding-stats",
("slot", self.slot as i64, i64), ("slot", self.slot as i64, i64),
("num_data_shreds", data_shreds.len() as i64, i64), ("num_data_shreds", data_shreds.len() as i64, i64),
("num_coding_shreds", coding_shreds.len() as i64, i64), ("num_coding_shreds", coding_shreds.len() as i64, i64),
("signing_coding", (elapsed - serialize_time) as i64, i64), ("serializing", serialize_time as i64, i64),
("serialzing", serialize_time as i64, i64), ("gen_data", gen_data_time as i64, i64),
("gen_coding", gen_coding_time as i64, i64),
("sign_coding", sign_coding_time as i64, i64),
); );
(data_shreds, coding_shreds, last_shred_index + 1) (data_shreds, coding_shreds, last_shred_index + 1)