OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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_stream_factory_peer.h" | 5 #include "net/quic/test_tools/quic_stream_factory_peer.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "net/cert/x509_certificate.h" | 10 #include "net/cert/x509_certificate.h" |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
64 return true; | 64 return true; |
65 } | 65 } |
66 return false; | 66 return false; |
67 } | 67 } |
68 | 68 |
69 void QuicStreamFactoryPeer::SetTaskRunner(QuicStreamFactory* factory, | 69 void QuicStreamFactoryPeer::SetTaskRunner(QuicStreamFactory* factory, |
70 base::TaskRunner* task_runner) { | 70 base::TaskRunner* task_runner) { |
71 factory->task_runner_ = task_runner; | 71 factory->task_runner_ = task_runner; |
72 } | 72 } |
73 | 73 |
74 int QuicStreamFactoryPeer::GetNumberOfLossyConnections( | |
75 QuicStreamFactory* factory, | |
76 uint16_t port) { | |
77 return factory->number_of_lossy_connections_[port]; | |
78 } | |
79 | |
80 QuicTime::Delta QuicStreamFactoryPeer::GetPingTimeout( | 74 QuicTime::Delta QuicStreamFactoryPeer::GetPingTimeout( |
81 QuicStreamFactory* factory) { | 75 QuicStreamFactory* factory) { |
82 return factory->ping_timeout_; | 76 return factory->ping_timeout_; |
83 } | 77 } |
84 | 78 |
85 bool QuicStreamFactoryPeer::IsQuicDisabled(QuicStreamFactory* factory, | 79 bool QuicStreamFactoryPeer::IsQuicDisabled(QuicStreamFactory* factory) { |
86 uint16_t port) { | 80 return factory->IsQuicDisabled(); |
87 return factory->IsQuicDisabled(port); | |
88 } | 81 } |
89 | 82 |
90 bool QuicStreamFactoryPeer::GetDelayTcpRace(QuicStreamFactory* factory) { | 83 bool QuicStreamFactoryPeer::GetDelayTcpRace(QuicStreamFactory* factory) { |
91 return factory->delay_tcp_race_; | 84 return factory->delay_tcp_race_; |
92 } | 85 } |
93 | 86 |
94 void QuicStreamFactoryPeer::SetDelayTcpRace(QuicStreamFactory* factory, | 87 void QuicStreamFactoryPeer::SetDelayTcpRace(QuicStreamFactory* factory, |
95 bool delay_tcp_race) { | 88 bool delay_tcp_race) { |
96 factory->delay_tcp_race_ = delay_tcp_race; | 89 factory->delay_tcp_race_ = delay_tcp_race; |
97 } | 90 } |
(...skipping 27 matching lines...) Expand all Loading... |
125 QuicTime::Delta yield_after_duration) { | 118 QuicTime::Delta yield_after_duration) { |
126 factory->yield_after_duration_ = yield_after_duration; | 119 factory->yield_after_duration_ = yield_after_duration; |
127 } | 120 } |
128 | 121 |
129 size_t QuicStreamFactoryPeer::GetNumberOfActiveJobs( | 122 size_t QuicStreamFactoryPeer::GetNumberOfActiveJobs( |
130 QuicStreamFactory* factory, | 123 QuicStreamFactory* factory, |
131 const QuicServerId& server_id) { | 124 const QuicServerId& server_id) { |
132 return (factory->active_jobs_[server_id]).size(); | 125 return (factory->active_jobs_[server_id]).size(); |
133 } | 126 } |
134 | 127 |
135 int QuicStreamFactoryPeer::GetNumTimeoutsWithOpenStreams( | |
136 QuicStreamFactory* factory) { | |
137 return factory->num_timeouts_with_open_streams_; | |
138 } | |
139 | |
140 int QuicStreamFactoryPeer::GetNumPublicResetsPostHandshake( | |
141 QuicStreamFactory* factory) { | |
142 return factory->num_public_resets_post_handshake_; | |
143 } | |
144 | |
145 void QuicStreamFactoryPeer::MaybeInitialize(QuicStreamFactory* factory) { | 128 void QuicStreamFactoryPeer::MaybeInitialize(QuicStreamFactory* factory) { |
146 factory->MaybeInitialize(); | 129 factory->MaybeInitialize(); |
147 } | 130 } |
148 | 131 |
149 bool QuicStreamFactoryPeer::HasInitializedData(QuicStreamFactory* factory) { | 132 bool QuicStreamFactoryPeer::HasInitializedData(QuicStreamFactory* factory) { |
150 return factory->has_initialized_data_; | 133 return factory->has_initialized_data_; |
151 } | 134 } |
152 | 135 |
153 bool QuicStreamFactoryPeer::SupportsQuicAtStartUp(QuicStreamFactory* factory, | 136 bool QuicStreamFactoryPeer::SupportsQuicAtStartUp(QuicStreamFactory* factory, |
154 HostPortPair host_port_pair) { | 137 HostPortPair host_port_pair) { |
(...skipping 51 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
206 return &factory->push_promise_index_; | 189 return &factory->push_promise_index_; |
207 } | 190 } |
208 | 191 |
209 int QuicStreamFactoryPeer::GetNumPushStreamsCreated( | 192 int QuicStreamFactoryPeer::GetNumPushStreamsCreated( |
210 QuicStreamFactory* factory) { | 193 QuicStreamFactory* factory) { |
211 return factory->num_push_streams_created_; | 194 return factory->num_push_streams_created_; |
212 } | 195 } |
213 | 196 |
214 } // namespace test | 197 } // namespace test |
215 } // namespace net | 198 } // namespace net |
OLD | NEW |