update for RTP buffer api changes

diff --git a/gst/dtmf/gstrtpdtmfdepay.c b/gst/dtmf/gstrtpdtmfdepay.c
index 0dda885013f7e1d2805469f7a91800fdc2529626..1bea465593b07cb791282e9ed4cdd1a514688d9f 100644 (file)
--- a/gst/dtmf/gstrtpdtmfdepay.c
+++ b/gst/dtmf/gstrtpdtmfdepay.c
@@ -407,9 +407,6 @@ gst_rtp_dtmf_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
 
   rtpdtmfdepay = GST_RTP_DTMF_DEPAY (depayload);
 
-  if (!gst_rtp_buffer_validate (buf))
-    goto bad_packet;
-
   gst_rtp_buffer_map (buf, GST_MAP_READ, &rtpbuffer);
 
   payload_len = gst_rtp_buffer_get_payload_len (&rtpbuffer);
@@ -423,7 +420,6 @@ gst_rtp_dtmf_depay_process (GstRTPBaseDepayload * depayload, GstBuffer * buf)
   if (dtmf_payload.event > MAX_EVENT)
     goto bad_packet;
 
-
   marker = gst_rtp_buffer_get_marker (&rtpbuffer);
 
   timestamp = gst_rtp_buffer_get_timestamp (&rtpbuffer);

diff --git a/gst/rtpmux/gstrtpmux.c b/gst/rtpmux/gstrtpmux.c
index 20ed5a1c3b8089f237c423d21a540a940dca6bfa..7f69957d2c437ea9fb3af81b77e5ce43a12b2186 100644 (file)
--- a/gst/rtpmux/gstrtpmux.c
+++ b/gst/rtpmux/gstrtpmux.c
@@ -469,12 +469,6 @@ gst_rtp_mux_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
 
   rtp_mux = GST_RTP_MUX (GST_OBJECT_PARENT (pad));
 
-  if (!gst_rtp_buffer_validate (buffer)) {
-    gst_buffer_unref (buffer);
-    GST_ERROR_OBJECT (rtp_mux, "Invalid RTP buffer");
-    return GST_FLOW_ERROR;
-  }
-
   GST_OBJECT_LOCK (rtp_mux);
   padpriv = gst_pad_get_element_private (pad);
 
@@ -486,7 +480,12 @@ gst_rtp_mux_chain (GstPad * pad, GstObject * parent, GstBuffer * buffer)
 
   buffer = gst_buffer_make_writable (buffer);
 
-  gst_rtp_buffer_map (buffer, GST_MAP_READWRITE, &rtpbuffer);
+  if (!gst_rtp_buffer_map (buffer, GST_MAP_READWRITE, &rtpbuffer)) {
+    GST_OBJECT_UNLOCK (rtp_mux);
+    gst_buffer_unref (buffer);
+    GST_ERROR_OBJECT (rtp_mux, "Invalid RTP buffer");
+    return GST_FLOW_ERROR;
+  }
 
   drop = !process_buffer_locked (rtp_mux, padpriv, &rtpbuffer);