Related to added more trace logs and improved logic of what is logged when
@@ -191,11 +191,21 @@ where TBackend: TransactionBackend + Clone + 'static
let mut delay = delay_for(self.timeout).fuse();
futures::select! {
mempool_response = mempool_response_receiver.select_next_some() => {
+ trace!(
+ target: LOG_TARGET,
+ "Transaction monitoring event 'mempool_response' triggered ({:?})",
+ mempool_response,
+ );
if self.handle_mempool_response(mempool_response).await? {
break;
}
},
base_node_response = base_node_response_receiver.select_next_some() => {
+ trace!(
+ target: LOG_TARGET,
+ "Transaction monitoring event 'base_node_response' triggered ({:?})",
+ base_node_response,
+ );
if self.handle_base_node_response(base_node_response).await? {
break;
}
@@ -205,19 +215,22 @@ where TBackend: TransactionBackend + Clone + 'static
self.timeout = to;
info!(
target: LOG_TARGET,
- "Broadcast monitoring protocol (Id: {}) timeout updated to {:?}", self.id ,self.timeout
+ "Transaction monitoring event 'updated_timeout' triggered (Id: {}), timeout updated to {:?}", self.id ,self.timeout
+ );
+ } else {
+ trace!(
+ target: LOG_TARGET,
+ "Transaction monitoring event 'updated_timeout' triggered (Id: {}) ({:?})",
+ self.id,
+ updated_timeout,
);
}
},
() = delay => {
- },
- }
-
- info!(
+ trace!(
target: LOG_TARGET,
- "Mempool broadcast timed out for Transaction with TX_ID: {}", self.id
+ "Transaction monitoring event 'time_out' for Mempool broadcast (Id: {}) ", self.id
);
-
let _ = self
.resources
.event_publisher
@@ -230,6 +243,8 @@ where TBackend: TransactionBackend + Clone + 'static
);
e
});
+ },
+ }
}
Ok(self.id)
