cleanup find_conflict_tx

nervosnetwork · Aug 11, 2023 · 07f4744 · 07f4744
1 parent 05e2f8a
commit 07f4744
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 11 deletions.
diff --git a/tx-pool/src/component/pool_map.rs b/tx-pool/src/component/pool_map.rs
@@ -241,13 +241,9 @@ impl PoolMap {
     }
 
     pub(crate) fn find_conflict_tx(&self, tx: &TransactionView) -> HashSet<ProposalShortId> {
-        let mut res = HashSet::default();
-        for i in tx.input_pts_iter() {
-            if let Some(id) = self.edges.get_input_ref(&i) {
-                res.insert(id.clone());
-            }
-        }
-        res
+        tx.input_pts_iter()
+            .filter_map(|out_point| self.edges.get_input_ref(&out_point).cloned())
+            .collect()
     }
 
     pub(crate) fn resolve_conflict(&mut self, tx: &TransactionView) -> Vec<ConflictEntry> {

diff --git a/tx-pool/src/pool.rs b/tx-pool/src/pool.rs
@@ -97,10 +97,8 @@ impl TxPool {
         if !self.enable_rbf() {
             return None;
         }
-        let conflicts = self.pool_map.find_conflict_tx(tx.transaction());
-        // we don't allow conflicted Tx in pool now
-        assert!(conflicts.len() == 1);
-        self.calculate_min_replace_fee(&conflicts, tx.size)
+        let ids = vec![tx.proposal_short_id()].iter().cloned().collect();
+        self.calculate_min_replace_fee(&ids, tx.size)
     }
 
     fn calculate_min_replace_fee(