mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-03-12 06:42:00 +00:00
Code Issues 1 Projects Releases Wiki Activity

stream: Get rtpinfo properties atomically from payloader

Browse source 
Fixes https://bugzilla.gnome.org/show_bug.cgi?id=722844
This commit is contained in:
Sebastian Rasmussen 2014-01-22 22:03:14 +01:00 committed by Wim Taymans
parent e04d9ac34d
commit 7edaa6ca20
1 changed files with 14 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
gst/rtsp-server/rtsp-stream.c
View file

@ -1879,33 +1879,31 @@ gst_rtsp_stream_get_rtpinfo (GstRTSPStream * stream,
GstClockTime * running_time) GstClockTime * running_time)
{ {
GstRTSPStreamPrivate *priv; GstRTSPStreamPrivate *priv;
GObjectClass *payobjclass; GstStructure *stats;
g_return_val_if_fail (GST_IS_RTSP_STREAM (stream), FALSE); g_return_val_if_fail (GST_IS_RTSP_STREAM (stream), FALSE);
priv = stream->priv; priv = stream->priv;
payobjclass = G_OBJECT_GET_CLASS (priv->payloader);
g_mutex_lock (&priv->lock); g_mutex_lock (&priv->lock);
if (seq && g_object_class_find_property (payobjclass, "seqnum"))
g_object_get (priv->payloader, "seqnum", seq, NULL);
if (rtptime && g_object_class_find_property (payobjclass, "timestamp")) g_object_get (priv->payloader, "stats", &stats, NULL);
g_object_get (priv->payloader, "timestamp", rtptime, NULL);
if (running_time if (seq)
&& g_object_class_find_property (payobjclass, "running-time")) gst_structure_get_uint (stats, "seqnum", seq);
g_object_get (priv->payloader, "running-time", running_time, NULL);
if (clock_rate && priv->caps) { if (rtptime)
GstStructure *s; gst_structure_get_uint (stats, "timestamp", rtptime);
s = gst_caps_get_structure (priv->caps, 0);
if (!gst_structure_get_int (s, "clock-rate", (gint *) clock_rate))
if (running_time) if (running_time)
gst_structure_get_clock_time (stats, "running-time", running_time);
if (clock_rate) {
gst_structure_get_uint (stats, "clock-rate", clock_rate);
if (*clock_rate == 0 && running_time)
*running_time = GST_CLOCK_TIME_NONE; *running_time = GST_CLOCK_TIME_NONE;
} }
g_mutex_unlock (&priv->lock); g_mutex_unlock (&priv->lock);
return TRUE; return TRUE;