listeners: fix duplicate listener names by stopping existing listener

- Check if listener with same name exists before starting new one
- Stop the existing listener to prevent conflicts
- Improve logging for duplicate listener detection

Signed-off-by: Eeshu-Yadav <[email protected]>

Author: Eeshu-Yadav

orion-lib/src/listeners/listeners_manager.rs

@@ -125,19 +125,19 @@ impl ListenersManager {
         let listener_name = listener.get_name();
         let (addr, dev) = listener.get_socket();
         info!("Listener {} at {addr} (device bind:{})", listener_name, dev.is_some());
+
+        // Stop the old listener if it exists before starting a new one
+        if self.listener_handles.contains_key(&listener_name) {
+            self.stop_listener(&listener_name)?;
+            #[cfg(debug_assertions)]
+            debug!("Listener {listener_name} already exists, stopping and replacing it");
+        }
+
         // spawn the task for this listener address, this will spawn additional task per connection
         let join_handle = tokio::spawn(async move {
             let error = listener.start().await;
             warn!("Listener {listener_name} exited: {error}");
         });
-        #[cfg(debug_assertions)]
-        if self.listener_handles.contains_key(&listener_name) {
-            debug!("Listener {listener_name} already exists, replacing it");
-        }
-        // note: join handle gets overwritten here if it already exists.
-        // handles are abort on drop so will be aborted, closing the socket
-        // but the any tasks spawned within this task, which happens on a per-connection basis,
-        // will survive past this point and only get dropped when their session ends
         self.listener_handles.insert(listener_name, ListenerInfo::new(join_handle, listener_conf));
 
         Ok(())