From 7447f3fb801ba954c7b8cbf3f47700ffcc562d20 Mon Sep 17 00:00:00 2001 From: Aria Date: Sat, 14 Oct 2023 22:58:03 +0100 Subject: some comments --- broadcast/src/handler.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'broadcast/src') diff --git a/broadcast/src/handler.rs b/broadcast/src/handler.rs index 5ebed27..d4bb94a 100644 --- a/broadcast/src/handler.rs +++ b/broadcast/src/handler.rs @@ -101,13 +101,15 @@ impl Handler for BroadcastHandler { .await } - // Ignore OK messages - we never actually request them BroadcastBody::BroadcastOk { in_reply_to } => { + // Stop retrying, if we still are if let Some(task) = self.attempted_broadcasts.lock().await.remove(&in_reply_to) { task.cancel().await; } } + + // Ignore other OK messages - we never actually request them BroadcastBody::TopologyOk { .. } => {} BroadcastBody::ReadOk { .. } => {} } -- cgit v1.2.3