mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-25 01:30:38 +00:00
Code Issues 1 Projects Releases Wiki Activity

jitterbuffer: bundle together late lost-events

Browse source 
The scenario where you have a gap in a steady flow of packets of
say 10 seconds (500 packets of with duration of 20ms), the jitterbuffer
will idle up until it receives the first buffer after the gap, but will
then go on to produce 499 lost-events, to "cover up" the gap.

Now this is obviously wrong, since the last possible time for the earliest
lost-events to be played out has obviously expired, but the fact that
the jitterbuffer has a "length", represented with its own latency combined
with the total latency downstream, allows for covering up at least some
of this gap.

So in the case of the "length" being 200ms, while having received packet
500, the jitterbuffer should still create a timeout for packet 491, which
will have its time expire at 10,02 seconds, specially since it might
actually arrive in time! But obviously, waiting for packet 100, that had
its time expire at 2 seconds, (remembering that the current time is 10)
is useless...

The patch will create one "big" lost-event for the first 490 packets,
and then go on to create single ones if they can reach their
playout deadline.

See https://bugzilla.gnome.org/show_bug.cgi?id=667838
This commit is contained in:
Havard Graff 2012-01-13 01:11:31 +01:00 committed by Wim Taymans
parent a858bf46db
commit 9c94f1187c
1 changed files with 44 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

55
gst/rtpmanager/gstrtpjitterbuffer.c
View file

@ -1718,6 +1718,9 @@ again:
if (G_UNLIKELY (gap != 0 && out_time != -1)) {
GstClockReturn ret;
GstClockTime duration = GST_CLOCK_TIME_NONE;
GstClockTimeDiff clock_jitter;
guint32 lost_packets = 1;
gboolean lost_packets_late = FALSE;
if (gap > 0) {
/* we have a gap */
@ -1759,12 +1762,13 @@ again:
goto push_buffer;
}
GST_DEBUG_OBJECT (jitterbuffer, "sync to timestamp %" GST_TIME_FORMAT,
GST_TIME_ARGS (out_time));
/* prepare for sync against clock */
sync_time = get_sync_time (jitterbuffer, out_time);
GST_DEBUG_OBJECT (jitterbuffer, "sync to timestamp %" GST_TIME_FORMAT
" with sync time %" GST_TIME_FORMAT,
GST_TIME_ARGS (out_time), GST_TIME_ARGS (sync_time));
/* create an entry for the clock */
id = priv->clock_id = gst_clock_new_single_shot_id (clock, sync_time);
priv->unscheduled = FALSE;
@ -1773,7 +1777,31 @@ again:
/* release the lock so that the other end can push stuff or unlock */
JBUF_UNLOCK (priv);
ret = gst_clock_id_wait (id, NULL);
ret = gst_clock_id_wait (id, &clock_jitter);
if (ret == GST_CLOCK_EARLY && gap > 0
&& clock_jitter > (priv->latency_ns + priv->peer_latency)) {
GstClockTimeDiff total_duration;
GstClockTime out_time_diff;
out_time_diff = apply_offset (jitterbuffer, timestamp) - out_time;
total_duration = MIN (out_time_diff, clock_jitter);
if (duration > 0)
lost_packets = total_duration / duration;
else
lost_packets = gap;
total_duration = lost_packets * duration;
GST_DEBUG_OBJECT (jitterbuffer,
"Current sync_time has expired a long time ago (+%" GST_TIME_FORMAT
") Cover up %d lost packets with duration %" GST_TIME_FORMAT,
GST_TIME_ARGS (clock_jitter),
lost_packets, GST_TIME_ARGS (total_duration));
duration = total_duration;
lost_packets_late = TRUE;
}
JBUF_LOCK (priv);
/* and free the entry */
@ -1802,15 +1830,20 @@ again:
if (gap > 0) {
GstEvent *event;
/* we had a gap and thus we lost a packet. Create an event for this. */
GST_DEBUG_OBJECT (jitterbuffer, "Packet #%d lost", next_seqnum);
priv->num_late++;
/* we had a gap and thus we lost some packets. Create an event for this. */
if (lost_packets > 1)
GST_DEBUG_OBJECT (jitterbuffer, "Packets #%d -> #%d lost", next_seqnum,
next_seqnum + lost_packets - 1);
else
GST_DEBUG_OBJECT (jitterbuffer, "Packet #%d lost", next_seqnum);
priv->num_late += lost_packets;
discont = TRUE;
/* update our expected next packet */
priv->last_popped_seqnum = next_seqnum;
priv->last_out_time = out_time;
priv->next_seqnum = (next_seqnum + 1) & 0xffff;
priv->last_out_time += duration;
priv->next_seqnum = (next_seqnum + lost_packets) & 0xffff;
if (priv->do_lost) {
/* create paket lost event */
@ -1818,8 +1851,8 @@ again:
gst_structure_new ("GstRTPPacketLost",
"seqnum", G_TYPE_UINT, (guint) next_seqnum,
"timestamp", G_TYPE_UINT64, out_time,
"duration", G_TYPE_UINT64, duration, NULL));
"duration", G_TYPE_UINT64, duration,
"late", G_TYPE_BOOLEAN, lost_packets_late, NULL));
JBUF_UNLOCK (priv);
gst_pad_push_event (priv->srcpad, event);
JBUF_LOCK_CHECK (priv, flushing);