add new interface to query the uncommitted txn count for sender

This commit is contained in:
Solovyov1796 2025-03-16 22:28:19 +08:00
parent d8e968146b
commit 2cc584be0b

View File

@ -495,6 +495,16 @@ func (mp *PriorityNonceMempool) doSelect(_ context.Context, _ [][]byte) mempool.
return iterator.iteratePriority()
}
func (mp *PriorityNonceMempool) GetSenderUncommittedTxnCount(ctx context.Context, sender string) int {
mp.mtx.Lock()
defer mp.mtx.Unlock()
if _, exists := mp.counterBySender[sender]; exists {
return mp.counterBySender[sender]
}
return 0
}
type reorderKey struct {
deleteKey txMeta
insertKey txMeta