correction tx channel count
This commit is contained in:
parent
d261c80574
commit
d3db9dbb84
|
@ -170,11 +170,11 @@ impl TxSender {
|
|||
{
|
||||
Ok(value) => match value {
|
||||
Some((sig, tx, slot)) => {
|
||||
TXS_IN_CHANNEL.dec();
|
||||
if self.txs_sent_store.contains_key(&sig) {
|
||||
// duplicate transaction
|
||||
continue;
|
||||
}
|
||||
TXS_IN_CHANNEL.dec();
|
||||
sigs_and_slots.push((sig, slot));
|
||||
txs.push(tx);
|
||||
// update the timeout inteval
|
||||
|
|
Loading…
Reference in New Issue