Add counter for new transactions in SendTransactionService (#20852)
* Add counter for inserted transactions * Add counter for tx recv
This commit is contained in:
parent
9b1199cdb1
commit
8959d5e21c
|
@ -143,6 +143,7 @@ impl SendTransactionService {
|
||||||
Err(RecvTimeoutError::Disconnected) => break,
|
Err(RecvTimeoutError::Disconnected) => break,
|
||||||
Err(RecvTimeoutError::Timeout) => {}
|
Err(RecvTimeoutError::Timeout) => {}
|
||||||
Ok(transaction_info) => {
|
Ok(transaction_info) => {
|
||||||
|
inc_new_counter_info!("send_transaction_service-recv-tx", 1);
|
||||||
let addresses = leader_info.as_ref().map(|leader_info| {
|
let addresses = leader_info.as_ref().map(|leader_info| {
|
||||||
leader_info.get_leader_tpus(config.leader_forward_count)
|
leader_info.get_leader_tpus(config.leader_forward_count)
|
||||||
});
|
});
|
||||||
|
@ -163,6 +164,7 @@ impl SendTransactionService {
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
if transactions.len() < MAX_TRANSACTION_QUEUE_SIZE {
|
if transactions.len() < MAX_TRANSACTION_QUEUE_SIZE {
|
||||||
|
inc_new_counter_info!("send_transaction_service-insert-tx", 1);
|
||||||
transactions.insert(transaction_info.signature, transaction_info);
|
transactions.insert(transaction_info.signature, transaction_info);
|
||||||
} else {
|
} else {
|
||||||
datapoint_warn!("send_transaction_service-queue-overflow");
|
datapoint_warn!("send_transaction_service-queue-overflow");
|
||||||
|
|
Loading…
Reference in New Issue