src: stream, rtsp: Remove stream if the path is already in use

src/stream/pipeline/mod.rs

@@ -188,6 +188,9 @@ impl PipelineState {
 
             debug!("caps: {:#?}", caps.to_string());
 
+            // In case it exisits, try to remove it first, but skip the result
+            let _ = RTSPServer::stop_pipeline(&sink.path());
+
             RTSPServer::add_pipeline(&sink.path(), &sink.socket_path(), caps)?;
 
             RTSPServer::start_pipeline(&sink.path())?;

src/stream/rtsp/rtsp_server.rs

@@ -227,6 +227,10 @@ impl RTSPServer {
     pub fn stop_pipeline(path: &str) -> Result<()> {
         let mut rtsp_server = RTSP_SERVER.as_ref().lock().unwrap();
 
+        if !rtsp_server.path_to_factory.contains_key(path) {
+            return Err(anyhow!("Path {path:?} not known."));
+        }
+
         // Much like HTTP servers, RTSP servers have multiple endpoints that
         // provide different streams. Here, we ask our server to give
         // us a reference to his list of endpoints, so we can add our
@@ -240,6 +244,8 @@ impl RTSPServer {
 
         rtsp_server.path_to_factory.remove(path);
 
+        debug!("RTSP {path:?} removed.");
+
         Ok(())
     }
 }