From 2cc584be0b00e959739ca08842ccca5ce2708988 Mon Sep 17 00:00:00 2001 From: Solovyov1796 <xinyu@0g.ai> Date: Sun, 16 Mar 2025 22:28:19 +0800 Subject: [PATCH] add new interface to query the uncommitted txn count for sender --- app/priority_nonce.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/app/priority_nonce.go b/app/priority_nonce.go index 084c944f..d6bb9e3a 100644 --- a/app/priority_nonce.go +++ b/app/priority_nonce.go @@ -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