Skip to content

Commit 1547da0

Browse files
committed
don't peek recycled nonces
1 parent a2a7561 commit 1547da0

2 files changed

Lines changed: 1 addition & 10 deletions

File tree

executors/src/eoa/store/mod.rs

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -510,15 +510,6 @@ impl EoaExecutorStore {
510510
}
511511
}
512512

513-
/// Peek recycled nonces without removing them
514-
pub async fn peek_recycled_nonces(&self) -> Result<Vec<u64>, TransactionStoreError> {
515-
let recycled_key = self.recycled_nonces_zset_name();
516-
let mut conn = self.redis.clone();
517-
518-
let nonces: Vec<u64> = conn.zrange(&recycled_key, 0, -1).await?;
519-
Ok(nonces)
520-
}
521-
522513
/// Peek at pending transactions without removing them (safe for planning)
523514
pub async fn peek_pending_transactions(
524515
&self,

executors/src/eoa/worker/send.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ impl<C: Chain> EoaExecutorWorker<C> {
6262
total_sent += self.process_recycled_nonces().await?;
6363

6464
// 3. Only proceed to new nonces if we successfully used all recycled nonces
65-
let remaining_recycled = self.store.peek_recycled_nonces().await?.len();
65+
let remaining_recycled = self.store.clean_and_get_recycled_nonces().await?.len();
6666
if remaining_recycled == 0 {
6767
let inflight_budget = self.store.get_inflight_budget(self.max_inflight).await?;
6868
if inflight_budget > 0 {

0 commit comments

Comments
 (0)