Chromium Code Reviews| 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 <vector> | 5 #include <vector> |
| 6 | 6 |
| 7 #include "base/basictypes.h" | 7 #include "base/basictypes.h" |
| 8 #include "base/compiler_specific.h" | 8 #include "base/compiler_specific.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/stl_util.h" | 10 #include "base/stl_util.h" |
| (...skipping 402 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 413 net::NetLog::TYPE_QUIC_SESSION_STREAM_FRAME_RECEIVED, | 413 net::NetLog::TYPE_QUIC_SESSION_STREAM_FRAME_RECEIVED, |
| 414 net::NetLog::PHASE_NONE); | 414 net::NetLog::PHASE_NONE); |
| 415 EXPECT_LT(0, pos); | 415 EXPECT_LT(0, pos); |
| 416 | 416 |
| 417 int log_stream_id; | 417 int log_stream_id; |
| 418 ASSERT_TRUE(entries[pos].GetIntegerValue("stream_id", &log_stream_id)); | 418 ASSERT_TRUE(entries[pos].GetIntegerValue("stream_id", &log_stream_id)); |
| 419 EXPECT_EQ(3, log_stream_id); | 419 EXPECT_EQ(3, log_stream_id); |
| 420 } | 420 } |
| 421 | 421 |
| 422 TEST_P(QuicNetworkTransactionTest, QuicProxy) { | 422 TEST_P(QuicNetworkTransactionTest, QuicProxy) { |
| 423 params_.enable_quic_for_proxies = true; | |
| 423 proxy_service_.reset( | 424 proxy_service_.reset( |
| 424 ProxyService::CreateFixedFromPacResult("QUIC myproxy:70")); | 425 ProxyService::CreateFixedFromPacResult("QUIC myproxy:70")); |
| 425 | 426 |
| 426 MockQuicData mock_quic_data; | 427 MockQuicData mock_quic_data; |
| 427 mock_quic_data.AddWrite( | 428 mock_quic_data.AddWrite( |
| 428 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, | 429 ConstructRequestHeadersPacket(1, kClientDataStreamId1, true, true, |
| 429 GetRequestHeaders("GET", "http", "/"))); | 430 GetRequestHeaders("GET", "http", "/"))); |
| 430 mock_quic_data.AddRead( | 431 mock_quic_data.AddRead( |
| 431 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, | 432 ConstructResponseHeadersPacket(1, kClientDataStreamId1, false, false, |
| 432 GetResponseHeaders("200 OK"))); | 433 GetResponseHeaders("200 OK"))); |
| 433 mock_quic_data.AddRead( | 434 mock_quic_data.AddRead( |
| 434 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); | 435 ConstructDataPacket(2, kClientDataStreamId1, false, true, 0, "hello!")); |
| 435 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); | 436 mock_quic_data.AddWrite(ConstructAckPacket(2, 1)); |
| 436 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF | 437 mock_quic_data.AddRead(SYNCHRONOUS, 0); // EOF |
| 437 | 438 |
| 438 mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); | 439 mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 1); |
| 439 | 440 |
| 440 // There is no need to set up an alternate protocol job, because | 441 // There is no need to set up an alternate protocol job, because |
| 441 // no attempt will be made to speak to the proxy over TCP. | 442 // no attempt will be made to speak to the proxy over TCP. |
| 442 | 443 |
| 443 CreateSession(); | 444 CreateSession(); |
| 444 | 445 |
| 445 SendRequestAndExpectQuicResponseFromProxy("hello!"); | 446 SendRequestAndExpectQuicResponseFromProxy("hello!"); |
| 447 params_.enable_quic_for_proxies = false; | |
|
Ryan Hamilton
2015/02/14 00:09:23
I don't think you need this line, do you?
tbansal1
2015/02/14 01:06:11
Done.
| |
| 446 } | 448 } |
| 447 | 449 |
| 448 TEST_P(QuicNetworkTransactionTest, ForceQuicWithErrorConnecting) { | 450 TEST_P(QuicNetworkTransactionTest, ForceQuicWithErrorConnecting) { |
| 449 params_.origin_to_force_quic_on = | 451 params_.origin_to_force_quic_on = |
| 450 HostPortPair::FromString("www.google.com:80"); | 452 HostPortPair::FromString("www.google.com:80"); |
| 451 | 453 |
| 452 MockQuicData mock_quic_data; | 454 MockQuicData mock_quic_data; |
| 453 mock_quic_data.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); | 455 mock_quic_data.AddRead(ASYNC, ERR_SOCKET_NOT_CONNECTED); |
| 454 | 456 |
| 455 mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 0); | 457 mock_quic_data.AddDelayedSocketDataToFactory(&socket_factory_, 0); |
| (...skipping 607 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 1063 nullptr, | 1065 nullptr, |
| 1064 net_log_.bound()); | 1066 net_log_.bound()); |
| 1065 | 1067 |
| 1066 CreateSessionWithNextProtos(); | 1068 CreateSessionWithNextProtos(); |
| 1067 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); | 1069 AddQuicAlternateProtocolMapping(MockCryptoClientStream::ZERO_RTT); |
| 1068 SendRequestAndExpectHttpResponse("hello world"); | 1070 SendRequestAndExpectHttpResponse("hello world"); |
| 1069 } | 1071 } |
| 1070 | 1072 |
| 1071 } // namespace test | 1073 } // namespace test |
| 1072 } // namespace net | 1074 } // namespace net |
| OLD | NEW |