summaryrefslogtreecommitdiff
path: root/broadcast/src/handler.rs
diff options
context:
space:
mode:
authorAria <me@aria.rip>2023-10-14 22:58:03 +0100
committerAria <me@aria.rip>2023-10-14 22:58:03 +0100
commit7447f3fb801ba954c7b8cbf3f47700ffcc562d20 (patch)
tree4a7a21ad9301985925038621614cd4e1d0721b25 /broadcast/src/handler.rs
parent2c6c06a9c31049567f1c1e0eff522c5a71d6c680 (diff)
some comments
Diffstat (limited to 'broadcast/src/handler.rs')
-rw-r--r--broadcast/src/handler.rs4
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 { .. } => {}
}