| 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/http/http_proxy_client_socket_pool.h" | 5 #include "net/http/http_proxy_client_socket_pool.h" |
| 6 | 6 |
| 7 #include <utility> | 7 #include <utility> |
| 8 | 8 |
| 9 #include "base/callback.h" | 9 #include "base/callback.h" |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 344 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 355 MockWrite(ASYNC, 0, request.c_str()), | 355 MockWrite(ASYNC, 0, request.c_str()), |
| 356 }; | 356 }; |
| 357 MockRead reads[] = { | 357 MockRead reads[] = { |
| 358 MockRead(ASYNC, 1, "HTTP/1.1 200 Connection Established\r\n\r\n"), | 358 MockRead(ASYNC, 1, "HTTP/1.1 200 Connection Established\r\n\r\n"), |
| 359 }; | 359 }; |
| 360 | 360 |
| 361 SpdySerializedFrame req( | 361 SpdySerializedFrame req( |
| 362 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, LOW, | 362 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, LOW, |
| 363 HostPortPair("www.google.com", 443))); | 363 HostPortPair("www.google.com", 443))); |
| 364 MockWrite spdy_writes[] = {CreateMockWrite(req, 0, ASYNC)}; | 364 MockWrite spdy_writes[] = {CreateMockWrite(req, 0, ASYNC)}; |
| 365 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); | 365 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(NULL, 0, 1)); |
| 366 MockRead spdy_reads[] = { | 366 MockRead spdy_reads[] = { |
| 367 CreateMockRead(resp, 1, ASYNC), | 367 CreateMockRead(resp, 1, ASYNC), |
| 368 // Connection stays open. | 368 // Connection stays open. |
| 369 MockRead(SYNCHRONOUS, ERR_IO_PENDING, 2), | 369 MockRead(SYNCHRONOUS, ERR_IO_PENDING, 2), |
| 370 }; | 370 }; |
| 371 | 371 |
| 372 Initialize(reads, arraysize(reads), writes, arraysize(writes), | 372 Initialize(reads, arraysize(reads), writes, arraysize(writes), |
| 373 spdy_reads, arraysize(spdy_reads), spdy_writes, | 373 spdy_reads, arraysize(spdy_reads), spdy_writes, |
| 374 arraysize(spdy_writes)); | 374 arraysize(spdy_writes)); |
| 375 AddAuthToCache(); | 375 AddAuthToCache(); |
| (...skipping 19 matching lines...) Expand all Loading... |
| 395 // SPDY session's socket request on Init (if applicable). | 395 // SPDY session's socket request on Init (if applicable). |
| 396 TEST_P(HttpProxyClientSocketPoolTest, | 396 TEST_P(HttpProxyClientSocketPoolTest, |
| 397 SetSpdySessionSocketRequestPriorityOnInit) { | 397 SetSpdySessionSocketRequestPriorityOnInit) { |
| 398 if (GetParam() != SPDY) | 398 if (GetParam() != SPDY) |
| 399 return; | 399 return; |
| 400 | 400 |
| 401 SpdySerializedFrame req( | 401 SpdySerializedFrame req( |
| 402 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, MEDIUM, | 402 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, MEDIUM, |
| 403 HostPortPair("www.google.com", 443))); | 403 HostPortPair("www.google.com", 443))); |
| 404 MockWrite spdy_writes[] = {CreateMockWrite(req, 0, ASYNC)}; | 404 MockWrite spdy_writes[] = {CreateMockWrite(req, 0, ASYNC)}; |
| 405 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetSynReply(NULL, 0, 1)); | 405 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(NULL, 0, 1)); |
| 406 MockRead spdy_reads[] = {CreateMockRead(resp, 1, ASYNC), | 406 MockRead spdy_reads[] = {CreateMockRead(resp, 1, ASYNC), |
| 407 MockRead(ASYNC, 0, 2)}; | 407 MockRead(ASYNC, 0, 2)}; |
| 408 | 408 |
| 409 Initialize(NULL, 0, NULL, 0, | 409 Initialize(NULL, 0, NULL, 0, |
| 410 spdy_reads, arraysize(spdy_reads), | 410 spdy_reads, arraysize(spdy_reads), |
| 411 spdy_writes, arraysize(spdy_writes)); | 411 spdy_writes, arraysize(spdy_writes)); |
| 412 AddAuthToCache(); | 412 AddAuthToCache(); |
| 413 | 413 |
| 414 EXPECT_EQ(ERR_IO_PENDING, | 414 EXPECT_EQ(ERR_IO_PENDING, |
| 415 handle_.Init("a", CreateTunnelParams(NULL), MEDIUM, | 415 handle_.Init("a", CreateTunnelParams(NULL), MEDIUM, |
| (...skipping 168 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 584 MockRead(ASYNC, 1, "HTTP/1.1 304 Not Modified\r\n\r\n"), | 584 MockRead(ASYNC, 1, "HTTP/1.1 304 Not Modified\r\n\r\n"), |
| 585 }; | 585 }; |
| 586 SpdySerializedFrame req( | 586 SpdySerializedFrame req( |
| 587 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, LOW, | 587 spdy_util_.ConstructSpdyConnect(kAuthHeaders, kAuthHeadersSize, 1, LOW, |
| 588 HostPortPair("www.google.com", 443))); | 588 HostPortPair("www.google.com", 443))); |
| 589 SpdySerializedFrame rst( | 589 SpdySerializedFrame rst( |
| 590 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); | 590 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); |
| 591 MockWrite spdy_writes[] = { | 591 MockWrite spdy_writes[] = { |
| 592 CreateMockWrite(req, 0, ASYNC), CreateMockWrite(rst, 2, ASYNC), | 592 CreateMockWrite(req, 0, ASYNC), CreateMockWrite(rst, 2, ASYNC), |
| 593 }; | 593 }; |
| 594 SpdySerializedFrame resp(spdy_util_.ConstructSpdySynReplyError(1)); | 594 SpdySerializedFrame resp(spdy_util_.ConstructSpdyReplyError(1)); |
| 595 MockRead spdy_reads[] = { | 595 MockRead spdy_reads[] = { |
| 596 CreateMockRead(resp, 1, ASYNC), MockRead(ASYNC, 0, 3), | 596 CreateMockRead(resp, 1, ASYNC), MockRead(ASYNC, 0, 3), |
| 597 }; | 597 }; |
| 598 | 598 |
| 599 Initialize(reads, arraysize(reads), writes, arraysize(writes), | 599 Initialize(reads, arraysize(reads), writes, arraysize(writes), |
| 600 spdy_reads, arraysize(spdy_reads), spdy_writes, | 600 spdy_reads, arraysize(spdy_reads), spdy_writes, |
| 601 arraysize(spdy_writes)); | 601 arraysize(spdy_writes)); |
| 602 AddAuthToCache(); | 602 AddAuthToCache(); |
| 603 | 603 |
| 604 int rv = handle_.Init("a", CreateTunnelParams(NULL), LOW, | 604 int rv = handle_.Init("a", CreateTunnelParams(NULL), LOW, |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 640 | 640 |
| 641 MockWrite spdy_writes[] = { | 641 MockWrite spdy_writes[] = { |
| 642 CreateMockWrite(req, 0, ASYNC), CreateMockWrite(rst, 3, ASYNC), | 642 CreateMockWrite(req, 0, ASYNC), CreateMockWrite(rst, 3, ASYNC), |
| 643 }; | 643 }; |
| 644 | 644 |
| 645 const char* const responseHeaders[] = { | 645 const char* const responseHeaders[] = { |
| 646 "location", redirectTarget.c_str(), | 646 "location", redirectTarget.c_str(), |
| 647 "set-cookie", "foo=bar", | 647 "set-cookie", "foo=bar", |
| 648 }; | 648 }; |
| 649 const int responseHeadersSize = arraysize(responseHeaders) / 2; | 649 const int responseHeadersSize = arraysize(responseHeaders) / 2; |
| 650 SpdySerializedFrame resp(spdy_util_.ConstructSpdySynReplyError( | 650 SpdySerializedFrame resp(spdy_util_.ConstructSpdyReplyError( |
| 651 "302 Found", responseHeaders, responseHeadersSize, 1)); | 651 "302 Found", responseHeaders, responseHeadersSize, 1)); |
| 652 MockRead spdy_reads[] = { | 652 MockRead spdy_reads[] = { |
| 653 CreateMockRead(resp, 1, ASYNC), MockRead(ASYNC, 0, 2), | 653 CreateMockRead(resp, 1, ASYNC), MockRead(ASYNC, 0, 2), |
| 654 }; | 654 }; |
| 655 | 655 |
| 656 Initialize(reads, arraysize(reads), writes, arraysize(writes), | 656 Initialize(reads, arraysize(reads), writes, arraysize(writes), |
| 657 spdy_reads, arraysize(spdy_reads), spdy_writes, | 657 spdy_reads, arraysize(spdy_reads), spdy_writes, |
| 658 arraysize(spdy_writes)); | 658 arraysize(spdy_writes)); |
| 659 AddAuthToCache(); | 659 AddAuthToCache(); |
| 660 | 660 |
| (...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 692 // Make sure Location header was included and correct. | 692 // Make sure Location header was included and correct. |
| 693 std::string location; | 693 std::string location; |
| 694 EXPECT_TRUE(headers->IsRedirect(&location)); | 694 EXPECT_TRUE(headers->IsRedirect(&location)); |
| 695 EXPECT_EQ(location, redirectTarget); | 695 EXPECT_EQ(location, redirectTarget); |
| 696 } | 696 } |
| 697 } | 697 } |
| 698 | 698 |
| 699 // It would be nice to also test the timeouts in HttpProxyClientSocketPool. | 699 // It would be nice to also test the timeouts in HttpProxyClientSocketPool. |
| 700 | 700 |
| 701 } // namespace net | 701 } // namespace net |
| OLD | NEW |