mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-28 04:31:06 +00:00
Code Issues 1 Projects Releases Wiki Activity

jitterbuffer: cache latency in nanoseconds

Browse source 
Cache the latency in nanoseconds units to avoid having to convert the
milliseconds value to nanoseconds all the time.
This commit is contained in:
Wim Taymans 2009-10-01 12:52:40 +02:00
parent c262735164
commit 8fb77403c5
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
gst/rtpmanager/gstrtpjitterbuffer.c
View file

@ -139,6 +139,7 @@ struct _GstRtpJitterBufferPrivate
/* properties */ /* properties */
guint latency_ms; guint latency_ms;
guint64 latency_ns;
gboolean drop_on_latency; gboolean drop_on_latency;
gint64 ts_offset; gint64 ts_offset;
gboolean do_lost; gboolean do_lost;
@ -414,6 +415,7 @@ gst_rtp_jitter_buffer_init (GstRtpJitterBuffer * jitterbuffer,
jitterbuffer->priv = priv; jitterbuffer->priv = priv;
priv->latency_ms = DEFAULT_LATENCY_MS; priv->latency_ms = DEFAULT_LATENCY_MS;
priv->latency_ns = priv->latency_ms * GST_MSECOND;
priv->drop_on_latency = DEFAULT_DROP_ON_LATENCY; priv->drop_on_latency = DEFAULT_DROP_ON_LATENCY;
priv->do_lost = DEFAULT_DO_LOST; priv->do_lost = DEFAULT_DO_LOST;
@ -1225,7 +1227,7 @@ gst_rtp_jitter_buffer_chain (GstPad * pad, GstBuffer * buffer)
* FALSE if a packet with the same seqnum was already in the queue, meaning we * FALSE if a packet with the same seqnum was already in the queue, meaning we
* have a duplicate. */ * have a duplicate. */
if (G_UNLIKELY (!rtp_jitter_buffer_insert (priv->jbuf, buffer, timestamp, if (G_UNLIKELY (!rtp_jitter_buffer_insert (priv->jbuf, buffer, timestamp,
priv->clock_rate, (priv->latency_ms * GST_MSECOND), &tail))) priv->clock_rate, priv->latency_ns, &tail)))
goto duplicate; goto duplicate;
/* signal addition of new buffer when the _loop is waiting. */ /* signal addition of new buffer when the _loop is waiting. */
@ -1326,7 +1328,7 @@ get_sync_time (GstRtpJitterBuffer * jitterbuffer, GstClockTime timestamp)
result = timestamp + GST_ELEMENT_CAST (jitterbuffer)->base_time; result = timestamp + GST_ELEMENT_CAST (jitterbuffer)->base_time;
/* add latency, this includes our own latency and the peer latency. */ /* add latency, this includes our own latency and the peer latency. */
result += (priv->latency_ms * GST_MSECOND); result += priv->latency_ns;
result += priv->peer_latency; result += priv->peer_latency;
return result; return result;
@ -1864,7 +1866,7 @@ gst_rtp_jitter_buffer_query (GstPad * pad, GstQuery * query)
/* store this so that we can safely sync on the peer buffers. */ /* store this so that we can safely sync on the peer buffers. */
JBUF_LOCK (priv); JBUF_LOCK (priv);
priv->peer_latency = min_latency; priv->peer_latency = min_latency;
our_latency = ((guint64) priv->latency_ms) * GST_MSECOND; our_latency = priv->latency_ns;
JBUF_UNLOCK (priv); JBUF_UNLOCK (priv);
GST_DEBUG_OBJECT (jitterbuffer, "Our latency: %" GST_TIME_FORMAT, GST_DEBUG_OBJECT (jitterbuffer, "Our latency: %" GST_TIME_FORMAT,
@ -1912,6 +1914,7 @@ gst_rtp_jitter_buffer_set_property (GObject * object,
JBUF_LOCK (priv); JBUF_LOCK (priv);
old_latency = priv->latency_ms; old_latency = priv->latency_ms;
priv->latency_ms = new_latency; priv->latency_ms = new_latency;
priv->latency_ns = priv->latency_ms * GST_MSECOND;
JBUF_UNLOCK (priv); JBUF_UNLOCK (priv);
/* post message if latency changed, this will inform the parent pipeline /* post message if latency changed, this will inform the parent pipeline