diff --git a/src/banking_stage.rs b/src/banking_stage.rs index 83b47a3c0d..55851c0126 100644 --- a/src/banking_stage.rs +++ b/src/banking_stage.rs @@ -43,10 +43,10 @@ fn recv_multiple_packets( mms.append(&mut nq); if recv_tries >= max_tries { + inc_new_counter!("banking_stage-max_packets_coalesced", 1); break; } } - inc_new_counter!("banking_stage-coalesced_packets", recv_tries); Ok(mms) } diff --git a/src/crdt.rs b/src/crdt.rs old mode 100755 new mode 100644 index 9ba8108ad9..dda8c67ee3 --- a/src/crdt.rs +++ b/src/crdt.rs @@ -575,6 +575,8 @@ impl Crdt { broadcast_table.len() ); + let old_transmit_index = transmit_index.data; + // enumerate all the blobs in the window, those are the indices // transmit them to nodes, starting from a different node let mut orders = Vec::with_capacity((received_index - transmit_index.data) as usize); @@ -658,7 +660,10 @@ impl Crdt { transmit_index.data += 1; } } - inc_new_counter!("crdt-broadcast-max_idx", transmit_index.data as usize); + inc_new_counter!( + "crdt-broadcast-max_idx", + (transmit_index.data - old_transmit_index) as usize + ); transmit_index.coding = transmit_index.data; Ok(())