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

rtpstats: Base the packet rate average on the packet rate itself

Browse source 
Do this so that the average update speed is in time instead of varying
based on the actual packet arrival rate.
This commit is contained in:
olivier.crete@collabora.com 2019-09-10 19:03:02 +01:00 committed by Olivier Crête
parent a637ec3da8
commit 774ddb15b8
1 changed files with 13 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
gst/rtpmanager/rtpstats.c
View file

@ -37,6 +37,7 @@ gst_rtp_packet_rate_ctx_update (RTPPacketRateCtx * ctx, guint16 seqnum,
guint64 new_ts, diff_ts; guint64 new_ts, diff_ts;
gint diff_seqnum; gint diff_seqnum;
gint32 new_packet_rate; gint32 new_packet_rate;
gint32 base;
if (ctx->clock_rate <= 0) { if (ctx->clock_rate <= 0) {
return ctx->avg_packet_rate; return ctx->avg_packet_rate;
@ -73,12 +74,19 @@ gst_rtp_packet_rate_ctx_update (RTPPacketRateCtx * ctx, guint16 seqnum,
* This is useful for bursty cases, where a lot of packets are close * This is useful for bursty cases, where a lot of packets are close
* to each other and should allow a higher reorder/dropout there. * to each other and should allow a higher reorder/dropout there.
* Round up the new average. * Round up the new average.
* We do it on different rates depending on the packet rate, so it's not too
* jumpy.
*/ */
if (ctx->avg_packet_rate > new_packet_rate) { if (ctx->avg_packet_rate > new_packet_rate)
ctx->avg_packet_rate = (7 * ctx->avg_packet_rate + new_packet_rate + 7) / 8; base = MAX (ctx->avg_packet_rate / 3, 8); /* about 333 ms */
} else { else
ctx->avg_packet_rate = (ctx->avg_packet_rate + new_packet_rate + 1) / 2; base = MAX (ctx->avg_packet_rate / 15, 2); /* about 66 ms */
}
diff_seqnum = MIN (diff_seqnum, base - 1);
ctx->avg_packet_rate = (((base - diff_seqnum) * ctx->avg_packet_rate) +
(new_packet_rate * diff_seqnum)) / base;
done_but_save: done_but_save: