refactor(mem-pool): reinject mem block tx log
@@ -359,18 +359,22 @@ impl RequestSubmitter {
let db = self.store.begin_transaction();
let mut mem_pool = self.mem_pool.lock().await;
+ log::info!(
+ "reinject mem block txs {}",
+ mem_pool.reinject_txs_mut().len()
+ );
while let Some(hash) = mem_pool.reinject_txs_mut().last().cloned() {
match db.get_mem_pool_transaction(&hash) {
Ok(Some(tx)) => {
if let Err(err) = mem_pool.push_transaction(tx) {
- log::error!("push mem pool reinject tx {} failed {}", hash.pack(), err);
+ log::error!("reinject mem block tx {} failed {}", hash.pack(), err);
}
}
Ok(None) => {
- log::error!("mem block tx {:?} not found", hash.pack());
+ log::error!("reinject mem block tx {} not found", hash.pack());
}
Err(err) => {
- log::error!("fetch mem block tx {} err {}", hash.pack(), err);
+ log::error!("reinject mem block tx {} err {}", hash.pack(), err);
}
}
