Skip to content

Commit

Permalink
Adjusted logs for better msg correlation.
Browse files Browse the repository at this point in the history
  • Loading branch information
adizere committed Jul 1, 2021
1 parent c509f88 commit 99ac0f9
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
5 changes: 3 additions & 2 deletions relayer/src/link.rs
Original file line number Diff line number Diff line change
Expand Up @@ -598,10 +598,11 @@ impl RelayPath {

for i in 0..MAX_RETRIES {
info!(
"[{}] relay op. data to {}, proofs height {}, (delayed by: {:?}) [try {}/{}]",
"[{}] relay op. data of {} msgs(s) to {} (height {}), delayed by: {:?} [try {}/{}]",
self,
odata.batch.len(),
odata.target,
odata.proofs_height,
odata.proofs_height.increment(),
odata.scheduled_time.elapsed(),
i + 1,
MAX_RETRIES
Expand Down
2 changes: 1 addition & 1 deletion relayer/src/worker/handle.rs
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ impl WorkerHandle {
Ok(())
}

/// Send a batch of [`NewBlock`] event to the worker.
/// Send a [`NewBlock`] event to the worker.
pub fn send_new_block(&self, height: Height, new_block: NewBlock) -> Result<(), BoxError> {
self.tx.send(WorkerCmd::NewBlock { height, new_block })?;
Ok(())
Expand Down

0 comments on commit 99ac0f9

Please sign in to comment.