ozone: evdev: Sync caps lock LED state to evdev
[chromium-blink-merge.git] / net / quic / test_tools / quic_connection_peer.cc
blobdd75ca808e008102f1416c868a0cc0ca0532a957
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
3 // found in the LICENSE file.
5 #include "net/quic/test_tools/quic_connection_peer.h"
7 #include "base/stl_util.h"
8 #include "net/quic/congestion_control/send_algorithm_interface.h"
9 #include "net/quic/quic_connection.h"
10 #include "net/quic/quic_packet_writer.h"
11 #include "net/quic/quic_received_packet_manager.h"
12 #include "net/quic/test_tools/quic_framer_peer.h"
13 #include "net/quic/test_tools/quic_packet_generator_peer.h"
14 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h"
16 namespace net {
17 namespace test {
19 // static
20 void QuicConnectionPeer::SendAck(QuicConnection* connection) {
21 connection->SendAck();
24 // static
25 void QuicConnectionPeer::SetSendAlgorithm(
26 QuicConnection* connection,
27 SendAlgorithmInterface* send_algorithm) {
28 connection->sent_packet_manager_.send_algorithm_.reset(send_algorithm);
31 // static
32 void QuicConnectionPeer::PopulateAckFrame(QuicConnection* connection,
33 QuicAckFrame* ack) {
34 connection->PopulateAckFrame(ack);
37 // static
38 void QuicConnectionPeer::PopulateStopWaitingFrame(
39 QuicConnection* connection,
40 QuicStopWaitingFrame* stop_waiting) {
41 connection->PopulateStopWaitingFrame(stop_waiting);
44 // static
45 QuicConnectionVisitorInterface* QuicConnectionPeer::GetVisitor(
46 QuicConnection* connection) {
47 return connection->visitor_;
50 // static
51 QuicPacketCreator* QuicConnectionPeer::GetPacketCreator(
52 QuicConnection* connection) {
53 return QuicPacketGeneratorPeer::GetPacketCreator(
54 &connection->packet_generator_);
57 // static
58 QuicPacketGenerator* QuicConnectionPeer::GetPacketGenerator(
59 QuicConnection* connection) {
60 return &connection->packet_generator_;
63 // static
64 QuicSentPacketManager* QuicConnectionPeer::GetSentPacketManager(
65 QuicConnection* connection) {
66 return &connection->sent_packet_manager_;
69 // static
70 QuicTime::Delta QuicConnectionPeer::GetNetworkTimeout(
71 QuicConnection* connection) {
72 return connection->idle_network_timeout_;
75 // static
76 // TODO(ianswett): Create a GetSentEntropyHash which accepts an AckFrame.
77 QuicPacketEntropyHash QuicConnectionPeer::GetSentEntropyHash(
78 QuicConnection* connection,
79 QuicPacketSequenceNumber sequence_number) {
80 QuicSentEntropyManager::CumulativeEntropy last_entropy_copy =
81 connection->sent_entropy_manager_.last_cumulative_entropy_;
82 connection->sent_entropy_manager_.UpdateCumulativeEntropy(sequence_number,
83 &last_entropy_copy);
84 return last_entropy_copy.entropy;
87 // static
88 QuicPacketEntropyHash QuicConnectionPeer::PacketEntropy(
89 QuicConnection* connection,
90 QuicPacketSequenceNumber sequence_number) {
91 return connection->sent_entropy_manager_.GetPacketEntropy(sequence_number);
94 // static
95 QuicPacketEntropyHash QuicConnectionPeer::ReceivedEntropyHash(
96 QuicConnection* connection,
97 QuicPacketSequenceNumber sequence_number) {
98 return connection->received_packet_manager_.EntropyHash(
99 sequence_number);
102 // static
103 bool QuicConnectionPeer::IsServer(QuicConnection* connection) {
104 return connection->is_server_;
107 // static
108 void QuicConnectionPeer::SetIsServer(QuicConnection* connection,
109 bool is_server) {
110 connection->is_server_ = is_server;
111 QuicFramerPeer::SetIsServer(&connection->framer_, is_server);
114 // static
115 void QuicConnectionPeer::SetSelfAddress(QuicConnection* connection,
116 const IPEndPoint& self_address) {
117 connection->self_address_ = self_address;
120 // static
121 void QuicConnectionPeer::SetPeerAddress(QuicConnection* connection,
122 const IPEndPoint& peer_address) {
123 connection->peer_address_ = peer_address;
126 // static
127 bool QuicConnectionPeer::IsSilentCloseEnabled(QuicConnection* connection) {
128 return connection->silent_close_enabled_;
131 // static
132 void QuicConnectionPeer::SwapCrypters(QuicConnection* connection,
133 QuicFramer* framer) {
134 QuicFramerPeer::SwapCrypters(framer, &connection->framer_);
137 // static
138 QuicConnectionHelperInterface* QuicConnectionPeer::GetHelper(
139 QuicConnection* connection) {
140 return connection->helper_;
143 // static
144 QuicFramer* QuicConnectionPeer::GetFramer(QuicConnection* connection) {
145 return &connection->framer_;
148 // static
149 QuicFecGroup* QuicConnectionPeer::GetFecGroup(QuicConnection* connection,
150 int fec_group) {
151 connection->last_header_.fec_group = fec_group;
152 return connection->GetFecGroup();
155 // static
156 QuicAlarm* QuicConnectionPeer::GetAckAlarm(QuicConnection* connection) {
157 return connection->ack_alarm_.get();
160 // static
161 QuicAlarm* QuicConnectionPeer::GetPingAlarm(QuicConnection* connection) {
162 return connection->ping_alarm_.get();
165 // static
166 QuicAlarm* QuicConnectionPeer::GetFecAlarm(QuicConnection* connection) {
167 return connection->fec_alarm_.get();
170 // static
171 QuicAlarm* QuicConnectionPeer::GetResumeWritesAlarm(
172 QuicConnection* connection) {
173 return connection->resume_writes_alarm_.get();
176 // static
177 QuicAlarm* QuicConnectionPeer::GetRetransmissionAlarm(
178 QuicConnection* connection) {
179 return connection->retransmission_alarm_.get();
182 // static
183 QuicAlarm* QuicConnectionPeer::GetSendAlarm(QuicConnection* connection) {
184 return connection->send_alarm_.get();
187 // static
188 QuicAlarm* QuicConnectionPeer::GetTimeoutAlarm(QuicConnection* connection) {
189 return connection->timeout_alarm_.get();
192 // static
193 QuicPacketWriter* QuicConnectionPeer::GetWriter(QuicConnection* connection) {
194 return connection->writer_;
197 // static
198 void QuicConnectionPeer::SetWriter(QuicConnection* connection,
199 QuicPacketWriter* writer,
200 bool owns_writer) {
201 if (connection->owns_writer_) {
202 delete connection->writer_;
204 connection->writer_ = writer;
205 connection->owns_writer_ = owns_writer;
208 // static
209 void QuicConnectionPeer::CloseConnection(QuicConnection* connection) {
210 connection->connected_ = false;
213 // static
214 QuicEncryptedPacket* QuicConnectionPeer::GetConnectionClosePacket(
215 QuicConnection* connection) {
216 return connection->connection_close_packet_.get();
219 // static
220 QuicPacketHeader* QuicConnectionPeer::GetLastHeader(
221 QuicConnection* connection) {
222 return &connection->last_header_;
225 // static
226 void QuicConnectionPeer::SetSequenceNumberOfLastSentPacket(
227 QuicConnection* connection, QuicPacketSequenceNumber number) {
228 connection->sequence_number_of_last_sent_packet_ = number;
231 // static
232 QuicConnectionStats* QuicConnectionPeer::GetStats(QuicConnection* connection) {
233 return &connection->stats_;
236 } // namespace test
237 } // namespace net