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

Side by Side Diff: net/quic/test_tools/quic_connection_peer.cc

Issue 968233004: Land Recent QUIC Changes until 03/02/2015. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@cleanup
Patch Set: Created 5 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
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/test_tools/quic_connection_peer.h" 5 #include "net/quic/test_tools/quic_connection_peer.h"
6 6
7 #include "base/stl_util.h" 7 #include "base/stl_util.h"
8 #include "net/quic/congestion_control/send_algorithm_interface.h" 8 #include "net/quic/congestion_control/send_algorithm_interface.h"
9 #include "net/quic/quic_connection.h" 9 #include "net/quic/quic_connection.h"
10 #include "net/quic/quic_packet_writer.h" 10 #include "net/quic/quic_packet_writer.h"
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after
60 return &connection->packet_generator_; 60 return &connection->packet_generator_;
61 } 61 }
62 62
63 // static 63 // static
64 QuicSentPacketManager* QuicConnectionPeer::GetSentPacketManager( 64 QuicSentPacketManager* QuicConnectionPeer::GetSentPacketManager(
65 QuicConnection* connection) { 65 QuicConnection* connection) {
66 return &connection->sent_packet_manager_; 66 return &connection->sent_packet_manager_;
67 } 67 }
68 68
69 // static 69 // static
70 QuicReceivedPacketManager* QuicConnectionPeer::GetReceivedPacketManager(
71 QuicConnection* connection) {
72 return &connection->received_packet_manager_;
73 }
74
75 // static
76 QuicTime::Delta QuicConnectionPeer::GetNetworkTimeout( 70 QuicTime::Delta QuicConnectionPeer::GetNetworkTimeout(
77 QuicConnection* connection) { 71 QuicConnection* connection) {
78 return connection->idle_network_timeout_; 72 return connection->idle_network_timeout_;
79 } 73 }
80 74
81 // static 75 // static
82 bool QuicConnectionPeer::IsSavedForRetransmission(
83 QuicConnection* connection,
84 QuicPacketSequenceNumber sequence_number) {
85 return connection->sent_packet_manager_.IsUnacked(sequence_number) &&
86 connection->sent_packet_manager_.HasRetransmittableFrames(
87 sequence_number);
88 }
89
90 // static
91 bool QuicConnectionPeer::IsRetransmission(
92 QuicConnection* connection,
93 QuicPacketSequenceNumber sequence_number) {
94 return QuicSentPacketManagerPeer::IsRetransmission(
95 &connection->sent_packet_manager_, sequence_number);
96 }
97
98 // static
99 // TODO(ianswett): Create a GetSentEntropyHash which accepts an AckFrame. 76 // TODO(ianswett): Create a GetSentEntropyHash which accepts an AckFrame.
100 QuicPacketEntropyHash QuicConnectionPeer::GetSentEntropyHash( 77 QuicPacketEntropyHash QuicConnectionPeer::GetSentEntropyHash(
101 QuicConnection* connection, 78 QuicConnection* connection,
102 QuicPacketSequenceNumber sequence_number) { 79 QuicPacketSequenceNumber sequence_number) {
103 QuicSentEntropyManager::CumulativeEntropy last_entropy_copy = 80 QuicSentEntropyManager::CumulativeEntropy last_entropy_copy =
104 connection->sent_entropy_manager_.last_cumulative_entropy_; 81 connection->sent_entropy_manager_.last_cumulative_entropy_;
105 connection->sent_entropy_manager_.UpdateCumulativeEntropy(sequence_number, 82 connection->sent_entropy_manager_.UpdateCumulativeEntropy(sequence_number,
106 &last_entropy_copy); 83 &last_entropy_copy);
107 return last_entropy_copy.entropy; 84 return last_entropy_copy.entropy;
108 } 85 }
(...skipping 124 matching lines...) Expand 10 before | Expand all | Expand 10 after
233 connection->connected_ = false; 210 connection->connected_ = false;
234 } 211 }
235 212
236 // static 213 // static
237 QuicEncryptedPacket* QuicConnectionPeer::GetConnectionClosePacket( 214 QuicEncryptedPacket* QuicConnectionPeer::GetConnectionClosePacket(
238 QuicConnection* connection) { 215 QuicConnection* connection) {
239 return connection->connection_close_packet_.get(); 216 return connection->connection_close_packet_.get();
240 } 217 }
241 218
242 // static 219 // static
243 void QuicConnectionPeer::SetSupportedVersions(QuicConnection* connection,
244 QuicVersionVector versions) {
245 connection->framer_.SetSupportedVersions(versions);
246 }
247
248 // static
249 QuicPacketHeader* QuicConnectionPeer::GetLastHeader( 220 QuicPacketHeader* QuicConnectionPeer::GetLastHeader(
250 QuicConnection* connection) { 221 QuicConnection* connection) {
251 return &connection->last_header_; 222 return &connection->last_header_;
252 } 223 }
253 224
254 // static 225 // static
255 void QuicConnectionPeer::SetSequenceNumberOfLastSentPacket( 226 void QuicConnectionPeer::SetSequenceNumberOfLastSentPacket(
256 QuicConnection* connection, QuicPacketSequenceNumber number) { 227 QuicConnection* connection, QuicPacketSequenceNumber number) {
257 connection->sequence_number_of_last_sent_packet_ = number; 228 connection->sequence_number_of_last_sent_packet_ = number;
258 } 229 }
259 230
260 // static 231 // static
261 QuicConnectionStats* QuicConnectionPeer::GetStats(QuicConnection* connection) { 232 QuicConnectionStats* QuicConnectionPeer::GetStats(QuicConnection* connection) {
262 return &connection->stats_; 233 return &connection->stats_;
263 } 234 }
264 235
265 } // namespace test 236 } // namespace test
266 } // namespace net 237 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/test_tools/quic_connection_peer.h ('k') | net/quic/test_tools/quic_sent_packet_manager_peer.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698