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

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

Issue 12334063: Land recent QUIC changes. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: more EXPECT_FALSE 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/test_tools/quic_connection_peer.h ('k') | net/quic/test_tools/quic_test_utils.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) 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/quic_congestion_manager.h" 8 #include "net/quic/congestion_control/quic_congestion_manager.h"
9 #include "net/quic/congestion_control/receive_algorithm_interface.h" 9 #include "net/quic/congestion_control/receive_algorithm_interface.h"
10 #include "net/quic/congestion_control/send_algorithm_interface.h" 10 #include "net/quic/congestion_control/send_algorithm_interface.h"
(...skipping 15 matching lines...) Expand all
26 } 26 }
27 27
28 // static 28 // static
29 void QuicConnectionPeer::SetSendAlgorithm( 29 void QuicConnectionPeer::SetSendAlgorithm(
30 QuicConnection* connection, 30 QuicConnection* connection,
31 SendAlgorithmInterface* send_algorithm) { 31 SendAlgorithmInterface* send_algorithm) {
32 connection->congestion_manager_.send_algorithm_.reset(send_algorithm); 32 connection->congestion_manager_.send_algorithm_.reset(send_algorithm);
33 } 33 }
34 34
35 // static 35 // static
36 QuicAckFrame* QuicConnectionPeer::GetOutgoingAck(QuicConnection* connection) { 36 QuicAckFrame* QuicConnectionPeer::GetOutgoingAck(
37 QuicConnection* connection) {
38 connection->UpdateOutgoingAck();
37 return &connection->outgoing_ack_; 39 return &connection->outgoing_ack_;
38 } 40 }
39 41
40 // static 42 // static
41 QuicConnectionVisitorInterface* QuicConnectionPeer::GetVisitor( 43 QuicConnectionVisitorInterface* QuicConnectionPeer::GetVisitor(
42 QuicConnection* connection) { 44 QuicConnection* connection) {
43 return connection->visitor_; 45 return connection->visitor_;
44 } 46 }
45 47
46 // static 48 // static
(...skipping 18 matching lines...) Expand all
65 QuicPacketSequenceNumber sequence_number) { 67 QuicPacketSequenceNumber sequence_number) {
66 return ContainsKey(connection->retransmission_map_, sequence_number); 68 return ContainsKey(connection->retransmission_map_, sequence_number);
67 } 69 }
68 70
69 // static 71 // static
70 size_t QuicConnectionPeer::GetRetransmissionCount( 72 size_t QuicConnectionPeer::GetRetransmissionCount(
71 QuicConnection* connection, 73 QuicConnection* connection,
72 QuicPacketSequenceNumber sequence_number) { 74 QuicPacketSequenceNumber sequence_number) {
73 QuicConnection::RetransmissionMap::iterator it = 75 QuicConnection::RetransmissionMap::iterator it =
74 connection->retransmission_map_.find(sequence_number); 76 connection->retransmission_map_.find(sequence_number);
77 DCHECK(connection->retransmission_map_.end() != it);
75 return it->second.number_retransmissions; 78 return it->second.number_retransmissions;
76 } 79 }
77 80
81 // static
82 QuicPacketEntropyHash QuicConnectionPeer::GetSentEntropyHash(
83 QuicConnection* connection,
84 QuicPacketSequenceNumber sequence_number) {
85 return connection->entropy_manager_.SentEntropyHash(sequence_number);
86 }
87
88 // static
89 bool QuicConnectionPeer::IsValidEntropy(
90 QuicConnection* connection,
91 QuicPacketSequenceNumber largest_observed,
92 const SequenceNumberSet& missing_packets,
93 QuicPacketEntropyHash entropy_hash) {
94 return connection->entropy_manager_.IsValidEntropy(
95 largest_observed, missing_packets, entropy_hash);
96 }
97
98 // static
99 QuicPacketEntropyHash QuicConnectionPeer::ReceivedEntropyHash(
100 QuicConnection* connection,
101 QuicPacketSequenceNumber sequence_number) {
102 return connection->entropy_manager_.ReceivedEntropyHash(sequence_number);
103 }
104
78 } // namespace test 105 } // namespace test
79 } // namespace net 106 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/test_tools/quic_connection_peer.h ('k') | net/quic/test_tools/quic_test_utils.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698