broker: discard new connection if already connected

EspressoSystems · Mar 18, 2024 · 8f9cc2d · 8f9cc2d
1 parent c585b07
commit 8f9cc2d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/cdn-broker/src/handlers/broker.rs b/cdn-broker/src/handlers/broker.rs
@@ -49,6 +49,11 @@ impl<
         // Create new batch sender
         let (sender, receiver) = connection;
 
+        // If we are already connected, ignore the new connection
+        if self.connections.all_brokers().contains(&broker_identifier) {
+            return;
+        }
+
         // Add to our brokers
         self.connections
             .add_broker(broker_identifier.clone(), sender);