diff --git a/bridge/src/bridge/deposit_relay.rs b/bridge/src/bridge/deposit_relay.rs index 1a83cf2..ae25695 100644 --- a/bridge/src/bridge/deposit_relay.rs +++ b/bridge/src/bridge/deposit_relay.rs @@ -73,6 +73,7 @@ impl Stream for DepositRelay { let next_state = match self.state { DepositRelayState::Wait => { let item = try_stream!(self.logs.poll()); + info!("got {} new deposits to relay", item.logs.len()); let deposits = item.logs .into_iter() .map(|log| deposit_relay_payload(&self.app.home_bridge, &self.app.foreign_bridge, log)) @@ -95,6 +96,7 @@ impl Stream for DepositRelay { }) .collect::>(); + info!("relaying {} deposits", deposits.len()); DepositRelayState::RelayDeposits { future: join_all(deposits), block: item.to, @@ -102,6 +104,7 @@ impl Stream for DepositRelay { }, DepositRelayState::RelayDeposits { ref mut future, block } => { let _ = try_ready!(future.poll()); + info!("deposit relay completed"); DepositRelayState::Yield(Some(block)) }, DepositRelayState::Yield(ref mut block) => match block.take() {