Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(649)

Side by Side Diff: webrtc/voice_engine/transport_feedback_packet_loss_tracker.h

Issue 2629883003: First-order-FEC recoverability calculation (Closed)
Patch Set: nit Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698