[gst-cvs] burger gst-plugins-base: gst-plugins-base/ gst-plugins-base/gst-libs/gst/rtp/

[<bu...@fr...>]

CVS Root:       /cvs/gstreamer
Module:         gst-plugins-base
Changes by:     burger
Date:           Sat Dec 17 2005  16:56:19 PST

Log message:
2005-12-17  Philippe Khalaf  <bu...@sp...>
	* gst-libs/gst/rtp/gstbasertpdepayload.c:
	(gst_base_rtp_depayload_init), (gst_base_rtp_depayload_handle_sink_event):
		Handle downstream newsegment by sending our own newsegment before the
		next buffer to be released. (#323900)

Modified files:
    .               : ChangeLog
    gst-libs/gst/rtp: gstbasertpdepayload.c

Links:
http://freedesktop.org/cgi-bin/viewcvs.cgi/gstreamer/gst-plugins-base/ChangeLog.diff?r1=1.2233&r2=1.2234
http://freedesktop.org/cgi-bin/viewcvs.cgi/gstreamer/gst-plugins-base/gst-libs/gst/rtp/gstbasertpdepayload.c.diff?r1=1.26&r2=1.27

====Begin Diffs====
Index: ChangeLog
===================================================================
RCS file: /cvs/gstreamer/gst-plugins-base/ChangeLog,v
retrieving revision 1.2233
retrieving revision 1.2234
diff -u -d -r1.2233 -r1.2234
--- ChangeLog	18 Dec 2005 00:41:09 -0000	1.2233
+++ ChangeLog	18 Dec 2005 00:56:06 -0000	1.2234
@@ -1,6 +1,13 @@
 2005-12-17  Philippe Khalaf  <bu...@sp...> 
 
 	* gst-libs/gst/rtp/gstbasertpdepayload.c:
+	(gst_base_rtp_depayload_init), (gst_base_rtp_depayload_handle_sink_event):
+		Handle downstream newsegment by sending our own newsegment before the
+		next buffer to be released. (#323900)
+
+2005-12-17  Philippe Khalaf  <bu...@sp...> 
+	* gst-libs/gst/rtp/gstbasertpdepayload.c:
 	(gst_base_rtp_depayload_set_gst_timestamp):
 		add queue delay to new segment as well (as opposed to just the first
 		buffer). (bug #322347)
Index: gstbasertpdepayload.c
RCS file: /cvs/gstreamer/gst-plugins-base/gst-libs/gst/rtp/gstbasertpdepayload.c,v
retrieving revision 1.26
retrieving revision 1.27
diff -u -d -r1.26 -r1.27
--- gstbasertpdepayload.c	18 Dec 2005 00:41:10 -0000	1.26
+++ gstbasertpdepayload.c	18 Dec 2005 00:56:07 -0000	1.27
@@ -79,6 +79,8 @@
 static GstFlowReturn gst_base_rtp_depayload_chain (GstPad * pad,
     GstBuffer * in);
+static gboolean
+gst_base_rtp_depayload_handle_sink_event (GstPad * pad, GstEvent * event);
 static GstStateChangeReturn gst_base_rtp_depayload_change_state (GstElement *
     element, GstStateChange transition);
@@ -139,6 +141,8 @@
   gst_pad_set_setcaps_function (filter->sinkpad,
       gst_base_rtp_depayload_setcaps);
   gst_pad_set_chain_function (filter->sinkpad, gst_base_rtp_depayload_chain);
+  gst_pad_set_event_function (filter->sinkpad,
+      gst_base_rtp_depayload_handle_sink_event);
   gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad);
   pad_template =
@@ -205,6 +209,33 @@
   return ret;
 }
+gst_base_rtp_depayload_handle_sink_event (GstPad * pad, GstEvent * event)
+{
+  GstBaseRTPDepayload *filter =
+      GST_BASE_RTP_DEPAYLOAD (GST_OBJECT_PARENT (pad));
+  gboolean res = TRUE;
+  switch (GST_EVENT_TYPE (event)) {
+    case GST_EVENT_NEWSEGMENT:
+    {
+      GST_DEBUG_OBJECT (filter,
+          "Upstream sent a NEWSEGMENT, handle in worker thread.");
+      /* the worker thread will assign a new RTP-TS<->GST-TS mapping
+       * based on the next processed RTP packet */
+      filter->need_newsegment = TRUE;
+      gst_event_unref (event);
+      break;
+    }
+    default:
+      /* pass other events forward */
+      res = gst_pad_push_event (filter->srcpad, event);
+  }
+  return res;
+}
 static GstFlowReturn
 gst_base_rtp_depayload_add_to_queue (GstBaseRTPDepayload * filter,
     GstBuffer * in)
@@ -359,8 +390,10 @@
 {
   while (filter->thread_running) {
     gst_base_rtp_depayload_queue_release (filter);
-    /* i want to run this thread clock_rate times per second */
-    /* sleep for 5msec */
+    /* sleep for 5msec (XXX: 5msec is a value that works for audio and video,
+     * should be adjusted based on frequency of incoming packet, 
+     * or by data comsumption rate of the sink (depends on how
+     * clock-drift compensation is implemented) */
     gst_base_rtp_depayload_wait (filter, GST_MSECOND * 5);
   }
   return NULL;