From 565c1158d51adb543d1634ca933aaa4d95c7fdad Mon Sep 17 00:00:00 2001 From: TheCharlatan Date: Wed, 8 Jun 2022 10:36:49 +0200 Subject: [PATCH] Checkpoint: Correct message sending --- src/checkpointd/runtime.rs | 4 ++-- src/walletd/runtime.rs | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/checkpointd/runtime.rs b/src/checkpointd/runtime.rs index 1d58cdc84..1bda20e6d 100644 --- a/src/checkpointd/runtime.rs +++ b/src/checkpointd/runtime.rs @@ -313,8 +313,8 @@ pub fn checkpoint_state( ); endpoints.send_to( ServiceBus::Ctl, - ServiceId::Wallet, ServiceId::Checkpoint, + ServiceId::Wallet, Request::CheckpointMultipartChunk(CheckpointMultipartChunk { checksum, msg_index: n, @@ -327,8 +327,8 @@ pub fn checkpoint_state( } else { endpoints.send_to( ServiceBus::Ctl, - ServiceId::Wallet, ServiceId::Checkpoint, + ServiceId::Wallet, Request::Checkpoint(Checkpoint { swap_id, state }), )?; } diff --git a/src/walletd/runtime.rs b/src/walletd/runtime.rs index 267cfd627..e0f7b0e6e 100644 --- a/src/walletd/runtime.rs +++ b/src/walletd/runtime.rs @@ -1606,12 +1606,12 @@ impl Runtime { Request::Checkpoint(request::Checkpoint { swap_id, state }) => match state { CheckpointState::CheckpointWalletAlicePreBuy(alice_state) | CheckpointState::CheckpointWalletAlicePreLock(alice_state) => { - debug!("Restoring alice wallet for swap {}", swap_id); + info!("Restoring alice wallet for swap {}", swap_id); self.wallets.insert(swap_id, Wallet::Alice(alice_state)); } CheckpointState::CheckpointWalletBobPreBuy(bob_state) | CheckpointState::CheckpointWalletBobPreLock(bob_state) => { - debug!("Restoring bob wallet for swap {}", swap_id); + info!("Restoring bob wallet for swap {}", swap_id); self.wallets.insert(swap_id, Wallet::Bob(bob_state)); } },