quic_connection_logger.cc 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609
  1. // Copyright (c) 2013 The Chromium Authors. All rights reserved.
  2. // Use of this source code is governed by a BSD-style license that can be
  3. // found in the LICENSE file.
  4. #include "net/quic/quic_connection_logger.h"
  5. #include <algorithm>
  6. #include <limits>
  7. #include <memory>
  8. #include <utility>
  9. #include <vector>
  10. #include "base/metrics/histogram_base.h"
  11. #include "base/metrics/histogram_functions.h"
  12. #include "base/metrics/histogram_macros.h"
  13. #include "base/values.h"
  14. #include "net/base/ip_address.h"
  15. #include "net/cert/x509_certificate.h"
  16. #include "net/quic/address_utils.h"
  17. #include "net/quic/quic_address_mismatch.h"
  18. #include "net/third_party/quiche/src/quiche/quic/core/crypto/crypto_handshake_message.h"
  19. #include "net/third_party/quiche/src/quiche/quic/core/crypto/crypto_protocol.h"
  20. #include "net/third_party/quiche/src/quiche/quic/core/quic_connection_id.h"
  21. #include "net/third_party/quiche/src/quiche/quic/core/quic_packets.h"
  22. #include "net/third_party/quiche/src/quiche/quic/core/quic_socket_address_coder.h"
  23. #include "net/third_party/quiche/src/quiche/quic/core/quic_time.h"
  24. #include "net/third_party/quiche/src/quiche/quic/core/quic_utils.h"
  25. using quic::kMaxOutgoingPacketSize;
  26. using std::string;
  27. namespace net {
  28. namespace {
  29. void UpdatePublicResetAddressMismatchHistogram(
  30. const IPEndPoint& server_hello_address,
  31. const IPEndPoint& public_reset_address) {
  32. int sample = GetAddressMismatch(server_hello_address, public_reset_address);
  33. // We are seemingly talking to an older server that does not support the
  34. // feature, so we can't report the results in the histogram.
  35. if (sample < 0) {
  36. return;
  37. }
  38. UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.PublicResetAddressMismatch2",
  39. static_cast<QuicAddressMismatch>(sample),
  40. QUIC_ADDRESS_MISMATCH_MAX);
  41. }
  42. // If |address| is an IPv4-mapped IPv6 address, returns ADDRESS_FAMILY_IPV4
  43. // instead of ADDRESS_FAMILY_IPV6. Othewise, behaves like GetAddressFamily().
  44. AddressFamily GetRealAddressFamily(const IPAddress& address) {
  45. return address.IsIPv4MappedIPv6() ? ADDRESS_FAMILY_IPV4
  46. : GetAddressFamily(address);
  47. }
  48. } // namespace
  49. QuicConnectionLogger::QuicConnectionLogger(
  50. quic::QuicSession* session,
  51. const char* const connection_description,
  52. std::unique_ptr<SocketPerformanceWatcher> socket_performance_watcher,
  53. const NetLogWithSource& net_log)
  54. : session_(session),
  55. connection_description_(connection_description),
  56. socket_performance_watcher_(std::move(socket_performance_watcher)),
  57. event_logger_(session, net_log) {}
  58. QuicConnectionLogger::~QuicConnectionLogger() {
  59. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.OutOfOrderPacketsReceived",
  60. num_out_of_order_received_packets_);
  61. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.OutOfOrderLargePacketsReceived",
  62. num_out_of_order_large_received_packets_);
  63. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.IncorrectConnectionIDsReceived",
  64. num_incorrect_connection_ids_);
  65. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.UndecryptablePacketsReceived",
  66. num_undecryptable_packets_);
  67. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.DuplicatePacketsReceived",
  68. num_duplicate_packets_);
  69. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.BlockedFrames.Received",
  70. num_blocked_frames_received_);
  71. UMA_HISTOGRAM_COUNTS_1M("Net.QuicSession.BlockedFrames.Sent",
  72. num_blocked_frames_sent_);
  73. const quic::QuicConnectionStats& stats = session_->connection()->GetStats();
  74. UMA_HISTOGRAM_TIMES("Net.QuicSession.MinRTT",
  75. base::Microseconds(stats.min_rtt_us));
  76. UMA_HISTOGRAM_TIMES("Net.QuicSession.SmoothedRTT",
  77. base::Microseconds(stats.srtt_us));
  78. if (num_frames_received_ > 0) {
  79. int duplicate_stream_frame_per_thousand =
  80. num_duplicate_frames_received_ * 1000 / num_frames_received_;
  81. if (num_packets_received_ < 100) {
  82. UMA_HISTOGRAM_CUSTOM_COUNTS(
  83. "Net.QuicSession.StreamFrameDuplicatedShortConnection",
  84. duplicate_stream_frame_per_thousand, 1, 1000, 75);
  85. } else {
  86. UMA_HISTOGRAM_CUSTOM_COUNTS(
  87. "Net.QuicSession.StreamFrameDuplicatedLongConnection",
  88. duplicate_stream_frame_per_thousand, 1, 1000, 75);
  89. }
  90. }
  91. RecordAggregatePacketLossRate();
  92. }
  93. void QuicConnectionLogger::OnFrameAddedToPacket(const quic::QuicFrame& frame) {
  94. switch (frame.type) {
  95. case quic::PADDING_FRAME:
  96. break;
  97. case quic::STREAM_FRAME:
  98. break;
  99. case quic::ACK_FRAME: {
  100. break;
  101. }
  102. case quic::RST_STREAM_FRAME:
  103. base::UmaHistogramSparse("Net.QuicSession.RstStreamErrorCodeClient",
  104. frame.rst_stream_frame->error_code);
  105. break;
  106. case quic::CONNECTION_CLOSE_FRAME:
  107. break;
  108. case quic::GOAWAY_FRAME:
  109. break;
  110. case quic::WINDOW_UPDATE_FRAME:
  111. break;
  112. case quic::BLOCKED_FRAME:
  113. ++num_blocked_frames_sent_;
  114. break;
  115. case quic::STOP_WAITING_FRAME:
  116. break;
  117. case quic::PING_FRAME:
  118. UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.ConnectionFlowControlBlocked",
  119. session_->IsConnectionFlowControlBlocked());
  120. UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.StreamFlowControlBlocked",
  121. session_->IsStreamFlowControlBlocked());
  122. break;
  123. case quic::MTU_DISCOVERY_FRAME:
  124. break;
  125. case quic::NEW_CONNECTION_ID_FRAME:
  126. break;
  127. case quic::MAX_STREAMS_FRAME:
  128. break;
  129. case quic::STREAMS_BLOCKED_FRAME:
  130. break;
  131. case quic::PATH_RESPONSE_FRAME:
  132. break;
  133. case quic::PATH_CHALLENGE_FRAME:
  134. break;
  135. case quic::STOP_SENDING_FRAME:
  136. base::UmaHistogramSparse("Net.QuicSession.StopSendingErrorCodeClient",
  137. frame.stop_sending_frame.error_code);
  138. break;
  139. case quic::MESSAGE_FRAME:
  140. break;
  141. case quic::CRYPTO_FRAME:
  142. break;
  143. case quic::NEW_TOKEN_FRAME:
  144. break;
  145. case quic::RETIRE_CONNECTION_ID_FRAME:
  146. break;
  147. default:
  148. DCHECK(false) << "Illegal frame type: " << frame.type;
  149. }
  150. event_logger_.OnFrameAddedToPacket(frame);
  151. }
  152. void QuicConnectionLogger::OnStreamFrameCoalesced(
  153. const quic::QuicStreamFrame& frame) {
  154. event_logger_.OnStreamFrameCoalesced(frame);
  155. }
  156. void QuicConnectionLogger::OnPacketSent(
  157. quic::QuicPacketNumber packet_number,
  158. quic::QuicPacketLength packet_length,
  159. bool has_crypto_handshake,
  160. quic::TransmissionType transmission_type,
  161. quic::EncryptionLevel encryption_level,
  162. const quic::QuicFrames& retransmittable_frames,
  163. const quic::QuicFrames& nonretransmittable_frames,
  164. quic::QuicTime sent_time) {
  165. // 4.4.1.4. Minimum Packet Size
  166. // The payload of a UDP datagram carrying the Initial packet MUST be
  167. // expanded to at least 1200 octets
  168. const quic::QuicPacketLength kMinClientInitialPacketLength = 1200;
  169. switch (encryption_level) {
  170. case quic::ENCRYPTION_INITIAL:
  171. UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.SendPacketSize.Initial",
  172. packet_length, 1, kMaxOutgoingPacketSize, 50);
  173. if (packet_length < kMinClientInitialPacketLength) {
  174. UMA_HISTOGRAM_CUSTOM_COUNTS(
  175. "Net.QuicSession.TooSmallInitialSentPacket",
  176. kMinClientInitialPacketLength - packet_length, 1,
  177. kMinClientInitialPacketLength, 50);
  178. }
  179. break;
  180. case quic::ENCRYPTION_HANDSHAKE:
  181. UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.SendPacketSize.Hanshake",
  182. packet_length, 1, kMaxOutgoingPacketSize, 50);
  183. break;
  184. case quic::ENCRYPTION_ZERO_RTT:
  185. UMA_HISTOGRAM_CUSTOM_COUNTS("Net.QuicSession.SendPacketSize.0RTT",
  186. packet_length, 1, kMaxOutgoingPacketSize, 50);
  187. break;
  188. case quic::ENCRYPTION_FORWARD_SECURE:
  189. UMA_HISTOGRAM_CUSTOM_COUNTS(
  190. "Net.QuicSession.SendPacketSize.ForwardSecure", packet_length, 1,
  191. kMaxOutgoingPacketSize, 50);
  192. break;
  193. case quic::NUM_ENCRYPTION_LEVELS:
  194. NOTREACHED();
  195. break;
  196. }
  197. event_logger_.OnPacketSent(packet_number, packet_length, has_crypto_handshake,
  198. transmission_type, encryption_level,
  199. retransmittable_frames, nonretransmittable_frames,
  200. sent_time);
  201. }
  202. void QuicConnectionLogger::OnPacketLoss(
  203. quic::QuicPacketNumber lost_packet_number,
  204. quic::EncryptionLevel encryption_level,
  205. quic::TransmissionType transmission_type,
  206. quic::QuicTime detection_time) {
  207. event_logger_.OnPacketLoss(lost_packet_number, encryption_level,
  208. transmission_type, detection_time);
  209. }
  210. void QuicConnectionLogger::OnPingSent() {
  211. no_packet_received_after_ping_ = true;
  212. }
  213. void QuicConnectionLogger::OnPacketReceived(
  214. const quic::QuicSocketAddress& self_address,
  215. const quic::QuicSocketAddress& peer_address,
  216. const quic::QuicEncryptedPacket& packet) {
  217. if (local_address_from_self_.GetFamily() == ADDRESS_FAMILY_UNSPECIFIED) {
  218. local_address_from_self_ = ToIPEndPoint(self_address);
  219. UMA_HISTOGRAM_ENUMERATION(
  220. "Net.QuicSession.ConnectionTypeFromSelf",
  221. GetRealAddressFamily(ToIPEndPoint(self_address).address()),
  222. ADDRESS_FAMILY_LAST);
  223. }
  224. previous_received_packet_size_ = last_received_packet_size_;
  225. last_received_packet_size_ = packet.length();
  226. event_logger_.OnPacketReceived(self_address, peer_address, packet);
  227. }
  228. void QuicConnectionLogger::OnUnauthenticatedHeader(
  229. const quic::QuicPacketHeader& header) {
  230. event_logger_.OnUnauthenticatedHeader(header);
  231. }
  232. void QuicConnectionLogger::OnIncorrectConnectionId(
  233. quic::QuicConnectionId connection_id) {
  234. ++num_incorrect_connection_ids_;
  235. }
  236. void QuicConnectionLogger::OnUndecryptablePacket(
  237. quic::EncryptionLevel decryption_level,
  238. bool dropped) {
  239. ++num_undecryptable_packets_;
  240. event_logger_.OnUndecryptablePacket(decryption_level, dropped);
  241. }
  242. void QuicConnectionLogger::OnAttemptingToProcessUndecryptablePacket(
  243. quic::EncryptionLevel decryption_level) {
  244. event_logger_.OnAttemptingToProcessUndecryptablePacket(decryption_level);
  245. }
  246. void QuicConnectionLogger::OnDuplicatePacket(
  247. quic::QuicPacketNumber packet_number) {
  248. ++num_duplicate_packets_;
  249. event_logger_.OnDuplicatePacket(packet_number);
  250. }
  251. void QuicConnectionLogger::OnProtocolVersionMismatch(
  252. quic::ParsedQuicVersion received_version) {
  253. // TODO(rtenneti): Add logging.
  254. }
  255. void QuicConnectionLogger::OnPacketHeader(const quic::QuicPacketHeader& header,
  256. quic::QuicTime receive_time,
  257. quic::EncryptionLevel level) {
  258. if (!first_received_packet_number_.IsInitialized()) {
  259. first_received_packet_number_ = header.packet_number;
  260. } else if (header.packet_number < first_received_packet_number_) {
  261. // Ignore packets with packet numbers less than
  262. // first_received_packet_number_.
  263. return;
  264. }
  265. ++num_packets_received_;
  266. if (!largest_received_packet_number_.IsInitialized()) {
  267. largest_received_packet_number_ = header.packet_number;
  268. } else if (largest_received_packet_number_ < header.packet_number) {
  269. uint64_t delta = header.packet_number - largest_received_packet_number_;
  270. if (delta > 1) {
  271. // There is a gap between the largest packet previously received and
  272. // the current packet. This indicates either loss, or out-of-order
  273. // delivery.
  274. UMA_HISTOGRAM_COUNTS_1M(
  275. "Net.QuicSession.PacketGapReceived",
  276. static_cast<base::HistogramBase::Sample>(delta - 1));
  277. }
  278. largest_received_packet_number_ = header.packet_number;
  279. }
  280. if (header.packet_number - first_received_packet_number_ <
  281. received_packets_.size()) {
  282. received_packets_[header.packet_number - first_received_packet_number_] =
  283. true;
  284. }
  285. if (last_received_packet_number_.IsInitialized() &&
  286. header.packet_number < last_received_packet_number_) {
  287. ++num_out_of_order_received_packets_;
  288. if (previous_received_packet_size_ < last_received_packet_size_)
  289. ++num_out_of_order_large_received_packets_;
  290. UMA_HISTOGRAM_COUNTS_1M(
  291. "Net.QuicSession.OutOfOrderGapReceived",
  292. static_cast<base::HistogramBase::Sample>(last_received_packet_number_ -
  293. header.packet_number));
  294. } else if (no_packet_received_after_ping_) {
  295. if (last_received_packet_number_.IsInitialized()) {
  296. UMA_HISTOGRAM_COUNTS_1M(
  297. "Net.QuicSession.PacketGapReceivedNearPing",
  298. static_cast<base::HistogramBase::Sample>(
  299. header.packet_number - last_received_packet_number_));
  300. }
  301. no_packet_received_after_ping_ = false;
  302. }
  303. last_received_packet_number_ = header.packet_number;
  304. event_logger_.OnPacketHeader(header, receive_time, level);
  305. }
  306. void QuicConnectionLogger::OnStreamFrame(const quic::QuicStreamFrame& frame) {
  307. event_logger_.OnStreamFrame(frame);
  308. }
  309. void QuicConnectionLogger::OnPathChallengeFrame(
  310. const quic::QuicPathChallengeFrame& frame) {
  311. event_logger_.OnPathChallengeFrame(frame);
  312. }
  313. void QuicConnectionLogger::OnPathResponseFrame(
  314. const quic::QuicPathResponseFrame& frame) {
  315. event_logger_.OnPathResponseFrame(frame);
  316. }
  317. void QuicConnectionLogger::OnCryptoFrame(const quic::QuicCryptoFrame& frame) {
  318. event_logger_.OnCryptoFrame(frame);
  319. }
  320. void QuicConnectionLogger::OnStopSendingFrame(
  321. const quic::QuicStopSendingFrame& frame) {
  322. base::UmaHistogramSparse("Net.QuicSession.StopSendingErrorCodeServer",
  323. frame.error_code);
  324. event_logger_.OnStopSendingFrame(frame);
  325. }
  326. void QuicConnectionLogger::OnStreamsBlockedFrame(
  327. const quic::QuicStreamsBlockedFrame& frame) {
  328. event_logger_.OnStreamsBlockedFrame(frame);
  329. }
  330. void QuicConnectionLogger::OnMaxStreamsFrame(
  331. const quic::QuicMaxStreamsFrame& frame) {
  332. event_logger_.OnMaxStreamsFrame(frame);
  333. }
  334. void QuicConnectionLogger::OnIncomingAck(
  335. quic::QuicPacketNumber ack_packet_number,
  336. quic::EncryptionLevel ack_decrypted_level,
  337. const quic::QuicAckFrame& frame,
  338. quic::QuicTime ack_receive_time,
  339. quic::QuicPacketNumber largest_observed,
  340. bool rtt_updated,
  341. quic::QuicPacketNumber least_unacked_sent_packet) {
  342. const size_t kApproximateLargestSoloAckBytes = 100;
  343. if (last_received_packet_number_ - first_received_packet_number_ <
  344. received_acks_.size() &&
  345. last_received_packet_size_ < kApproximateLargestSoloAckBytes) {
  346. received_acks_[last_received_packet_number_ -
  347. first_received_packet_number_] = true;
  348. }
  349. event_logger_.OnIncomingAck(ack_packet_number, ack_decrypted_level, frame,
  350. ack_receive_time, largest_observed, rtt_updated,
  351. least_unacked_sent_packet);
  352. }
  353. void QuicConnectionLogger::OnStopWaitingFrame(
  354. const quic::QuicStopWaitingFrame& frame) {
  355. event_logger_.OnStopWaitingFrame(frame);
  356. }
  357. void QuicConnectionLogger::OnRstStreamFrame(
  358. const quic::QuicRstStreamFrame& frame) {
  359. base::UmaHistogramSparse("Net.QuicSession.RstStreamErrorCodeServer",
  360. frame.error_code);
  361. event_logger_.OnRstStreamFrame(frame);
  362. }
  363. void QuicConnectionLogger::OnConnectionCloseFrame(
  364. const quic::QuicConnectionCloseFrame& frame) {
  365. event_logger_.OnConnectionCloseFrame(frame);
  366. }
  367. void QuicConnectionLogger::OnWindowUpdateFrame(
  368. const quic::QuicWindowUpdateFrame& frame,
  369. const quic::QuicTime& receive_time) {
  370. event_logger_.OnWindowUpdateFrame(frame, receive_time);
  371. }
  372. void QuicConnectionLogger::OnBlockedFrame(const quic::QuicBlockedFrame& frame) {
  373. ++num_blocked_frames_received_;
  374. event_logger_.OnBlockedFrame(frame);
  375. }
  376. void QuicConnectionLogger::OnGoAwayFrame(const quic::QuicGoAwayFrame& frame) {
  377. UMA_HISTOGRAM_BOOLEAN("Net.QuicSession.GoAwayReceivedForConnectionMigration",
  378. frame.error_code == quic::QUIC_ERROR_MIGRATING_PORT);
  379. event_logger_.OnGoAwayFrame(frame);
  380. }
  381. void QuicConnectionLogger::OnPingFrame(
  382. const quic::QuicPingFrame& frame,
  383. quic::QuicTime::Delta ping_received_delay) {
  384. event_logger_.OnPingFrame(frame, ping_received_delay);
  385. }
  386. void QuicConnectionLogger::OnPaddingFrame(const quic::QuicPaddingFrame& frame) {
  387. event_logger_.OnPaddingFrame(frame);
  388. }
  389. void QuicConnectionLogger::OnNewConnectionIdFrame(
  390. const quic::QuicNewConnectionIdFrame& frame) {
  391. event_logger_.OnNewConnectionIdFrame(frame);
  392. }
  393. void QuicConnectionLogger::OnNewTokenFrame(
  394. const quic::QuicNewTokenFrame& frame) {
  395. event_logger_.OnNewTokenFrame(frame);
  396. }
  397. void QuicConnectionLogger::OnRetireConnectionIdFrame(
  398. const quic::QuicRetireConnectionIdFrame& frame) {
  399. event_logger_.OnRetireConnectionIdFrame(frame);
  400. }
  401. void QuicConnectionLogger::OnMessageFrame(const quic::QuicMessageFrame& frame) {
  402. event_logger_.OnMessageFrame(frame);
  403. }
  404. void QuicConnectionLogger::OnHandshakeDoneFrame(
  405. const quic::QuicHandshakeDoneFrame& frame) {
  406. event_logger_.OnHandshakeDoneFrame(frame);
  407. }
  408. void QuicConnectionLogger::OnCoalescedPacketSent(
  409. const quic::QuicCoalescedPacket& coalesced_packet,
  410. size_t length) {
  411. event_logger_.OnCoalescedPacketSent(coalesced_packet, length);
  412. }
  413. void QuicConnectionLogger::OnPublicResetPacket(
  414. const quic::QuicPublicResetPacket& packet) {
  415. UpdatePublicResetAddressMismatchHistogram(
  416. local_address_from_shlo_, ToIPEndPoint(packet.client_address));
  417. event_logger_.OnPublicResetPacket(packet);
  418. }
  419. void QuicConnectionLogger::OnVersionNegotiationPacket(
  420. const quic::QuicVersionNegotiationPacket& packet) {
  421. event_logger_.OnVersionNegotiationPacket(packet);
  422. }
  423. void QuicConnectionLogger::OnCryptoHandshakeMessageReceived(
  424. const quic::CryptoHandshakeMessage& message) {
  425. if (message.tag() == quic::kSHLO) {
  426. absl::string_view address;
  427. quic::QuicSocketAddressCoder decoder;
  428. if (message.GetStringPiece(quic::kCADR, &address) &&
  429. decoder.Decode(address.data(), address.size())) {
  430. local_address_from_shlo_ =
  431. IPEndPoint(ToIPAddress(decoder.ip()), decoder.port());
  432. UMA_HISTOGRAM_ENUMERATION(
  433. "Net.QuicSession.ConnectionTypeFromPeer",
  434. GetRealAddressFamily(local_address_from_shlo_.address()),
  435. ADDRESS_FAMILY_LAST);
  436. int sample = GetAddressMismatch(local_address_from_shlo_,
  437. local_address_from_self_);
  438. // We are seemingly talking to an older server that does not support the
  439. // feature, so we can't report the results in the histogram.
  440. if (sample >= 0) {
  441. UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.SelfShloAddressMismatch",
  442. static_cast<QuicAddressMismatch>(sample),
  443. QUIC_ADDRESS_MISMATCH_MAX);
  444. }
  445. }
  446. }
  447. event_logger_.OnCryptoHandshakeMessageReceived(message);
  448. }
  449. void QuicConnectionLogger::OnCryptoHandshakeMessageSent(
  450. const quic::CryptoHandshakeMessage& message) {
  451. event_logger_.OnCryptoHandshakeMessageSent(message);
  452. }
  453. void QuicConnectionLogger::OnConnectionClosed(
  454. const quic::QuicConnectionCloseFrame& frame,
  455. quic::ConnectionCloseSource source) {
  456. event_logger_.OnConnectionClosed(frame, source);
  457. }
  458. void QuicConnectionLogger::OnSuccessfulVersionNegotiation(
  459. const quic::ParsedQuicVersion& version) {
  460. event_logger_.OnSuccessfulVersionNegotiation(version);
  461. }
  462. void QuicConnectionLogger::UpdateReceivedFrameCounts(
  463. quic::QuicStreamId stream_id,
  464. int num_frames_received,
  465. int num_duplicate_frames_received) {
  466. if (!quic::QuicUtils::IsCryptoStreamId(session_->transport_version(),
  467. stream_id)) {
  468. num_frames_received_ += num_frames_received;
  469. num_duplicate_frames_received_ += num_duplicate_frames_received;
  470. }
  471. }
  472. void QuicConnectionLogger::OnCertificateVerified(
  473. const CertVerifyResult& result) {
  474. event_logger_.OnCertificateVerified(result);
  475. }
  476. base::HistogramBase* QuicConnectionLogger::Get6PacketHistogram(
  477. const char* which_6) const {
  478. // This histogram takes a binary encoding of the 6 consecutive packets
  479. // received. As a result, there are 64 possible sample-patterns.
  480. string prefix("Net.QuicSession.6PacketsPatternsReceived_");
  481. return base::LinearHistogram::FactoryGet(
  482. prefix + which_6 + connection_description_, 1, 64, 65,
  483. base::HistogramBase::kUmaTargetedHistogramFlag);
  484. }
  485. float QuicConnectionLogger::ReceivedPacketLossRate() const {
  486. if (!largest_received_packet_number_.IsInitialized())
  487. return 0.0f;
  488. float num_packets =
  489. largest_received_packet_number_ - first_received_packet_number_ + 1;
  490. float num_missing = num_packets - num_packets_received_;
  491. return num_missing / num_packets;
  492. }
  493. void QuicConnectionLogger::OnRttChanged(quic::QuicTime::Delta rtt) const {
  494. // Notify socket performance watcher of the updated RTT value.
  495. if (!socket_performance_watcher_)
  496. return;
  497. int64_t microseconds = rtt.ToMicroseconds();
  498. if (microseconds != 0 &&
  499. socket_performance_watcher_->ShouldNotifyUpdatedRTT()) {
  500. socket_performance_watcher_->OnUpdatedRTTAvailable(
  501. base::Microseconds(rtt.ToMicroseconds()));
  502. }
  503. }
  504. void QuicConnectionLogger::OnTransportParametersSent(
  505. const quic::TransportParameters& transport_parameters) {
  506. event_logger_.OnTransportParametersSent(transport_parameters);
  507. }
  508. void QuicConnectionLogger::OnTransportParametersReceived(
  509. const quic::TransportParameters& transport_parameters) {
  510. event_logger_.OnTransportParametersReceived(transport_parameters);
  511. }
  512. void QuicConnectionLogger::OnTransportParametersResumed(
  513. const quic::TransportParameters& transport_parameters) {
  514. event_logger_.OnTransportParametersResumed(transport_parameters);
  515. }
  516. void QuicConnectionLogger::OnZeroRttRejected(int reason) {
  517. event_logger_.OnZeroRttRejected(reason);
  518. }
  519. void QuicConnectionLogger::RecordAggregatePacketLossRate() const {
  520. // For short connections under 22 packets in length, we'll rely on the
  521. // Net.QuicSession.21CumulativePacketsReceived_* histogram to indicate packet
  522. // loss rates. This way we avoid tremendously anomalous contributions to our
  523. // histogram. (e.g., if we only got 5 packets, but lost 1, we'd otherwise
  524. // record a 20% loss in this histogram!). We may still get some strange data
  525. // (1 loss in 22 is still high :-/).
  526. if (!largest_received_packet_number_.IsInitialized() ||
  527. largest_received_packet_number_ - first_received_packet_number_ < 22)
  528. return;
  529. string prefix("Net.QuicSession.PacketLossRate_");
  530. base::HistogramBase* histogram = base::Histogram::FactoryGet(
  531. prefix + connection_description_, 1, 1000, 75,
  532. base::HistogramBase::kUmaTargetedHistogramFlag);
  533. histogram->Add(static_cast<base::HistogramBase::Sample>(
  534. ReceivedPacketLossRate() * 1000));
  535. }
  536. } // namespace net