asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (c) 2014 The WebRTC project authors. All Rights Reserved. |
| 3 | * |
| 4 | * Use of this source code is governed by a BSD-style license |
| 5 | * that can be found in the LICENSE file in the root of the source |
| 6 | * tree. An additional intellectual property rights grant can be found |
| 7 | * in the file PATENTS. All contributing project authors may |
| 8 | * be found in the AUTHORS file in the root of the source tree. |
| 9 | */ |
| 10 | |
Mirko Bonadei | 92ea95e | 2017-09-15 06:47:31 +0200 | [diff] [blame] | 11 | #include "video/report_block_stats.h" |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 12 | |
| 13 | namespace webrtc { |
| 14 | |
| 15 | namespace { |
| 16 | int FractionLost(uint32_t num_lost_sequence_numbers, |
| 17 | uint32_t num_sequence_numbers) { |
| 18 | if (num_sequence_numbers == 0) { |
| 19 | return 0; |
| 20 | } |
| 21 | return ((num_lost_sequence_numbers * 255) + (num_sequence_numbers / 2)) / |
| 22 | num_sequence_numbers; |
| 23 | } |
| 24 | } // namespace |
| 25 | |
| 26 | |
| 27 | // Helper class for rtcp statistics. |
| 28 | ReportBlockStats::ReportBlockStats() |
| 29 | : num_sequence_numbers_(0), |
| 30 | num_lost_sequence_numbers_(0) { |
| 31 | } |
| 32 | |
| 33 | void ReportBlockStats::Store(const RtcpStatistics& rtcp_stats, |
| 34 | uint32_t remote_ssrc, |
| 35 | uint32_t source_ssrc) { |
| 36 | RTCPReportBlock block; |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 37 | block.packets_lost = rtcp_stats.packets_lost; |
| 38 | block.fraction_lost = rtcp_stats.fraction_lost; |
| 39 | block.extended_highest_sequence_number = |
| 40 | rtcp_stats.extended_highest_sequence_number; |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 41 | block.jitter = rtcp_stats.jitter; |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 42 | block.sender_ssrc = remote_ssrc; |
| 43 | block.source_ssrc = source_ssrc; |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 44 | uint32_t num_sequence_numbers = 0; |
| 45 | uint32_t num_lost_sequence_numbers = 0; |
| 46 | StoreAndAddPacketIncrement( |
| 47 | block, &num_sequence_numbers, &num_lost_sequence_numbers); |
| 48 | } |
| 49 | |
| 50 | RTCPReportBlock ReportBlockStats::AggregateAndStore( |
| 51 | const ReportBlockVector& report_blocks) { |
| 52 | RTCPReportBlock aggregate; |
| 53 | if (report_blocks.empty()) { |
| 54 | return aggregate; |
| 55 | } |
| 56 | uint32_t num_sequence_numbers = 0; |
| 57 | uint32_t num_lost_sequence_numbers = 0; |
| 58 | ReportBlockVector::const_iterator report_block = report_blocks.begin(); |
| 59 | for (; report_block != report_blocks.end(); ++report_block) { |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 60 | aggregate.packets_lost += report_block->packets_lost; |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 61 | aggregate.jitter += report_block->jitter; |
| 62 | StoreAndAddPacketIncrement(*report_block, |
| 63 | &num_sequence_numbers, |
| 64 | &num_lost_sequence_numbers); |
| 65 | } |
| 66 | |
| 67 | if (report_blocks.size() == 1) { |
| 68 | // No aggregation needed. |
| 69 | return report_blocks[0]; |
| 70 | } |
| 71 | // Fraction lost since previous report block. |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 72 | aggregate.fraction_lost = |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 73 | FractionLost(num_lost_sequence_numbers, num_sequence_numbers); |
Peter Boström | ae37abb | 2015-06-18 19:00:34 +0200 | [diff] [blame] | 74 | aggregate.jitter = static_cast<uint32_t>( |
| 75 | (aggregate.jitter + report_blocks.size() / 2) / report_blocks.size()); |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 76 | return aggregate; |
| 77 | } |
| 78 | |
| 79 | void ReportBlockStats::StoreAndAddPacketIncrement( |
| 80 | const RTCPReportBlock& report_block, |
| 81 | uint32_t* num_sequence_numbers, |
| 82 | uint32_t* num_lost_sequence_numbers) { |
| 83 | // Get diff with previous report block. |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 84 | ReportBlockMap::iterator prev_report_block = |
| 85 | prev_report_blocks_.find(report_block.source_ssrc); |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 86 | if (prev_report_block != prev_report_blocks_.end()) { |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 87 | int seq_num_diff = |
| 88 | report_block.extended_highest_sequence_number - |
| 89 | prev_report_block->second.extended_highest_sequence_number; |
| 90 | int cum_loss_diff = |
| 91 | report_block.packets_lost - prev_report_block->second.packets_lost; |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 92 | if (seq_num_diff >= 0 && cum_loss_diff >= 0) { |
| 93 | *num_sequence_numbers += seq_num_diff; |
| 94 | *num_lost_sequence_numbers += cum_loss_diff; |
| 95 | // Update total number of packets/lost packets. |
| 96 | num_sequence_numbers_ += seq_num_diff; |
| 97 | num_lost_sequence_numbers_ += cum_loss_diff; |
| 98 | } |
| 99 | } |
| 100 | // Store current report block. |
srte | 3e69e5c | 2017-08-09 06:13:45 -0700 | [diff] [blame] | 101 | prev_report_blocks_[report_block.source_ssrc] = report_block; |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 102 | } |
| 103 | |
| 104 | int ReportBlockStats::FractionLostInPercent() const { |
asapersson@webrtc.org | e7358ea | 2015-01-21 09:00:19 +0000 | [diff] [blame] | 105 | if (num_sequence_numbers_ == 0) { |
| 106 | return -1; |
| 107 | } |
asapersson@webrtc.org | 823c9b8 | 2015-01-08 07:50:56 +0000 | [diff] [blame] | 108 | return FractionLost( |
| 109 | num_lost_sequence_numbers_, num_sequence_numbers_) * 100 / 255; |
| 110 | } |
| 111 | |
| 112 | } // namespace webrtc |
| 113 | |