From e568db40258d549777ac1c16971678e18a18f5f5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Martin=20Storsj=C3=B6?= Date: Thu, 10 Jan 2013 16:35:11 +0200 Subject: [PATCH] rtpdec: Calculate and report packet reception jitter MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This brings back some code that was added originally in 4a6cc061 but never was used, and was removed as unused in 4cc843fa. The code is updated to actually work and is tested to return sane values. Signed-off-by: Martin Storsjö --- libavformat/rtpdec.c | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/libavformat/rtpdec.c b/libavformat/rtpdec.c index 20c11c73cf..ac294a0c42 100644 --- a/libavformat/rtpdec.c +++ b/libavformat/rtpdec.c @@ -228,6 +228,24 @@ static int rtp_valid_packet_in_sequence(RTPStatistics *s, uint16_t seq) return 1; } +static void rtcp_update_jitter(RTPStatistics *s, uint32_t sent_timestamp, + uint32_t arrival_timestamp) +{ + // Most of this is pretty straight from RFC 3550 appendix A.8 + uint32_t transit = arrival_timestamp - sent_timestamp; + uint32_t prev_transit = s->transit; + int32_t d = transit - prev_transit; + // Doing the FFABS() call directly on the "transit - prev_transit" + // expression doesn't work, since it's an unsigned expression. Doing the + // transit calculation in unsigned is desired though, since it most + // probably will need to wrap around. + d = FFABS(d); + s->transit = transit; + if (!prev_transit) + return; + s->jitter += d - (int32_t) ((s->jitter + 8) >> 4); +} + int ff_rtp_check_and_send_back_rr(RTPDemuxContext *s, URLContext *fd, AVIOContext *avio, int count) { @@ -812,6 +830,16 @@ static int rtp_parse_one_packet(RTPDemuxContext *s, AVPacket *pkt, return rtcp_parse_packet(s, buf, len); } + if (s->st) { + int64_t received = av_gettime(); + uint32_t arrival_ts = av_rescale_q(received, AV_TIME_BASE_Q, + s->st->time_base); + timestamp = AV_RB32(buf + 4); + // Calculate the jitter immediately, before queueing the packet + // into the reordering queue. + rtcp_update_jitter(&s->statistics, timestamp, arrival_ts); + } + if ((s->seq == 0 && !s->queue) || s->queue_size <= 1) { /* First packet, or no reordering */ return rtp_parse_packet_internal(s, pkt, buf, len);