From 4049d0126aa48086c4c32a0d131a26378aaf3cd3 Mon Sep 17 00:00:00 2001 From: David Craven Date: Mon, 8 Jul 2024 10:35:36 +0200 Subject: [PATCH 1/2] Fix indentation. --- chronicle/src/shards/service.rs | 40 ++++++++++++++++----------------- 1 file changed, 20 insertions(+), 20 deletions(-) diff --git a/chronicle/src/shards/service.rs b/chronicle/src/shards/service.rs index 6e0b3755b..a725bbfa3 100644 --- a/chronicle/src/shards/service.rs +++ b/chronicle/src/shards/service.rs @@ -233,26 +233,26 @@ where for session in start_sessions { tss.on_start(session); } - while let Some(n) = self.messages.keys().copied().next() { - if n > block_number { - break; - } - for (shard_id, peer_id, msg) in self.messages.remove(&n).unwrap() { - let Some(tss) = self.tss_states.get_mut(&shard_id) else { - event!( - target: TW_LOG, - parent: &span, - Level::INFO, - shard_id, - "dropping message {} from {:?}", - msg, - peer_id, - ); - continue; - }; - tss.on_message(peer_id, msg)?; - self.poll_actions(&span, shard_id, n).await; - } + } + while let Some(n) = self.messages.keys().copied().next() { + if n > block_number { + break; + } + for (shard_id, peer_id, msg) in self.messages.remove(&n).unwrap() { + let Some(tss) = self.tss_states.get_mut(&shard_id) else { + event!( + target: TW_LOG, + parent: &span, + Level::INFO, + shard_id, + "dropping message {} from {:?}", + msg, + peer_id, + ); + continue; + }; + tss.on_message(peer_id, msg)?; + self.poll_actions(&span, shard_id, n).await; } } Ok(()) From 9f2fd2f6bd7ac839fcf0e3c329129037da61f59e Mon Sep 17 00:00:00 2001 From: David Craven Date: Mon, 8 Jul 2024 10:43:16 +0200 Subject: [PATCH 2/2] Invalid signing session is fine. --- tss/src/lib.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tss/src/lib.rs b/tss/src/lib.rs index 4697ba6e7..ee9f3ac23 100644 --- a/tss/src/lib.rs +++ b/tss/src/lib.rs @@ -190,7 +190,7 @@ where if let Some(session) = signing_sessions.get_mut(&id) { session.on_message(frost_id, msg); } else { - anyhow::bail!("invalid signing session"); + tracing::info!("invalid signing session {}", id); } }, (_, msg) => {