| /external/chromium_org/net/url_request/ |
| url_request_ftp_job_unittest.cc | 231 void AddSocket(MockRead* reads, size_t reads_size,
263 MockRead reads[] = {
264 MockRead(ASYNC, 1, "HTTP/1.1 200 OK\r\n"),
265 MockRead(ASYNC, 2, "Content-Length: 9\r\n\r\n"),
266 MockRead(ASYNC, 3, "test.html"),
313 MockRead reads[] = {
315 MockRead(ASYNC, 1, "HTTP/1.1 407 Proxy Authentication Required\r\n"),
316 MockRead(ASYNC, 2, "Proxy-Authenticate: Basic "
318 MockRead(ASYNC, 3, "Content-Length: 9\r\n\r\n"),
319 MockRead(ASYNC, 4, "test.html")
[all...] |
| /external/chromium_org/net/socket/ |
| deterministic_socket_data_unittest.cc | 38 void Initialize(MockRead* reads, size_t reads_count, MockWrite* writes,
89 void DeterministicSocketDataTest::Initialize(MockRead* reads,
199 MockRead reads[] = {
200 MockRead(SYNCHRONOUS, kMsg1, kLen1, 0), // Sync Read
201 MockRead(SYNCHRONOUS, 0, 1), // EOF
211 MockRead reads[] = {
212 MockRead(SYNCHRONOUS, kMsg1, kLen1, 1), // Sync Read
213 MockRead(SYNCHRONOUS, 0, 2), // EOF
228 MockRead reads[] = {
229 MockRead(SYNCHRONOUS, kMsg1, kLen1, 0), // Sync Rea
[all...] |
| socks5_client_socket_unittest.cc | 35 scoped_ptr<SOCKS5ClientSocket> BuildMockSocket(MockRead reads[],
85 MockRead reads[],
132 MockRead data_reads[] = {
133 MockRead(ASYNC, kSOCKS5GreetResponse, kSOCKS5GreetResponseLength),
134 MockRead(ASYNC, kSOCKS5OkResponse, kSOCKS5OkResponseLength),
135 MockRead(ASYNC, payload_read.data(), payload_read.size()) };
204 MockRead data_reads[] = {
205 MockRead(SYNCHRONOUS, kSOCKS5GreetResponse, kSOCKS5GreetResponseLength),
206 MockRead(SYNCHRONOUS, kSOCKS5OkResponse, kSOCKS5OkResponseLength)
230 MockRead data_reads[] = {MockRead()}
[all...] |
| socks_client_socket_unittest.cc | 33 MockRead reads[], size_t reads_count,
61 MockRead reads[],
144 MockRead data_reads[] = {
145 MockRead(ASYNC, kSOCKSOkReply, arraysize(kSOCKSOkReply)),
146 MockRead(ASYNC, payload_read.data(), payload_read.size()) };
220 MockRead data_reads[] = {
221 MockRead(SYNCHRONOUS, tests[i].fail_reply,
257 MockRead data_reads[] = {
258 MockRead(ASYNC, kSOCKSPartialReply1, arraysize(kSOCKSPartialReply1)),
259 MockRead(ASYNC, kSOCKSPartialReply2, arraysize(kSOCKSPartialReply2)) }
[all...] |
| socket_test_util.h | 42 // If the |result| member of a MockRead is
43 // ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ, that MockRead is just a
45 // MockRead. The other members of that MockRead are ignored.
76 // MockRead and MockWrite shares the same interface and members, but we'd like
78 // interchangably. To do this, a struct template is defined, and MockRead and
83 // |data| in MockRead and MockWrite has different meanings: |data| in MockRead
184 typedef MockReadWrite<MOCK_READ> MockRead;
203 // If the |MockRead.result| is ERR_IO_PENDING, it informs the calle
[all...] |
| socket_test_util.cc | 123 const char* stop = (r.sequence_number & MockRead::STOPLOOP) ? " (STOP)" : "";
124 DVLOG(1) << "Stage: " << (r.sequence_number & ~MockRead::STOPLOOP) << stop
159 StaticSocketDataProvider::StaticSocketDataProvider(MockRead* reads,
173 const MockRead& StaticSocketDataProvider::PeekRead() const {
183 const MockRead& StaticSocketDataProvider::PeekRead(size_t index) const {
193 MockRead StaticSocketDataProvider::GetNextRead() {
247 MockRead DynamicSocketDataProvider::GetNextRead() {
249 return MockRead(SYNCHRONOUS, ERR_UNEXPECTED);
250 MockRead result = reads_.front();
270 reads_.push_back(MockRead(ASYNC, data, length))
[all...] |
| socks_client_socket_pool_unittest.cc | 74 reads_.reset(new MockRead[3]);
75 reads_[0] = MockRead(mode, kSOCKS5GreetResponse,
77 reads_[1] = MockRead(mode, kSOCKS5OkResponse, kSOCKS5OkResponseLength);
78 reads_[2] = MockRead(mode, 0);
89 scoped_ptr<MockRead[]> reads_;
233 MockRead failed_read[] = {
234 MockRead(SYNCHRONOUS, 0),
252 MockRead failed_read[] = {
253 MockRead(ASYNC, 0),
|
| /external/chromium_org/net/quic/ |
| quic_network_transaction_unittest.cc | 73 reads_.push_back(MockRead(SYNCHRONOUS, packet->data(), packet->length(),
79 reads_.push_back(MockRead(mode, rv));
90 MockRead* reads = reads_.empty() ? NULL : &reads_[0];
100 std::vector<MockRead> reads_;
441 MockRead http_reads[] = {
442 MockRead("HTTP/1.1 200 OK\r\n\r\n"),
443 MockRead("hello world"),
444 MockRead(SYNCHRONOUS, ERR_TEST_PEER_CLOSE_AFTER_NEXT_MOCK_READ),
445 MockRead(ASYNC, OK)
459 MockRead http_reads[] =
[all...] |
| quic_stream_factory_test.cc | 149 MockRead reads[] = {
150 MockRead(ASYNC, OK, 0) // EOF
226 MockRead reads[] = {
227 MockRead(ASYNC, OK, 0) // EOF
268 MockRead reads[] = {
269 MockRead(ASYNC, OK, 0) // EOF
297 MockRead reads[] = {
298 MockRead(ASYNC, OK, 0) // EOF
332 MockRead reads[] = {
333 MockRead(ASYNC, OK, 0) // EO
[all...] |
| /external/chromium_org/net/http/ |
| http_network_layer_unittest.cc | 101 MockRead data_reads[] = {
102 MockRead("HTTP/1.1 200 OK\r\n"
104 MockRead("Bypass message"),
105 MockRead(SYNCHRONOUS, OK),
113 MockRead data_reads[],
124 MockRead data_reads[],
148 MockRead data_reads2[3];
150 data_reads2[data_reads2_index++] = MockRead("HTTP/1.0 200 OK\r\n"
153 data_reads2[data_reads2_index++] = MockRead(content.c_str());
154 data_reads2[data_reads2_index++] = MockRead(SYNCHRONOUS, OK)
[all...] |
| http_network_transaction_unittest.cc | 283 const MockRead* read_failure);
290 const MockRead* read_failure,
374 SimpleGetHelperResult SimpleGetHelper(MockRead data_reads[],
381 int64 ReadsSize(MockRead data_reads[], size_t reads_count) {
388 void ConnectStatusHelperWithExpectedStatus(const MockRead& status,
391 void ConnectStatusHelper(const MockRead& status);
646 MockRead data_reads[] = {
647 MockRead("HTTP/1.0 200 OK\r\n\r\n"),
648 MockRead("hello world"),
649 MockRead(SYNCHRONOUS, OK)
[all...] |
| http_stream_parser_unittest.cc | 211 // MockRead below.
214 MockRead reads[] = {
215 MockRead(ASYNC, 5, "HTTP/1.1 200 OK\r\n"),
216 MockRead(ASYNC, 6, "Content-Length: 8\r\n\r\n"),
217 MockRead(ASYNC, 7, "one.html"),
218 MockRead(SYNCHRONOUS, 0, 8), // EOF
326 MockRead truncated_status_reads[] = {
327 MockRead(SYNCHRONOUS, 1, "HTTP/1.1 20"),
328 MockRead(SYNCHRONOUS, 0, 2), // EOF
331 MockRead truncated_after_status_reads[] =
[all...] |
| http_proxy_client_socket_pool_unittest.cc | 255 void Initialize(MockRead* reads, size_t reads_count,
257 MockRead* spdy_reads, size_t spdy_reads_count,
371 MockRead reads[] = {
373 MockRead(ASYNC, 1, "HTTP/1.1 407 Proxy Authentication Required\r\n"),
374 MockRead(ASYNC, 2, "Proxy-Authenticate: Basic realm=\"MyRealm1\"\r\n"),
375 MockRead(ASYNC, 3, "Content-Length: 10\r\n\r\n"),
376 MockRead(ASYNC, 4, "0123456789"),
392 MockRead spdy_reads[] = {
394 MockRead(ASYNC, 0, 3)
442 MockRead reads[] =
[all...] |
| /external/chromium_org/net/websockets/ |
| websocket_basic_stream_test.cc | 85 StrictStaticSocketDataProvider(MockRead* reads,
119 scoped_ptr<ClientSocketHandle> MakeTransportSocket(MockRead reads[],
146 void CreateStream(MockRead reads[],
159 void CreateReadOnly(MockRead (&reads)[N]) {
183 void CreateRead(const MockRead& read) {
188 MockRead reads_[1];
216 reads_.reset(new MockRead[number_of_chunks]);
225 reads_[i] = MockRead(mode, start, len);
231 scoped_ptr<MockRead[]> reads_;
273 CreateRead(MockRead(SYNCHRONOUS, kSampleFrame, kSampleFrameSize))
[all...] |
| /external/chromium_org/google_apis/gcm/engine/ |
| connection_handler_impl_unittest.cc | 25 typedef std::vector<net::MockRead> ReadList;
239 ReadList read_list(1, net::MockRead(net::ASYNC,
264 ReadList read_list(1, net::MockRead(net::ASYNC,
285 ReadList read_list(1, net::MockRead(net::SYNCHRONOUS,
307 read_list.push_back(net::MockRead(net::ASYNC,
310 read_list.push_back(net::MockRead(net::SYNCHRONOUS,
329 ReadList read_list(1, net::MockRead(net::SYNCHRONOUS,
343 read_list[0] = net::MockRead(net::ASYNC,
369 read_list.push_back(net::MockRead(net::ASYNC,
372 read_list.push_back(net::MockRead(net::ASYNC
[all...] |
| /external/chromium_org/net/spdy/ |
| spdy_proxy_client_socket_unittest.cc | 72 void Initialize(MockRead* reads, size_t reads_count, MockWrite* writes,
175 void SpdyProxyClientSocketTest::Initialize(MockRead* reads,
393 MockRead reads[] = {
395 MockRead(ASYNC, 0, 2), // EOF
414 MockRead reads[] = {
416 MockRead(ASYNC, 0, 2), // EOF
435 MockRead reads[] = {
437 MockRead(ASYNC, 0, 2), // EOF
457 MockRead reads[] = {
458 CreateMockRead(*resp, 1, ASYNC), MockRead(ASYNC, 0, 3), // EO
[all...] |
| spdy_network_transaction_unittest.cc | 420 void ConnectStatusHelperWithExpectedStatus(const MockRead& status,
423 void ConnectStatusHelper(const MockRead& status);
746 MockRead reads[] = {
749 MockRead(ASYNC, 0, 0) // EOF
818 MockRead reads[] = {
821 MockRead(ASYNC, 0, 0) // EOF
872 MockRead reads[] =
[all...] |
| spdy_http_stream_unittest.cc | 90 void InitSessionDeterministic(MockRead* reads, size_t reads_count,
103 void InitSession(MockRead* reads, size_t reads_count,
139 MockRead reads[] = {
140 MockRead(ASYNC, 0, 0) // EOF
164 MockRead reads[] = {
166 MockRead(SYNCHRONOUS, 0, 3) // EOF
236 MockRead reads[] = {
241 MockRead(ASYNC, 0, 6) // EOF
328 std::vector<MockRead> reads;
331 reads.push_back(MockRead(SYNCHRONOUS, 0, seq++)); // EO
[all...] |
| spdy_session_unittest.cc | 239 MockRead reads[] = {MockRead(ASYNC, 0, 0), };
293 MockRead reads[] = {
323 MockRead reads[] = {
350 MockRead reads[] = {
352 MockRead(ASYNC, 0, 3) // EOF
431 MockRead reads[] = {
434 MockRead(ASYNC, 0, 4) // EOF
510 MockRead reads[] = {
512 MockRead(ASYNC, 0, 3) // EO
[all...] |
| spdy_session_pool_unittest.cc | 102 MockRead reads[] = {
103 MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever.
141 MockRead reads[] = {
142 MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever.
273 MockRead reads[] = {
274 MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever.
363 MockRead reads[] = {
364 MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever.
516 MockRead reads[] = {
517 MockRead(SYNCHRONOUS, ERR_IO_PENDING) // Stall forever
[all...] |
| /external/chromium_org/net/socket_stream/ |
| socket_stream_unittest.cc | 411 MockRead data_reads[] = {
412 MockRead(SocketStreamTest::kWebSocketHandshakeResponse),
414 MockRead(ASYNC, ERR_IO_PENDING)
527 MockRead data_reads1[] = {
528 MockRead("HTTP/1.1 407 Proxy Authentication Required\r\n"),
529 MockRead("Proxy-Authenticate: Basic realm=\"MyRealm1\"\r\n"),
530 MockRead("\r\n"),
542 MockRead data_reads2[] = {
543 MockRead("HTTP/1.1 200 Connection Established\r\n"),
544 MockRead("Proxy-agent: Apache/2.2.8\r\n")
[all...] |
| /external/chromium_org/google_apis/gcm/base/ |
| socket_stream_unittest.cc | 19 typedef std::vector<net::MockRead> ReadList;
198 BuildSocket(ReadList(1, net::MockRead(net::SYNCHRONOUS,
214 net::MockRead(net::SYNCHRONOUS,
218 net::MockRead(net::SYNCHRONOUS,
234 net::MockRead(net::SYNCHRONOUS, net::ERR_IO_PENDING));
236 net::MockRead(net::ASYNC, kReadData, first_read_len));
238 net::MockRead(net::ASYNC, &kReadData[first_read_len], second_read_len));
254 BuildSocket(ReadList(1, net::MockRead(net::SYNCHRONOUS,
273 BuildSocket(ReadList(1, net::MockRead(net::SYNCHRONOUS,
291 BuildSocket(ReadList(1, net::MockRead(net::SYNCHRONOUS, result))
[all...] |
| /external/chromium_org/jingle/glue/ |
| chrome_async_socket_unittest.cc | 46 virtual net::MockRead GetNextRead() OVERRIDE {
50 const net::MockRead pending_read(net::SYNCHRONOUS, net::ERR_IO_PENDING);
53 net::MockRead mock_read = reads_.front();
81 void AddRead(const net::MockRead& mock_read) {
97 std::deque<net::MockRead> reads_;
378 async_socket_data_provider_.AddRead(net::MockRead(kDummyData));
633 async_socket_data_provider_.AddRead(net::MockRead(kReadData));
647 async_socket_data_provider_.AddRead(net::MockRead(kReadData));
658 async_socket_data_provider_.AddRead(net::MockRead(kReadData2));
669 async_socket_data_provider_.AddRead(net::MockRead(kReadData))
[all...] |
| proxy_resolving_client_socket_unittest.cc | 82 net::MockRead reads[] = {
83 net::MockRead("HTTP/1.1 200 Success\r\n\r\n")
|
| /external/chromium_org/components/data_reduction_proxy/browser/ |
| data_reduction_proxy_protocol_unittest.cc | 33 using net::MockRead;
124 MockRead data_reads[] = {
125 MockRead(first_response),
126 MockRead(payload1.c_str()),
127 MockRead(net::SYNCHRONOUS, net::OK),
148 MockRead data_reads2[] = {
149 MockRead("HTTP/1.0 200 OK\r\n"
151 MockRead("content"),
152 MockRead(net::SYNCHRONOUS, net::OK),
773 MockRead data_reads[] =
[all...] |
