| OLD | NEW |
| 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 Loading... |
| 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 Loading... |
| 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 |
| OLD | NEW |