| 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_spdy3.h" | 5 #include "net/spdy/spdy_test_util_spdy3.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 922 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 933 } | 933 } |
| 934 | 934 |
| 935 SpdySessionDependencies::SpdySessionDependencies() | 935 SpdySessionDependencies::SpdySessionDependencies() |
| 936 : host_resolver(new MockCachingHostResolver), | 936 : host_resolver(new MockCachingHostResolver), |
| 937 cert_verifier(new MockCertVerifier), | 937 cert_verifier(new MockCertVerifier), |
| 938 proxy_service(ProxyService::CreateDirect()), | 938 proxy_service(ProxyService::CreateDirect()), |
| 939 ssl_config_service(new SSLConfigServiceDefaults), | 939 ssl_config_service(new SSLConfigServiceDefaults), |
| 940 socket_factory(new MockClientSocketFactory), | 940 socket_factory(new MockClientSocketFactory), |
| 941 deterministic_socket_factory(new DeterministicMockClientSocketFactory), | 941 deterministic_socket_factory(new DeterministicMockClientSocketFactory), |
| 942 http_auth_handler_factory( | 942 http_auth_handler_factory( |
| 943 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())) { | 943 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), |
| 944 net_log(NULL) { |
| 944 // Note: The CancelledTransaction test does cleanup by running all | 945 // Note: The CancelledTransaction test does cleanup by running all |
| 945 // tasks in the message loop (RunAllPending). Unfortunately, that | 946 // tasks in the message loop (RunAllPending). Unfortunately, that |
| 946 // doesn't clean up tasks on the host resolver thread; and | 947 // doesn't clean up tasks on the host resolver thread; and |
| 947 // TCPConnectJob is currently not cancellable. Using synchronous | 948 // TCPConnectJob is currently not cancellable. Using synchronous |
| 948 // lookups allows the test to shutdown cleanly. Until we have | 949 // lookups allows the test to shutdown cleanly. Until we have |
| 949 // cancellable TCPConnectJobs, use synchronous lookups. | 950 // cancellable TCPConnectJobs, use synchronous lookups. |
| 950 host_resolver->set_synchronous_mode(true); | 951 host_resolver->set_synchronous_mode(true); |
| 951 } | 952 } |
| 952 | 953 |
| 953 SpdySessionDependencies::SpdySessionDependencies(ProxyService* proxy_service) | 954 SpdySessionDependencies::SpdySessionDependencies(ProxyService* proxy_service) |
| 954 : host_resolver(new MockHostResolver), | 955 : host_resolver(new MockHostResolver), |
| 955 cert_verifier(new MockCertVerifier), | 956 cert_verifier(new MockCertVerifier), |
| 956 proxy_service(proxy_service), | 957 proxy_service(proxy_service), |
| 957 ssl_config_service(new SSLConfigServiceDefaults), | 958 ssl_config_service(new SSLConfigServiceDefaults), |
| 958 socket_factory(new MockClientSocketFactory), | 959 socket_factory(new MockClientSocketFactory), |
| 959 deterministic_socket_factory(new DeterministicMockClientSocketFactory), | 960 deterministic_socket_factory(new DeterministicMockClientSocketFactory), |
| 960 http_auth_handler_factory( | 961 http_auth_handler_factory( |
| 961 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())) {} | 962 HttpAuthHandlerFactory::CreateDefault(host_resolver.get())), |
| 963 net_log(NULL) {} |
| 962 | 964 |
| 963 SpdySessionDependencies::~SpdySessionDependencies() {} | 965 SpdySessionDependencies::~SpdySessionDependencies() {} |
| 964 | 966 |
| 965 // static | 967 // static |
| 966 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( | 968 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSession( |
| 967 SpdySessionDependencies* session_deps) { | 969 SpdySessionDependencies* session_deps) { |
| 968 net::HttpNetworkSession::Params params; | 970 net::HttpNetworkSession::Params params = session_deps->CreateSessionParams(); |
| 969 params.client_socket_factory = session_deps->socket_factory.get(); | 971 params.client_socket_factory = session_deps->socket_factory.get(); |
| 970 params.host_resolver = session_deps->host_resolver.get(); | |
| 971 params.cert_verifier = session_deps->cert_verifier.get(); | |
| 972 params.proxy_service = session_deps->proxy_service.get(); | |
| 973 params.ssl_config_service = session_deps->ssl_config_service; | |
| 974 params.http_auth_handler_factory = | |
| 975 session_deps->http_auth_handler_factory.get(); | |
| 976 params.http_server_properties = &session_deps->http_server_properties; | |
| 977 params.trusted_spdy_proxy = | |
| 978 session_deps->trusted_spdy_proxy; | |
| 979 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 972 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 980 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 973 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 981 pool_peer.EnableSendingInitialSettings(false); | 974 pool_peer.EnableSendingInitialSettings(false); |
| 982 return http_session; | 975 return http_session; |
| 983 } | 976 } |
| 984 | 977 |
| 985 // static | 978 // static |
| 986 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSessionDeterministic( | 979 HttpNetworkSession* SpdySessionDependencies::SpdyCreateSessionDeterministic( |
| 987 SpdySessionDependencies* session_deps) { | 980 SpdySessionDependencies* session_deps) { |
| 988 net::HttpNetworkSession::Params params; | 981 net::HttpNetworkSession::Params params = session_deps->CreateSessionParams(); |
| 989 params.client_socket_factory = | 982 params.client_socket_factory = |
| 990 session_deps->deterministic_socket_factory.get(); | 983 session_deps->deterministic_socket_factory.get(); |
| 991 params.host_resolver = session_deps->host_resolver.get(); | |
| 992 params.cert_verifier = session_deps->cert_verifier.get(); | |
| 993 params.proxy_service = session_deps->proxy_service.get(); | |
| 994 params.ssl_config_service = session_deps->ssl_config_service; | |
| 995 params.http_auth_handler_factory = | |
| 996 session_deps->http_auth_handler_factory.get(); | |
| 997 params.http_server_properties = &session_deps->http_server_properties; | |
| 998 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 984 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 999 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 985 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 1000 pool_peer.EnableSendingInitialSettings(false); | 986 pool_peer.EnableSendingInitialSettings(false); |
| 1001 return http_session; | 987 return http_session; |
| 1002 } | 988 } |
| 1003 | 989 |
| 990 net::HttpNetworkSession::Params SpdySessionDependencies::CreateSessionParams() { |
| 991 net::HttpNetworkSession::Params params; |
| 992 params.host_resolver = host_resolver.get(); |
| 993 params.cert_verifier = cert_verifier.get(); |
| 994 params.proxy_service = proxy_service.get(); |
| 995 params.ssl_config_service = ssl_config_service; |
| 996 params.http_auth_handler_factory = http_auth_handler_factory.get(); |
| 997 params.http_server_properties = &http_server_properties; |
| 998 params.trusted_spdy_proxy = trusted_spdy_proxy; |
| 999 params.net_log = net_log; |
| 1000 return params; |
| 1001 } |
| 1002 |
| 1004 SpdyURLRequestContext::SpdyURLRequestContext() | 1003 SpdyURLRequestContext::SpdyURLRequestContext() |
| 1005 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { | 1004 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { |
| 1006 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); | 1005 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); |
| 1007 storage_.set_cert_verifier(new MockCertVerifier); | 1006 storage_.set_cert_verifier(new MockCertVerifier); |
| 1008 storage_.set_proxy_service(ProxyService::CreateDirect()); | 1007 storage_.set_proxy_service(ProxyService::CreateDirect()); |
| 1009 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); | 1008 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); |
| 1010 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( | 1009 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( |
| 1011 host_resolver())); | 1010 host_resolver())); |
| 1012 storage_.set_http_server_properties(new HttpServerPropertiesImpl); | 1011 storage_.set_http_server_properties(new HttpServerPropertiesImpl); |
| 1013 net::HttpNetworkSession::Params params; | 1012 net::HttpNetworkSession::Params params; |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1067 SpdyTestStateHelper::~SpdyTestStateHelper() { | 1066 SpdyTestStateHelper::~SpdyTestStateHelper() { |
| 1068 SpdySession::ResetStaticSettingsToInit(); | 1067 SpdySession::ResetStaticSettingsToInit(); |
| 1069 // TODO(rch): save/restore this value | 1068 // TODO(rch): save/restore this value |
| 1070 BufferedSpdyFramer::set_enable_compression_default(true); | 1069 BufferedSpdyFramer::set_enable_compression_default(true); |
| 1071 crypto::ECSignatureCreator::SetFactoryForTesting(NULL); | 1070 crypto::ECSignatureCreator::SetFactoryForTesting(NULL); |
| 1072 } | 1071 } |
| 1073 | 1072 |
| 1074 } // namespace test_spdy3 | 1073 } // namespace test_spdy3 |
| 1075 | 1074 |
| 1076 } // namespace net | 1075 } // namespace net |
| OLD | NEW |