| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_network_transaction.h" | 5 #include "net/http/http_network_transaction.h" |
| 6 | 6 |
| 7 #include <math.h> // ceil | 7 #include <math.h> // ceil |
| 8 #include <stdarg.h> | 8 #include <stdarg.h> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <vector> | 10 #include <vector> |
| (...skipping 7598 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 7609 | 7609 |
| 7610 HttpNetworkSessionPeer peer(session); | 7610 HttpNetworkSessionPeer peer(session); |
| 7611 CaptureGroupNameTransportSocketPool* transport_conn_pool = | 7611 CaptureGroupNameTransportSocketPool* transport_conn_pool = |
| 7612 new CaptureGroupNameTransportSocketPool(NULL, NULL); | 7612 new CaptureGroupNameTransportSocketPool(NULL, NULL); |
| 7613 CaptureGroupNameSSLSocketPool* ssl_conn_pool = | 7613 CaptureGroupNameSSLSocketPool* ssl_conn_pool = |
| 7614 new CaptureGroupNameSSLSocketPool(NULL, NULL); | 7614 new CaptureGroupNameSSLSocketPool(NULL, NULL); |
| 7615 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( | 7615 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( |
| 7616 new MockClientSocketPoolManager); | 7616 new MockClientSocketPoolManager); |
| 7617 mock_pool_manager->SetTransportSocketPool(transport_conn_pool); | 7617 mock_pool_manager->SetTransportSocketPool(transport_conn_pool); |
| 7618 mock_pool_manager->SetSSLSocketPool(ssl_conn_pool); | 7618 mock_pool_manager->SetSSLSocketPool(ssl_conn_pool); |
| 7619 peer.SetClientSocketPoolManager( | 7619 peer.SetClientSocketPoolManager(mock_pool_manager.Pass()); |
| 7620 mock_pool_manager.PassAs<ClientSocketPoolManager>()); | |
| 7621 | 7620 |
| 7622 EXPECT_EQ(ERR_IO_PENDING, | 7621 EXPECT_EQ(ERR_IO_PENDING, |
| 7623 GroupNameTransactionHelper(tests[i].url, session)); | 7622 GroupNameTransactionHelper(tests[i].url, session)); |
| 7624 if (tests[i].ssl) | 7623 if (tests[i].ssl) |
| 7625 EXPECT_EQ(tests[i].expected_group_name, | 7624 EXPECT_EQ(tests[i].expected_group_name, |
| 7626 ssl_conn_pool->last_group_name_received()); | 7625 ssl_conn_pool->last_group_name_received()); |
| 7627 else | 7626 else |
| 7628 EXPECT_EQ(tests[i].expected_group_name, | 7627 EXPECT_EQ(tests[i].expected_group_name, |
| 7629 transport_conn_pool->last_group_name_received()); | 7628 transport_conn_pool->last_group_name_received()); |
| 7630 } | 7629 } |
| (...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 7676 HostPortPair proxy_host("http_proxy", 80); | 7675 HostPortPair proxy_host("http_proxy", 80); |
| 7677 CaptureGroupNameHttpProxySocketPool* http_proxy_pool = | 7676 CaptureGroupNameHttpProxySocketPool* http_proxy_pool = |
| 7678 new CaptureGroupNameHttpProxySocketPool(NULL, NULL); | 7677 new CaptureGroupNameHttpProxySocketPool(NULL, NULL); |
| 7679 CaptureGroupNameSSLSocketPool* ssl_conn_pool = | 7678 CaptureGroupNameSSLSocketPool* ssl_conn_pool = |
| 7680 new CaptureGroupNameSSLSocketPool(NULL, NULL); | 7679 new CaptureGroupNameSSLSocketPool(NULL, NULL); |
| 7681 | 7680 |
| 7682 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( | 7681 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( |
| 7683 new MockClientSocketPoolManager); | 7682 new MockClientSocketPoolManager); |
| 7684 mock_pool_manager->SetSocketPoolForHTTPProxy(proxy_host, http_proxy_pool); | 7683 mock_pool_manager->SetSocketPoolForHTTPProxy(proxy_host, http_proxy_pool); |
| 7685 mock_pool_manager->SetSocketPoolForSSLWithProxy(proxy_host, ssl_conn_pool); | 7684 mock_pool_manager->SetSocketPoolForSSLWithProxy(proxy_host, ssl_conn_pool); |
| 7686 peer.SetClientSocketPoolManager( | 7685 peer.SetClientSocketPoolManager(mock_pool_manager.Pass()); |
| 7687 mock_pool_manager.PassAs<ClientSocketPoolManager>()); | |
| 7688 | 7686 |
| 7689 EXPECT_EQ(ERR_IO_PENDING, | 7687 EXPECT_EQ(ERR_IO_PENDING, |
| 7690 GroupNameTransactionHelper(tests[i].url, session)); | 7688 GroupNameTransactionHelper(tests[i].url, session)); |
| 7691 if (tests[i].ssl) | 7689 if (tests[i].ssl) |
| 7692 EXPECT_EQ(tests[i].expected_group_name, | 7690 EXPECT_EQ(tests[i].expected_group_name, |
| 7693 ssl_conn_pool->last_group_name_received()); | 7691 ssl_conn_pool->last_group_name_received()); |
| 7694 else | 7692 else |
| 7695 EXPECT_EQ(tests[i].expected_group_name, | 7693 EXPECT_EQ(tests[i].expected_group_name, |
| 7696 http_proxy_pool->last_group_name_received()); | 7694 http_proxy_pool->last_group_name_received()); |
| 7697 } | 7695 } |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 7747 HostPortPair proxy_host("socks_proxy", 1080); | 7745 HostPortPair proxy_host("socks_proxy", 1080); |
| 7748 CaptureGroupNameSOCKSSocketPool* socks_conn_pool = | 7746 CaptureGroupNameSOCKSSocketPool* socks_conn_pool = |
| 7749 new CaptureGroupNameSOCKSSocketPool(NULL, NULL); | 7747 new CaptureGroupNameSOCKSSocketPool(NULL, NULL); |
| 7750 CaptureGroupNameSSLSocketPool* ssl_conn_pool = | 7748 CaptureGroupNameSSLSocketPool* ssl_conn_pool = |
| 7751 new CaptureGroupNameSSLSocketPool(NULL, NULL); | 7749 new CaptureGroupNameSSLSocketPool(NULL, NULL); |
| 7752 | 7750 |
| 7753 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( | 7751 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( |
| 7754 new MockClientSocketPoolManager); | 7752 new MockClientSocketPoolManager); |
| 7755 mock_pool_manager->SetSocketPoolForSOCKSProxy(proxy_host, socks_conn_pool); | 7753 mock_pool_manager->SetSocketPoolForSOCKSProxy(proxy_host, socks_conn_pool); |
| 7756 mock_pool_manager->SetSocketPoolForSSLWithProxy(proxy_host, ssl_conn_pool); | 7754 mock_pool_manager->SetSocketPoolForSSLWithProxy(proxy_host, ssl_conn_pool); |
| 7757 peer.SetClientSocketPoolManager( | 7755 peer.SetClientSocketPoolManager(mock_pool_manager.Pass()); |
| 7758 mock_pool_manager.PassAs<ClientSocketPoolManager>()); | |
| 7759 | 7756 |
| 7760 scoped_ptr<HttpTransaction> trans( | 7757 scoped_ptr<HttpTransaction> trans( |
| 7761 new HttpNetworkTransaction(DEFAULT_PRIORITY, session.get())); | 7758 new HttpNetworkTransaction(DEFAULT_PRIORITY, session.get())); |
| 7762 | 7759 |
| 7763 EXPECT_EQ(ERR_IO_PENDING, | 7760 EXPECT_EQ(ERR_IO_PENDING, |
| 7764 GroupNameTransactionHelper(tests[i].url, session)); | 7761 GroupNameTransactionHelper(tests[i].url, session)); |
| 7765 if (tests[i].ssl) | 7762 if (tests[i].ssl) |
| 7766 EXPECT_EQ(tests[i].expected_group_name, | 7763 EXPECT_EQ(tests[i].expected_group_name, |
| 7767 ssl_conn_pool->last_group_name_received()); | 7764 ssl_conn_pool->last_group_name_received()); |
| 7768 else | 7765 else |
| (...skipping 2032 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 9801 TransportClientSocketPool* transport_pool = new TransportClientSocketPool( | 9798 TransportClientSocketPool* transport_pool = new TransportClientSocketPool( |
| 9802 50, // Max sockets for pool | 9799 50, // Max sockets for pool |
| 9803 1, // Max sockets per group | 9800 1, // Max sockets per group |
| 9804 &transport_pool_histograms, | 9801 &transport_pool_histograms, |
| 9805 session_deps_.host_resolver.get(), | 9802 session_deps_.host_resolver.get(), |
| 9806 session_deps_.socket_factory.get(), | 9803 session_deps_.socket_factory.get(), |
| 9807 session_deps_.net_log); | 9804 session_deps_.net_log); |
| 9808 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( | 9805 scoped_ptr<MockClientSocketPoolManager> mock_pool_manager( |
| 9809 new MockClientSocketPoolManager); | 9806 new MockClientSocketPoolManager); |
| 9810 mock_pool_manager->SetTransportSocketPool(transport_pool); | 9807 mock_pool_manager->SetTransportSocketPool(transport_pool); |
| 9811 session_peer.SetClientSocketPoolManager( | 9808 session_peer.SetClientSocketPoolManager(mock_pool_manager.Pass()); |
| 9812 mock_pool_manager.PassAs<ClientSocketPoolManager>()); | |
| 9813 | 9809 |
| 9814 scoped_ptr<HttpTransaction> trans( | 9810 scoped_ptr<HttpTransaction> trans( |
| 9815 new HttpNetworkTransaction(DEFAULT_PRIORITY, session.get())); | 9811 new HttpNetworkTransaction(DEFAULT_PRIORITY, session.get())); |
| 9816 TestCompletionCallback callback; | 9812 TestCompletionCallback callback; |
| 9817 | 9813 |
| 9818 const MockWrite kGet( | 9814 const MockWrite kGet( |
| 9819 "GET / HTTP/1.1\r\n" | 9815 "GET / HTTP/1.1\r\n" |
| 9820 "Host: www.example.com\r\n" | 9816 "Host: www.example.com\r\n" |
| 9821 "Connection: keep-alive\r\n\r\n"); | 9817 "Connection: keep-alive\r\n\r\n"); |
| 9822 const MockWrite kGetAuth( | 9818 const MockWrite kGetAuth( |
| (...skipping 3383 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 13206 EXPECT_EQ(ERR_IO_PENDING, rv); | 13202 EXPECT_EQ(ERR_IO_PENDING, rv); |
| 13207 | 13203 |
| 13208 rv = callback.WaitForResult(); | 13204 rv = callback.WaitForResult(); |
| 13209 EXPECT_EQ(ERR_CONNECTION_RESET, rv); | 13205 EXPECT_EQ(ERR_CONNECTION_RESET, rv); |
| 13210 | 13206 |
| 13211 const HttpResponseInfo* response = trans->GetResponseInfo(); | 13207 const HttpResponseInfo* response = trans->GetResponseInfo(); |
| 13212 EXPECT_TRUE(response == NULL); | 13208 EXPECT_TRUE(response == NULL); |
| 13213 } | 13209 } |
| 13214 | 13210 |
| 13215 } // namespace net | 13211 } // namespace net |
| OLD | NEW |