Tracks are dropped only if input is required

Author: JBRS307

smelter-core/src/pipeline/webrtc/whep_input/input.rs

@@ -189,8 +189,11 @@ async fn init_whep_client(
         let video_sender = Arc::new(Mutex::new(video_sender));
         let audio_sender = Arc::new(Mutex::new(audio_sender));
 
-        // Drop senders if appropriate tracks do not come within 2 seconds.
-        wait_for_tracks(video_sender.clone(), audio_sender.clone());
+        // If the input is required, drop senders if appropriate tracks do not
+        // come within 2 seconds.
+        if queue_input.required() {
+            wait_for_tracks(video_sender.clone(), audio_sender.clone());
+        }
 
         pc.on_track(move |track_ctx| {
             let ctx = WhepTrackContext::new(track_ctx, &ctx, &buffer);

smelter-core/src/pipeline/webrtc/whip_input/create_new_session.rs

@@ -95,8 +95,11 @@ pub(crate) async fn create_new_whip_session(
         let video_sender = Arc::new(Mutex::new(video_sender));
         let audio_sender = Arc::new(Mutex::new(audio_sender));
 
-        // Drop senders if appropriate tracks do not come within 2 seconds.
-        wait_for_tracks(video_sender.clone(), audio_sender.clone());
+        // If the input is required, drop senders if appropriate tracks do not
+        // come within 2 seconds.
+        if queue_input.required() {
+            wait_for_tracks(video_sender.clone(), audio_sender.clone());
+        }
 
         peer_connection.on_track(move |track_ctx| {
             let ctx = WhipTrackContext::new(track_ctx, &state, &buffer);

smelter-core/src/queue/queue_input.rs

@@ -277,6 +277,10 @@ impl QueueInput {
         self.0.lock().unwrap().resume();
     }
 
+    pub fn required(&self) -> bool {
+        self.0.lock().unwrap().required
+    }
+
     pub fn downgrade(&self) -> WeakQueueInput {
         WeakQueueInput(Arc::downgrade(&self.0))
     }