deposit_relay.rs: add info level logging
This commit is contained in:
parent
60130d0d6f
commit
c91eae631f
|
@ -73,6 +73,7 @@ impl<T: Transport> Stream for DepositRelay<T> {
|
||||||
let next_state = match self.state {
|
let next_state = match self.state {
|
||||||
DepositRelayState::Wait => {
|
DepositRelayState::Wait => {
|
||||||
let item = try_stream!(self.logs.poll());
|
let item = try_stream!(self.logs.poll());
|
||||||
|
info!("got {} new deposits to relay", item.logs.len());
|
||||||
let deposits = item.logs
|
let deposits = item.logs
|
||||||
.into_iter()
|
.into_iter()
|
||||||
.map(|log| deposit_relay_payload(&self.app.home_bridge, &self.app.foreign_bridge, log))
|
.map(|log| deposit_relay_payload(&self.app.home_bridge, &self.app.foreign_bridge, log))
|
||||||
|
@ -95,6 +96,7 @@ impl<T: Transport> Stream for DepositRelay<T> {
|
||||||
})
|
})
|
||||||
.collect::<Vec<_>>();
|
.collect::<Vec<_>>();
|
||||||
|
|
||||||
|
info!("relaying {} deposits", deposits.len());
|
||||||
DepositRelayState::RelayDeposits {
|
DepositRelayState::RelayDeposits {
|
||||||
future: join_all(deposits),
|
future: join_all(deposits),
|
||||||
block: item.to,
|
block: item.to,
|
||||||
|
@ -102,6 +104,7 @@ impl<T: Transport> Stream for DepositRelay<T> {
|
||||||
},
|
},
|
||||||
DepositRelayState::RelayDeposits { ref mut future, block } => {
|
DepositRelayState::RelayDeposits { ref mut future, block } => {
|
||||||
let _ = try_ready!(future.poll());
|
let _ = try_ready!(future.poll());
|
||||||
|
info!("deposit relay completed");
|
||||||
DepositRelayState::Yield(Some(block))
|
DepositRelayState::Yield(Some(block))
|
||||||
},
|
},
|
||||||
DepositRelayState::Yield(ref mut block) => match block.take() {
|
DepositRelayState::Yield(ref mut block) => match block.take() {
|
||||||
|
|
Loading…
Reference in New Issue