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

Side by Side Diff: net/quic/quic_connection_logger.cc

Issue 198353003: Land Recent QUIC Changes (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 9 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 | Annotate | Revision Log
« no previous file with comments | « net/quic/quic_connection_logger.h ('k') | net/quic/quic_connection_stats.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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
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
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
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
OLDNEW
« no previous file with comments | « net/quic/quic_connection_logger.h ('k') | net/quic/quic_connection_stats.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698