OLD | NEW |
1 /* | 1 /* |
2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. | 2 * Copyright (c) 2016 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 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 | 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 | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
11 #ifndef WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ | 11 #ifndef WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ |
12 #define WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ | 12 #define WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ |
13 | 13 |
14 #include <map> | 14 #include <map> |
15 | 15 |
16 #include "webrtc/base/optional.h" | 16 #include "webrtc/base/optional.h" |
17 #include "webrtc/modules/include/module_common_types.h" | 17 #include "webrtc/modules/include/module_common_types.h" |
18 | 18 |
19 namespace webrtc { | 19 namespace webrtc { |
20 | 20 |
21 namespace rtcp { | 21 namespace rtcp { |
22 class TransportFeedbackInterface; | 22 class TransportFeedbackInterface; |
23 } | 23 } |
24 | 24 |
25 class TransportFeedbackPacketLossTracker final { | 25 class TransportFeedbackPacketLossTracker final { |
26 public: | 26 public: |
27 // Up to |max_window_size| latest packet statuses wil be used for calculating | 27 // Up to |max_window_size| latest packet statuses wil be used for calculating |
28 // the packet loss metrics. When less than |min_window_size| samples are | 28 // the packet loss metrics. When less than |min_window_size| samples are |
29 // available for making a reliable estimation, GetPacketLossRates() will | 29 // available for making a reliable estimation, neither PLR nor RPLR would |
30 // return false to indicate packet loss metrics are not ready. | 30 // be considered validly computable. |
| 31 // When |min_pairs_num_for_rplr| pairs or more are available, RPLR is reliably |
| 32 // computable. This is independent of PLR being computable. |
31 TransportFeedbackPacketLossTracker(size_t min_window_size, | 33 TransportFeedbackPacketLossTracker(size_t min_window_size, |
32 size_t max_window_size); | 34 size_t max_window_size, |
| 35 size_t min_pairs_num_for_rplr); |
33 | 36 |
34 void OnReceivedTransportFeedback( | 37 void OnReceivedTransportFeedback( |
35 const rtcp::TransportFeedbackInterface& feedback); | 38 const rtcp::TransportFeedbackInterface& feedback); |
36 | 39 |
37 // Returns true if packet loss rate and packet loss episode duration are ready | 40 // Returns the packet loss rate, if the window has enough data to |
38 // and assigns respective values to |*packet_loss_rate| and | 41 // reliably compute it. |
39 // |*consecutive_packet_loss_rate|. Continuous packet loss rate is defined as | 42 rtc::Optional<float> GetPacketLossRate() const; |
40 // the probability of losing two adjacent packets. | 43 |
41 bool GetPacketLossRates(float* packet_loss_rate, | 44 // Returns the first-order-FEC recoverable packet loss rate, if the window |
42 float* consecutive_packet_loss_rate) const; | 45 // has enough data to reliably compute it. |
| 46 rtc::Optional<float> GetRecoverablePacketLossRate() const; |
43 | 47 |
44 // Verifies that the internal states are correct. Only used for tests. | 48 // Verifies that the internal states are correct. Only used for tests. |
45 void Validate() const; | 49 void Validate() const; |
46 | 50 |
47 private: | 51 private: |
48 // PacketStatus is a map from sequence number to a boolean. The boolean is | 52 // PacketStatus is a map from sequence number to a boolean. The boolean is |
49 // true if it is received. | 53 // true if it is received. |
50 typedef std::map<uint16_t, bool> PacketStatus; | 54 typedef std::map<uint16_t, bool> PacketStatus; |
51 typedef PacketStatus::const_iterator PacketStatusIterator; | 55 typedef PacketStatus::const_iterator PacketStatusIterator; |
52 | 56 |
53 void Reset(); | 57 void Reset(); |
54 // ReferenceSequenceNumber() provides a sequence number that defines the | 58 // ReferenceSequenceNumber() provides a sequence number that defines the |
55 // order of packet reception info stored in |packet_status_window_|. In | 59 // order of packet reception info stored in |packet_status_window_|. In |
56 // particular, given any sequence number |x|, | 60 // particular, given any sequence number |x|, |
57 // (2^16 + x - ref_seq_num_) % 2^16 defines its actual position in | 61 // (2^16 + x - ref_seq_num_) % 2^16 defines its actual position in |
58 // |packet_status_window_|. | 62 // |packet_status_window_|. |
59 uint16_t ReferenceSequenceNumber() const; | 63 uint16_t ReferenceSequenceNumber() const; |
60 bool IsOldSequenceNumber(uint16_t seq_num) const; | 64 bool IsOldSequenceNumber(uint16_t seq_num) const; |
61 void InsertPacketStatus(uint16_t seq_num, bool received); | 65 void InsertPacketStatus(uint16_t seq_num, bool received); |
62 void RemoveOldestPacketStatus(); | 66 void RemoveOldestPacketStatus(); |
63 void ApplyPacketStatus(PacketStatusIterator it); | 67 void ApplyPacketStatus(PacketStatusIterator it); |
64 void UndoPacketStatus(PacketStatusIterator it); | 68 void UndoPacketStatus(PacketStatusIterator it); |
65 PacketStatusIterator PreviousPacketStatus(PacketStatusIterator it); | 69 PacketStatusIterator PreviousPacketStatus(PacketStatusIterator it); |
66 PacketStatusIterator NextPacketStatus(PacketStatusIterator it); | 70 PacketStatusIterator NextPacketStatus(PacketStatusIterator it); |
67 | 71 |
68 const size_t min_window_size_; | 72 const size_t min_window_size_; |
69 const size_t max_window_size_; | 73 const size_t max_window_size_; |
| 74 const size_t min_pairs_num_for_rplr_; |
70 | 75 |
71 PacketStatus packet_status_window_; | 76 PacketStatus packet_status_window_; |
72 // |ref_packet_status_| points to the oldest item in |packet_status_window_|. | 77 // |ref_packet_status_| points to the oldest item in |packet_status_window_|. |
73 PacketStatusIterator ref_packet_status_; | 78 PacketStatusIterator ref_packet_status_; |
74 | 79 |
75 size_t num_received_packets_; | 80 size_t num_received_packets_; |
76 size_t num_lost_packets_; | 81 size_t num_lost_packets_; |
77 size_t num_consecutive_losses_; | 82 size_t num_known_status_pairs_; |
78 size_t num_consecutive_old_reports_; | 83 size_t num_loss_followed_by_reception_pairs_; |
| 84 size_t num_consecutive_old_reports_; // TODO(eladalon): Upcoming CL removes. |
79 }; | 85 }; |
80 | 86 |
81 } // namespace webrtc | 87 } // namespace webrtc |
82 | 88 |
83 #endif // WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ | 89 #endif // WEBRTC_VOICE_ENGINE_TRANSPORT_FEEDBACK_PACKET_LOSS_TRACKER_H_ |
OLD | NEW |