Change sigverify counter from entries to packets
batch or entries kind of useless since it can have some variable number of packets
This commit is contained in:
committed by
sakridge
parent
656b3139e3
commit
1dac4c33b8
@ -54,7 +54,7 @@ impl SigVerifyStage {
|
|||||||
) -> Result<()> {
|
) -> Result<()> {
|
||||||
let (batch, len, recv_time) =
|
let (batch, len, recv_time) =
|
||||||
streamer::recv_batch(&recvr.lock().expect("'recvr' lock in fn verifier"))?;
|
streamer::recv_batch(&recvr.lock().expect("'recvr' lock in fn verifier"))?;
|
||||||
inc_new_counter_info!("sigverify_stage-entries_received", len);
|
inc_new_counter_info!("sigverify_stage-packets_received", len);
|
||||||
|
|
||||||
let now = Instant::now();
|
let now = Instant::now();
|
||||||
let batch_len = batch.len();
|
let batch_len = batch.len();
|
||||||
@ -67,10 +67,7 @@ impl SigVerifyStage {
|
|||||||
);
|
);
|
||||||
|
|
||||||
let verified_batch = Self::verify_batch(batch, sigverify_disabled);
|
let verified_batch = Self::verify_batch(batch, sigverify_disabled);
|
||||||
inc_new_counter_info!(
|
inc_new_counter_info!("sigverify_stage-verified_packets_send", len);
|
||||||
"sigverify_stage-verified_entries_send",
|
|
||||||
verified_batch.len()
|
|
||||||
);
|
|
||||||
|
|
||||||
if sendr.send(verified_batch).is_err() {
|
if sendr.send(verified_batch).is_err() {
|
||||||
return Err(Error::SendError);
|
return Err(Error::SendError);
|
||||||
|
Reference in New Issue
Block a user