ts/examples: add rtp mode with jitter-buffer & trace stop duration

1 files changed, 28 insertions, 10 deletions

diff --git a/generic/threadshare/src/jitterbuffer/imp.rs b/generic/threadshare/src/jitterbuffer/imp.rs
index 98ff1b142..248b9f156 100644
--- a/generic/threadshare/src/jitterbuffer/imp.rs
+++ b/generic/threadshare/src/jitterbuffer/imp.rs
@@ -180,20 +180,32 @@ impl SinkHandler {
     ) -> Result<gst::FlowSuccess, gst::FlowError> {
         let s = caps.structure(0).ok_or(gst::FlowError::Error)?;
 
-        gst::info!(CAT, obj: element, "Parsing {:?}", caps);
+        gst::debug!(CAT, obj: element, "Parsing {:?}", caps);
 
-        let payload = s.get::<i32>("payload").map_err(|_| gst::FlowError::Error)?;
+        let payload = s.get::<i32>("payload").map_err(|err| {
+            gst::debug!(CAT, obj: element, "Caps 'payload': {}", err);
+            gst::FlowError::Error
+        })?;
 
         if pt != 0 && payload as u8 != pt {
+            gst::debug!(
+                CAT,
+                obj: element,
+                "Caps 'payload' ({}) doesn't match payload type ({})",
+                payload,
+                pt
+            );
             return Err(gst::FlowError::Error);
         }
 
         inner.last_pt = Some(pt);
-        let clock_rate = s
-            .get::<i32>("clock-rate")
-            .map_err(|_| gst::FlowError::Error)?;
+        let clock_rate = s.get::<i32>("clock-rate").map_err(|err| {
+            gst::debug!(CAT, obj: element, "Caps 'clock-rate': {}", err);
+            gst::FlowError::Error
+        })?;
 
         if clock_rate <= 0 {
+            gst::debug!(CAT, obj: element, "Caps 'clock-rate' <= 0");
             return Err(gst::FlowError::Error);
         }
         state.clock_rate = Some(clock_rate as u32);
@@ -371,8 +383,14 @@ impl SinkHandler {
                 drop(state);
                 let caps = element
                     .try_emit_by_name::<Option<gst::Caps>>("request-pt-map", &[&(pt as u32)])
-                    .map_err(|_| gst::FlowError::Error)?
-                    .ok_or(gst::FlowError::Error)?;
+                    .map_err(|err| {
+                        gst::error!(CAT, obj: pad, "Emitting 'request-pt-map': {}", err);
+                        gst::FlowError::Error
+                    })?
+                    .ok_or_else(|| {
+                        gst::error!(CAT, obj: pad, "Signal 'request-pt-map' retuned None");
+                        gst::FlowError::Error
+                    })?;
                 let mut state = jb.state.lock().unwrap();
                 self.parse_caps(inner, &mut state, element, &caps, pt)?;
                 state
@@ -1248,7 +1266,7 @@ static CAT: Lazy<gst::DebugCategory> = Lazy::new(|| {
 
 impl JitterBuffer {
     fn clear_pt_map(&self, element: &super::JitterBuffer) {
-        gst::info!(CAT, obj: element, "Clearing PT map");
+        gst::debug!(CAT, obj: element, "Clearing PT map");
 
         let mut state = self.state.lock().unwrap();
         state.clock_rate = None;
@@ -1256,7 +1274,7 @@ impl JitterBuffer {
     }
 
     fn prepare(&self, element: &super::JitterBuffer) -> Result<(), gst::ErrorMessage> {
-        gst::info!(CAT, obj: element, "Preparing");
+        gst::debug!(CAT, obj: element, "Preparing");
 
         let context = {
             let settings = self.settings.lock().unwrap();
@@ -1275,7 +1293,7 @@ impl JitterBuffer {
                 )
             })?;
 
-        gst::info!(CAT, obj: element, "Prepared");
+        gst::debug!(CAT, obj: element, "Prepared");
 
         Ok(())
     }