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 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 22 matching lines...) Expand all Loading... |
33 base::DictionaryValue* dict = new base::DictionaryValue(); | 33 base::DictionaryValue* dict = new base::DictionaryValue(); |
34 dict->SetString("self_address", self_address->ToString()); | 34 dict->SetString("self_address", self_address->ToString()); |
35 dict->SetString("peer_address", peer_address->ToString()); | 35 dict->SetString("peer_address", peer_address->ToString()); |
36 dict->SetInteger("size", packet_size); | 36 dict->SetInteger("size", packet_size); |
37 return dict; | 37 return dict; |
38 } | 38 } |
39 | 39 |
40 base::Value* NetLogQuicPacketSentCallback( | 40 base::Value* NetLogQuicPacketSentCallback( |
41 QuicPacketSequenceNumber sequence_number, | 41 QuicPacketSequenceNumber sequence_number, |
42 EncryptionLevel level, | 42 EncryptionLevel level, |
| 43 TransmissionType transmission_type, |
43 size_t packet_size, | 44 size_t packet_size, |
44 WriteResult result, | 45 WriteResult result, |
45 NetLog::LogLevel /* log_level */) { | 46 NetLog::LogLevel /* log_level */) { |
46 base::DictionaryValue* dict = new base::DictionaryValue(); | 47 base::DictionaryValue* dict = new base::DictionaryValue(); |
47 dict->SetInteger("encryption_level", level); | 48 dict->SetInteger("encryption_level", level); |
| 49 dict->SetInteger("transmission_type", transmission_type); |
48 dict->SetString("packet_sequence_number", | 50 dict->SetString("packet_sequence_number", |
49 base::Uint64ToString(sequence_number)); | 51 base::Uint64ToString(sequence_number)); |
50 dict->SetInteger("size", packet_size); | 52 dict->SetInteger("size", packet_size); |
51 if (result.status != WRITE_STATUS_OK) { | 53 if (result.status != WRITE_STATUS_OK) { |
52 dict->SetInteger("net_error", result.error_code); | 54 dict->SetInteger("net_error", result.error_code); |
53 } | 55 } |
54 return dict; | 56 return dict; |
55 } | 57 } |
56 | 58 |
57 base::Value* NetLogQuicPacketRetransmittedCallback( | 59 base::Value* NetLogQuicPacketRetransmittedCallback( |
(...skipping 266 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
324 frame.stop_waiting_frame)); | 326 frame.stop_waiting_frame)); |
325 break; | 327 break; |
326 default: | 328 default: |
327 DCHECK(false) << "Illegal frame type: " << frame.type; | 329 DCHECK(false) << "Illegal frame type: " << frame.type; |
328 } | 330 } |
329 } | 331 } |
330 | 332 |
331 void QuicConnectionLogger::OnPacketSent( | 333 void QuicConnectionLogger::OnPacketSent( |
332 QuicPacketSequenceNumber sequence_number, | 334 QuicPacketSequenceNumber sequence_number, |
333 EncryptionLevel level, | 335 EncryptionLevel level, |
| 336 TransmissionType transmission_type, |
334 const QuicEncryptedPacket& packet, | 337 const QuicEncryptedPacket& packet, |
335 WriteResult result) { | 338 WriteResult result) { |
336 net_log_.AddEvent( | 339 net_log_.AddEvent( |
337 NetLog::TYPE_QUIC_SESSION_PACKET_SENT, | 340 NetLog::TYPE_QUIC_SESSION_PACKET_SENT, |
338 base::Bind(&NetLogQuicPacketSentCallback, sequence_number, level, | 341 base::Bind(&NetLogQuicPacketSentCallback, sequence_number, level, |
339 packet.length(), result)); | 342 transmission_type, packet.length(), result)); |
340 } | 343 } |
341 | 344 |
342 void QuicConnectionLogger:: OnPacketRetransmitted( | 345 void QuicConnectionLogger:: OnPacketRetransmitted( |
343 QuicPacketSequenceNumber old_sequence_number, | 346 QuicPacketSequenceNumber old_sequence_number, |
344 QuicPacketSequenceNumber new_sequence_number) { | 347 QuicPacketSequenceNumber new_sequence_number) { |
345 net_log_.AddEvent( | 348 net_log_.AddEvent( |
346 NetLog::TYPE_QUIC_SESSION_PACKET_RETRANSMITTED, | 349 NetLog::TYPE_QUIC_SESSION_PACKET_RETRANSMITTED, |
347 base::Bind(&NetLogQuicPacketRetransmittedCallback, | 350 base::Bind(&NetLogQuicPacketRetransmittedCallback, |
348 old_sequence_number, new_sequence_number)); | 351 old_sequence_number, new_sequence_number)); |
349 } | 352 } |
(...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
550 DCHECK(!packets_received_[0]); | 553 DCHECK(!packets_received_[0]); |
551 for (size_t i = 1; i <= last_index; ++i) { | 554 for (size_t i = 1; i <= last_index; ++i) { |
552 if (packets_received_[i]) | 555 if (packets_received_[i]) |
553 packet_ack_histogram->Add(i); | 556 packet_ack_histogram->Add(i); |
554 else | 557 else |
555 packet_nack_histogram->Add(i); | 558 packet_nack_histogram->Add(i); |
556 } | 559 } |
557 } | 560 } |
558 | 561 |
559 } // namespace net | 562 } // namespace net |
OLD | NEW |