Fixed counters for coalescing and broadcast index (#900)

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)
 }
 

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(())