diff options
author | Aria <me@aria.rip> | 2023-10-14 22:58:03 +0100 |
---|---|---|
committer | Aria <me@aria.rip> | 2023-10-14 22:58:03 +0100 |
commit | 7447f3fb801ba954c7b8cbf3f47700ffcc562d20 (patch) | |
tree | 4a7a21ad9301985925038621614cd4e1d0721b25 /broadcast | |
parent | 2c6c06a9c31049567f1c1e0eff522c5a71d6c680 (diff) |
some comments
Diffstat (limited to 'broadcast')
-rw-r--r-- | broadcast/src/handler.rs | 4 |
1 files changed, 3 insertions, 1 deletions
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 { .. } => {} } |