| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/quic/quic_connection_logger.h" | 5 #include "net/quic/quic_connection_logger.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <string> | 8 #include <string> |
| 9 #include <utility> | 9 #include <utility> |
| 10 | 10 |
| (...skipping 441 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 452 100); | 452 100); |
| 453 } | 453 } |
| 454 last_packet_sent_time_ = sent_time; | 454 last_packet_sent_time_ = sent_time; |
| 455 } | 455 } |
| 456 | 456 |
| 457 void QuicConnectionLogger::OnPacketReceived(const IPEndPoint& self_address, | 457 void QuicConnectionLogger::OnPacketReceived(const IPEndPoint& self_address, |
| 458 const IPEndPoint& peer_address, | 458 const IPEndPoint& peer_address, |
| 459 const QuicEncryptedPacket& packet) { | 459 const QuicEncryptedPacket& packet) { |
| 460 if (local_address_from_self_.GetFamily() == ADDRESS_FAMILY_UNSPECIFIED) { | 460 if (local_address_from_self_.GetFamily() == ADDRESS_FAMILY_UNSPECIFIED) { |
| 461 local_address_from_self_ = self_address; | 461 local_address_from_self_ = self_address; |
| 462 UMA_HISTOGRAM_ENUMERATION("Net.QuicSession.ConnectionTypeFromSelf", | 462 UMA_HISTOGRAM_ENUMERATION( |
| 463 GetRealAddressFamily(self_address.address()), | 463 "Net.QuicSession.ConnectionTypeFromSelf", |
| 464 ADDRESS_FAMILY_LAST); | 464 GetRealAddressFamily(self_address.address().bytes()), |
| 465 ADDRESS_FAMILY_LAST); |
| 465 } | 466 } |
| 466 | 467 |
| 467 previous_received_packet_size_ = last_received_packet_size_; | 468 previous_received_packet_size_ = last_received_packet_size_; |
| 468 last_received_packet_size_ = packet.length(); | 469 last_received_packet_size_ = packet.length(); |
| 469 net_log_.AddEvent(NetLog::TYPE_QUIC_SESSION_PACKET_RECEIVED, | 470 net_log_.AddEvent(NetLog::TYPE_QUIC_SESSION_PACKET_RECEIVED, |
| 470 base::Bind(&NetLogQuicPacketCallback, &self_address, | 471 base::Bind(&NetLogQuicPacketCallback, &self_address, |
| 471 &peer_address, packet.length())); | 472 &peer_address, packet.length())); |
| 472 } | 473 } |
| 473 | 474 |
| 474 void QuicConnectionLogger::OnUnauthenticatedHeader( | 475 void QuicConnectionLogger::OnUnauthenticatedHeader( |
| (...skipping 178 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 653 base::Bind(&NetLogQuicCryptoHandshakeMessageCallback, &message)); | 654 base::Bind(&NetLogQuicCryptoHandshakeMessageCallback, &message)); |
| 654 | 655 |
| 655 if (message.tag() == kSHLO) { | 656 if (message.tag() == kSHLO) { |
| 656 StringPiece address; | 657 StringPiece address; |
| 657 QuicSocketAddressCoder decoder; | 658 QuicSocketAddressCoder decoder; |
| 658 if (message.GetStringPiece(kCADR, &address) && | 659 if (message.GetStringPiece(kCADR, &address) && |
| 659 decoder.Decode(address.data(), address.size())) { | 660 decoder.Decode(address.data(), address.size())) { |
| 660 local_address_from_shlo_ = IPEndPoint(decoder.ip(), decoder.port()); | 661 local_address_from_shlo_ = IPEndPoint(decoder.ip(), decoder.port()); |
| 661 UMA_HISTOGRAM_ENUMERATION( | 662 UMA_HISTOGRAM_ENUMERATION( |
| 662 "Net.QuicSession.ConnectionTypeFromPeer", | 663 "Net.QuicSession.ConnectionTypeFromPeer", |
| 663 GetRealAddressFamily(local_address_from_shlo_.address()), | 664 GetRealAddressFamily(local_address_from_shlo_.address().bytes()), |
| 664 ADDRESS_FAMILY_LAST); | 665 ADDRESS_FAMILY_LAST); |
| 665 } | 666 } |
| 666 } | 667 } |
| 667 } | 668 } |
| 668 | 669 |
| 669 void QuicConnectionLogger::OnCryptoHandshakeMessageSent( | 670 void QuicConnectionLogger::OnCryptoHandshakeMessageSent( |
| 670 const CryptoHandshakeMessage& message) { | 671 const CryptoHandshakeMessage& message) { |
| 671 net_log_.AddEvent( | 672 net_log_.AddEvent( |
| 672 NetLog::TYPE_QUIC_SESSION_CRYPTO_HANDSHAKE_MESSAGE_SENT, | 673 NetLog::TYPE_QUIC_SESSION_CRYPTO_HANDSHAKE_MESSAGE_SENT, |
| 673 base::Bind(&NetLogQuicCryptoHandshakeMessageCallback, &message)); | 674 base::Bind(&NetLogQuicCryptoHandshakeMessageCallback, &message)); |
| (...skipping 199 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 873 continue; | 874 continue; |
| 874 } | 875 } |
| 875 // Record some overlapping patterns, to get a better picture, since this is | 876 // Record some overlapping patterns, to get a better picture, since this is |
| 876 // not very expensive. | 877 // not very expensive. |
| 877 if (i % 3 == 0) | 878 if (i % 3 == 0) |
| 878 six_packet_histogram->Add(recent_6_mask); | 879 six_packet_histogram->Add(recent_6_mask); |
| 879 } | 880 } |
| 880 } | 881 } |
| 881 | 882 |
| 882 } // namespace net | 883 } // namespace net |
| OLD | NEW |