| 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 |