GST_STATIC_CAPS ("application/x-rtcp")
);
-#define GST_PAD_LOCK(obj) (g_rec_mutex_lock (&(obj)->padlock))
-#define GST_PAD_UNLOCK(obj) (g_rec_mutex_unlock (&(obj)->padlock))
+#define INTERNAL_STREAM_LOCK(obj) (g_rec_mutex_lock (&(obj)->padlock))
+#define INTERNAL_STREAM_UNLOCK(obj) (g_rec_mutex_unlock (&(obj)->padlock))
typedef enum
{
GstRtpSsrcDemuxPad *demuxpad;
GstPad *retpad;
- GST_PAD_LOCK (demux);
+ INTERNAL_STREAM_LOCK (demux);
demuxpad = find_demux_pad_for_ssrc (demux, ssrc);
if (demuxpad != NULL) {
g_assert_not_reached ();
}
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
return retpad;
}
g_signal_emit (G_OBJECT (demux),
gst_rtp_ssrc_demux_signals[SIGNAL_NEW_SSRC_PAD], 0, ssrc, rtp_pad);
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
gst_object_unref (rtp_pad);
gst_object_unref (rtcp_pad);
{
GstRtpSsrcDemuxPad *dpad;
- GST_PAD_LOCK (demux);
+ INTERNAL_STREAM_LOCK (demux);
dpad = find_demux_pad_for_ssrc (demux, ssrc);
if (dpad == NULL) {
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
goto unknown_pad;
}
GST_DEBUG_OBJECT (demux, "clearing pad for SSRC %08x", ssrc);
demux->srcpads = g_slist_remove (demux->srcpads, dpad);
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
gst_pad_set_active (dpad->rtp_pad, FALSE);
gst_pad_set_active (dpad->rtcp_pad, FALSE);
GSList *walk = NULL;
GstEvent *newevent = NULL;
- GST_PAD_LOCK (fdata->demux);
+ INTERNAL_STREAM_LOCK (fdata->demux);
for (walk = fdata->demux->srcpads; walk; walk = walk->next) {
GstRtpSsrcDemuxPad *dpad = (GstRtpSsrcDemuxPad *) walk->data;
break;
}
}
- GST_PAD_UNLOCK (fdata->demux);
+ INTERNAL_STREAM_UNLOCK (fdata->demux);
if (newevent)
fdata->res &= gst_pad_push_event (pad, newevent);
if (ret != GST_FLOW_OK) {
/* check if the ssrc still there, may have been removed */
- GST_PAD_LOCK (demux);
+ INTERNAL_STREAM_LOCK (demux);
dpad = find_demux_pad_for_ssrc (demux, ssrc);
if (dpad == NULL || dpad->rtp_pad != srcpad) {
/* SSRC was removed during the push ... ignore the error */
ret = GST_FLOW_OK;
}
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
}
gst_object_unref (srcpad);
if (ret != GST_FLOW_OK) {
/* check if the ssrc still there, may have been removed */
- GST_PAD_LOCK (demux);
+ INTERNAL_STREAM_LOCK (demux);
dpad = find_demux_pad_for_ssrc (demux, ssrc);
if (dpad == NULL || dpad->rtcp_pad != srcpad) {
/* SSRC was removed during the push ... ignore the error */
ret = GST_FLOW_OK;
}
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
}
gst_object_unref (srcpad);
demux = GST_RTP_SSRC_DEMUX (parent);
- GST_PAD_LOCK (demux);
+ INTERNAL_STREAM_LOCK (demux);
for (current = demux->srcpads; current; current = g_slist_next (current)) {
GstRtpSsrcDemuxPad *dpad = (GstRtpSsrcDemuxPad *) current->data;
g_value_unset (&val);
}
- GST_PAD_UNLOCK (demux);
+ INTERNAL_STREAM_UNLOCK (demux);
return it;
}