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

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

Issue 12317026: Various small QUIC cleanups after merging to Chrome. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 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 unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « net/quic/quic_connection.h ('k') | net/quic/quic_framer_test.cc » ('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) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 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.h" 5 #include "net/quic/quic_connection.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "base/stl_util.h" 10 #include "base/stl_util.h"
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after
67 return delta <= kMaxPacketGap; 67 return delta <= kMaxPacketGap;
68 } 68 }
69 69
70 } // namespace 70 } // namespace
71 71
72 QuicConnection::UnackedPacket::UnackedPacket(QuicFrames unacked_frames) 72 QuicConnection::UnackedPacket::UnackedPacket(QuicFrames unacked_frames)
73 : frames(unacked_frames) { 73 : frames(unacked_frames) {
74 } 74 }
75 75
76 QuicConnection::UnackedPacket::UnackedPacket(QuicFrames unacked_frames, 76 QuicConnection::UnackedPacket::UnackedPacket(QuicFrames unacked_frames,
77 std::string data) 77 string data)
78 : frames(unacked_frames), 78 : frames(unacked_frames),
79 data(data) { 79 data(data) {
80 } 80 }
81 81
82 QuicConnection::UnackedPacket::~UnackedPacket() { 82 QuicConnection::UnackedPacket::~UnackedPacket() {
83 } 83 }
84 84
85 QuicConnection::QuicConnection(QuicGuid guid, 85 QuicConnection::QuicConnection(QuicGuid guid,
86 IPEndPoint address, 86 IPEndPoint address,
87 QuicConnectionHelperInterface* helper) 87 QuicConnectionHelperInterface* helper)
(...skipping 387 matching lines...) Expand 10 before | Expand all | Expand 10 after
475 DLOG(INFO) << "Connection closed with error " 475 DLOG(INFO) << "Connection closed with error "
476 << QuicUtils::ErrorToString(frame.error_code); 476 << QuicUtils::ErrorToString(frame.error_code);
477 CloseConnection(frame.error_code, true); 477 CloseConnection(frame.error_code, true);
478 } 478 }
479 479
480 void QuicConnection::OnPacketComplete() { 480 void QuicConnection::OnPacketComplete() {
481 if (!last_packet_revived_) { 481 if (!last_packet_revived_) {
482 DLOG(INFO) << "Got packet " << last_header_.packet_sequence_number 482 DLOG(INFO) << "Got packet " << last_header_.packet_sequence_number
483 << " with " << last_stream_frames_.size() 483 << " with " << last_stream_frames_.size()
484 << " stream frames for " << last_header_.public_header.guid; 484 << " stream frames for " << last_header_.public_header.guid;
485 congestion_manager_.RecordIncomingPacket(last_size_, 485 congestion_manager_.RecordIncomingPacket(
486 last_header_.packet_sequence_number, time_of_last_received_packet_, 486 last_size_, last_header_.packet_sequence_number,
487 last_packet_revived_); 487 time_of_last_received_packet_, last_packet_revived_);
488 } else { 488 } else {
489 DLOG(INFO) << "Got revived packet with " << last_stream_frames_.size() 489 DLOG(INFO) << "Got revived packet with " << last_stream_frames_.size()
490 << " frames."; 490 << " frames.";
491 } 491 }
492 492
493 if (last_stream_frames_.empty() || 493 if (last_stream_frames_.empty() ||
494 visitor_->OnPacket(self_address_, peer_address_, 494 visitor_->OnPacket(self_address_, peer_address_,
495 last_header_, last_stream_frames_)) { 495 last_header_, last_stream_frames_)) {
496 RecordPacketReceived(last_header_); 496 RecordPacketReceived(last_header_);
497 } 497 }
(...skipping 560 matching lines...) Expand 10 before | Expand all | Expand 10 after
1058 << " delta:" << delta.ToMicroseconds(); 1058 << " delta:" << delta.ToMicroseconds();
1059 if (delta >= timeout_) { 1059 if (delta >= timeout_) {
1060 SendConnectionClose(QUIC_CONNECTION_TIMED_OUT); 1060 SendConnectionClose(QUIC_CONNECTION_TIMED_OUT);
1061 return true; 1061 return true;
1062 } 1062 }
1063 helper_->SetTimeoutAlarm(timeout_.Subtract(delta)); 1063 helper_->SetTimeoutAlarm(timeout_.Subtract(delta));
1064 return false; 1064 return false;
1065 } 1065 }
1066 1066
1067 } // namespace net 1067 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/quic_connection.h ('k') | net/quic/quic_framer_test.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698