| 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/spdy/spdy_test_util_spdy2.h" | 5 #include "net/spdy/spdy_test_util_spdy2.h" |
| 6 | 6 |
| 7 #include <string> | 7 #include <string> |
| 8 | 8 |
| 9 #include "base/basictypes.h" | 9 #include "base/basictypes.h" |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 887 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 898 } | 898 } |
| 899 | 899 |
| 900 SpdySessionDependencies::SpdySessionDependencies() | 900 SpdySessionDependencies::SpdySessionDependencies() |
| 901 : host_resolver(new MockCachingHostResolver), | 901 : host_resolver(new MockCachingHostResolver), |
| 902 cert_verifier(new MockCertVerifier), | 902 cert_verifier(new MockCertVerifier), |
| 903 proxy_service(ProxyService::CreateDirect()), | 903 proxy_service(ProxyService::CreateDirect()), |
| 904 ssl_config_service(new SSLConfigServiceDefaults), | 904 ssl_config_service(new SSLConfigServiceDefaults), |
| 905 socket_factory(new MockClientSocketFactory), | 905 socket_factory(new MockClientSocketFactory), |
| 906 deterministic_socket_factory(new DeterministicMockClientSocketFactory), | 906 deterministic_socket_factory(new DeterministicMockClientSocketFactory), |
| 907 http_auth_handler_factory( | 907 http_auth_handler_factory( |
| 908 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())) { | 908 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), |
| 909 net_log(NULL) { |
| 909 // Note: The CancelledTransaction test does cleanup by running all | 910 // Note: The CancelledTransaction test does cleanup by running all |
| 910 // tasks in the message loop (RunAllPending). Unfortunately, that | 911 // tasks in the message loop (RunAllPending). Unfortunately, that |
| 911 // doesn't clean up tasks on the host resolver thread; and | 912 // doesn't clean up tasks on the host resolver thread; and |
| 912 // TCPConnectJob is currently not cancellable. Using synchronous | 913 // TCPConnectJob is currently not cancellable. Using synchronous |
| 913 // lookups allows the test to shutdown cleanly. Until we have | 914 // lookups allows the test to shutdown cleanly. Until we have |
| 914 // cancellable TCPConnectJobs, use synchronous lookups. | 915 // cancellable TCPConnectJobs, use synchronous lookups. |
| 915 host_resolver->set_synchronous_mode(true); | 916 host_resolver->set_synchronous_mode(true); |
| 916 } | 917 } |
| 917 | 918 |
| 918 SpdySessionDependencies::SpdySessionDependencies(ProxyService* proxy_service) | 919 SpdySessionDependencies::SpdySessionDependencies(ProxyService* proxy_service) |
| 919 : host_resolver(new MockHostResolver), | 920 : host_resolver(new MockHostResolver), |
| 920 cert_verifier(new MockCertVerifier), | 921 cert_verifier(new MockCertVerifier), |
| 921 proxy_service(proxy_service), | 922 proxy_service(proxy_service), |
| 922 ssl_config_service(new SSLConfigServiceDefaults), | 923 ssl_config_service(new SSLConfigServiceDefaults), |
| 923 socket_factory(new MockClientSocketFactory), | 924 socket_factory(new MockClientSocketFactory), |
| 924 deterministic_socket_factory(new DeterministicMockClientSocketFactory), | 925 deterministic_socket_factory(new DeterministicMockClientSocketFactory), |
| 925 http_auth_handler_factory( | 926 http_auth_handler_factory( |
| 926 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())) {} | 927 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), |
| 928 net_log(NULL) {} |
| 927 | 929 |
| 928 SpdySessionDependencies::~SpdySessionDependencies() {} | 930 SpdySessionDependencies::~SpdySessionDependencies() {} |
| 929 | 931 |
| 930 // static | 932 // static |
| 931 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( | 933 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( |
| 932 SpdySessionDependencies* session_deps) { | 934 SpdySessionDependencies* session_deps) { |
| 933 net::HttpNetworkSession::Params params; | 935 net::HttpNetworkSession::Params params = session_deps->CreateSessionParams(); |
| 934 params.client_socket_factory = session_deps->socket_factory.get(); | 936 params.client_socket_factory = session_deps->socket_factory.get(); |
| 935 params.host_resolver = session_deps->host_resolver.get(); | |
| 936 params.cert_verifier = session_deps->cert_verifier.get(); | |
| 937 params.proxy_service = session_deps->proxy_service.get(); | |
| 938 params.ssl_config_service = session_deps->ssl_config_service; | |
| 939 params.http_auth_handler_factory = | |
| 940 session_deps->http_auth_handler_factory.get(); | |
| 941 params.http_server_properties = &session_deps->http_server_properties; | |
| 942 params.trusted_spdy_proxy = | |
| 943 session_deps->trusted_spdy_proxy; | |
| 944 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 937 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 945 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 938 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 946 pool_peer.EnableSendingInitialSettings(false); | 939 pool_peer.EnableSendingInitialSettings(false); |
| 947 return http_session; | 940 return http_session; |
| 948 } | 941 } |
| 949 | 942 |
| 950 // static | 943 // static |
| 951 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSessionDeterministic( | 944 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSessionDeterministic( |
| 952 SpdySessionDependencies* session_deps) { | 945 SpdySessionDependencies* session_deps) { |
| 953 net::HttpNetworkSession::Params params; | 946 net::HttpNetworkSession::Params params = session_deps->CreateSessionParams(); |
| 954 params.client_socket_factory = | 947 params.client_socket_factory = |
| 955 session_deps->deterministic_socket_factory.get(); | 948 session_deps->deterministic_socket_factory.get(); |
| 956 params.host_resolver = session_deps->host_resolver.get(); | |
| 957 params.cert_verifier = session_deps->cert_verifier.get(); | |
| 958 params.proxy_service = session_deps->proxy_service.get(); | |
| 959 params.ssl_config_service = session_deps->ssl_config_service; | |
| 960 params.http_auth_handler_factory = | |
| 961 session_deps->http_auth_handler_factory.get(); | |
| 962 params.http_server_properties = &session_deps->http_server_properties; | |
| 963 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 949 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 964 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 950 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 965 pool_peer.EnableSendingInitialSettings(false); | 951 pool_peer.EnableSendingInitialSettings(false); |
| 966 return http_session; | 952 return http_session; |
| 967 } | 953 } |
| 968 | 954 |
| 955 net::HttpNetworkSession::Params SpdySessionDependencies::CreateSessionParams() { |
| 956 net::HttpNetworkSession::Params params; |
| 957 params.host_resolver = host_resolver.get(); |
| 958 params.cert_verifier = cert_verifier.get(); |
| 959 params.proxy_service = proxy_service.get(); |
| 960 params.ssl_config_service = ssl_config_service; |
| 961 params.http_auth_handler_factory = http_auth_handler_factory.get(); |
| 962 params.http_server_properties = &http_server_properties; |
| 963 params.trusted_spdy_proxy = trusted_spdy_proxy; |
| 964 params.net_log = net_log; |
| 965 return params; |
| 966 } |
| 967 |
| 969 SpdyURLRequestContext::SpdyURLRequestContext() | 968 SpdyURLRequestContext::SpdyURLRequestContext() |
| 970 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { | 969 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { |
| 971 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); | 970 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); |
| 972 storage_.set_cert_verifier(new MockCertVerifier); | 971 storage_.set_cert_verifier(new MockCertVerifier); |
| 973 storage_.set_proxy_service(ProxyService::CreateDirect()); | 972 storage_.set_proxy_service(ProxyService::CreateDirect()); |
| 974 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); | 973 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); |
| 975 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( | 974 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( |
| 976 host_resolver())); | 975 host_resolver())); |
| 977 storage_.set_http_server_properties(new HttpServerPropertiesImpl); | 976 storage_.set_http_server_properties(new HttpServerPropertiesImpl); |
| 978 net::HttpNetworkSession::Params params; | 977 net::HttpNetworkSession::Params params; |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1021 } | 1020 } |
| 1022 | 1021 |
| 1023 SpdyTestStateHelper::~SpdyTestStateHelper() { | 1022 SpdyTestStateHelper::~SpdyTestStateHelper() { |
| 1024 SpdySession::ResetStaticSettingsToInit(); | 1023 SpdySession::ResetStaticSettingsToInit(); |
| 1025 // TODO(rch): save/restore this value | 1024 // TODO(rch): save/restore this value |
| 1026 BufferedSpdyFramer::set_enable_compression_default(true); | 1025 BufferedSpdyFramer::set_enable_compression_default(true); |
| 1027 } | 1026 } |
| 1028 | 1027 |
| 1029 } // namespace test_spdy2 | 1028 } // namespace test_spdy2 |
| 1030 } // namespace net | 1029 } // namespace net |
| OLD | NEW |