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

Unified Diff: net/quic/quic_connection_logger.cc

Issue 1672513002: Expose packet loss counts from QUIC to NetworkQualityEstimator (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Addressed bengr comments, Rebased Created 4 years, 10 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 side-by-side diff with in-line comments
Download patch
« no previous file with comments | « net/quic/quic_connection_logger.h ('k') | net/quic/quic_connection_logger_unittest.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: net/quic/quic_connection_logger.cc
diff --git a/net/quic/quic_connection_logger.cc b/net/quic/quic_connection_logger.cc
index 96c6425d1620b7a379cc1f8b69126682ce979da2..f3858e20260aae0d41a33599fe025d6f212cdf74 100644
--- a/net/quic/quic_connection_logger.cc
+++ b/net/quic/quic_connection_logger.cc
@@ -503,6 +503,9 @@ void QuicConnectionLogger::OnProtocolVersionMismatch(
void QuicConnectionLogger::OnPacketHeader(const QuicPacketHeader& header) {
net_log_.AddEvent(NetLog::TYPE_QUIC_SESSION_PACKET_AUTHENTICATED);
++num_packets_received_;
+
+ const QuicPacketCount previous_largest_received_packet_number =
+ largest_received_packet_number_;
if (largest_received_packet_number_ < header.packet_number) {
QuicPacketNumber delta =
header.packet_number - largest_received_packet_number_;
@@ -528,6 +531,40 @@ void QuicConnectionLogger::OnPacketHeader(const QuicPacketHeader& header) {
header.packet_number));
}
last_received_packet_number_ = header.packet_number;
+ ReportPacketCounts(previous_largest_received_packet_number);
+}
+
+void QuicConnectionLogger::ReportPacketCounts(
+ QuicPacketCount previous_largest_received_packet_number) const {
+ DCHECK_GE(largest_received_packet_number_,
+ previous_largest_received_packet_number);
+ if (!socket_performance_watcher_)
+ return;
+
+ size_t packets_lost = 0;
+ size_t packets_received_in_order = 0;
+ size_t packets_received_out_of_order = 0;
+
+ const size_t diff =
+ largest_received_packet_number_ - previous_largest_received_packet_number;
+
+ if (diff == 0) {
+ // The received packet number has a lower sequence number than the expected
+ // sequence number.
+ packets_received_out_of_order = 1;
+ } else if (diff == 1) {
+ // The received packet number has the same sequence number as the expected
+ // sequence number.
+ packets_received_in_order = 1;
+ } else {
+ // The received packet number has higher sequence number as the expected
+ // sequence number. Report all packets with intermediate sequence numbers
+ // as lost.
+ packets_lost = diff - 1;
Ryan Hamilton 2016/03/01 18:20:32 This is a very aggressive definition of loss. Reor
tbansal1 2016/03/01 19:05:36 This API also reports p_r_out_of_order count. So,
Ryan Hamilton 2016/03/02 04:26:49 If you have a variable called "packets_lost" but i
tbansal1 2016/03/03 02:39:05 I will change the name, and send out the CL. In th
Ryan Hamilton 2016/03/03 04:24:24 The receiver will see packets 1, 2, ... 100, 500,
tbansal1 2016/03/03 23:34:46 Done.
+ packets_received_in_order = 1;
+ }
+ socket_performance_watcher_->OnUpdatedPacketCountAvailable(
+ packets_lost, packets_received_in_order, packets_received_out_of_order);
}
void QuicConnectionLogger::OnStreamFrame(const QuicStreamFrame& frame) {
@@ -775,8 +812,8 @@ void QuicConnectionLogger::AddTo21CumulativeHistogram(
float QuicConnectionLogger::ReceivedPacketLossRate() const {
if (largest_received_packet_number_ <= num_packets_received_)
return 0.0f;
- float num_received = largest_received_packet_number_ - num_packets_received_;
- return num_received / largest_received_packet_number_;
+ float num_lost = largest_received_packet_number_ - num_packets_received_;
+ return num_lost / largest_received_packet_number_;
}
void QuicConnectionLogger::OnRttChanged(QuicTime::Delta rtt) const {
« no previous file with comments | « net/quic/quic_connection_logger.h ('k') | net/quic/quic_connection_logger_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698