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 = CreateSessionParams(session_deps); |
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 = CreateSessionParams(session_deps); |
989 params.client_socket_factory = | 982 params.client_socket_factory = |
990 session_deps->deterministic_socket_factory.get(); | 983 session_deps->deterministic_socket_factory.get(); |
| 984 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 985 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 986 pool_peer.EnableSendingInitialSettings(false); |
| 987 return http_session; |
| 988 } |
| 989 |
| 990 // static |
| 991 net::HttpNetworkSession::Params SpdySessionDependencies::CreateSessionParams( |
| 992 SpdySessionDependencies* session_deps) { |
| 993 net::HttpNetworkSession::Params params; |
991 params.host_resolver = session_deps->host_resolver.get(); | 994 params.host_resolver = session_deps->host_resolver.get(); |
992 params.cert_verifier = session_deps->cert_verifier.get(); | 995 params.cert_verifier = session_deps->cert_verifier.get(); |
993 params.proxy_service = session_deps->proxy_service.get(); | 996 params.proxy_service = session_deps->proxy_service.get(); |
994 params.ssl_config_service = session_deps->ssl_config_service; | 997 params.ssl_config_service = session_deps->ssl_config_service; |
995 params.http_auth_handler_factory = | 998 params.http_auth_handler_factory = |
996 session_deps->http_auth_handler_factory.get(); | 999 session_deps->http_auth_handler_factory.get(); |
997 params.http_server_properties = &session_deps->http_server_properties; | 1000 params.http_server_properties = &session_deps->http_server_properties; |
998 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 1001 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy; |
999 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 1002 params.net_log = session_deps->net_log; |
1000 pool_peer.EnableSendingInitialSettings(false); | 1003 return params; |
1001 return http_session; | |
1002 } | 1004 } |
1003 | 1005 |
1004 SpdyURLRequestContext::SpdyURLRequestContext() | 1006 SpdyURLRequestContext::SpdyURLRequestContext() |
1005 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { | 1007 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { |
1006 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); | 1008 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); |
1007 storage_.set_cert_verifier(new MockCertVerifier); | 1009 storage_.set_cert_verifier(new MockCertVerifier); |
1008 storage_.set_proxy_service(ProxyService::CreateDirect()); | 1010 storage_.set_proxy_service(ProxyService::CreateDirect()); |
1009 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); | 1011 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); |
1010 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( | 1012 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( |
1011 host_resolver())); | 1013 host_resolver())); |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1067 SpdyTestStateHelper::~SpdyTestStateHelper() { | 1069 SpdyTestStateHelper::~SpdyTestStateHelper() { |
1068 SpdySession::ResetStaticSettingsToInit(); | 1070 SpdySession::ResetStaticSettingsToInit(); |
1069 // TODO(rch): save/restore this value | 1071 // TODO(rch): save/restore this value |
1070 BufferedSpdyFramer::set_enable_compression_default(true); | 1072 BufferedSpdyFramer::set_enable_compression_default(true); |
1071 crypto::ECSignatureCreator::SetFactoryForTesting(NULL); | 1073 crypto::ECSignatureCreator::SetFactoryForTesting(NULL); |
1072 } | 1074 } |
1073 | 1075 |
1074 } // namespace test_spdy3 | 1076 } // namespace test_spdy3 |
1075 | 1077 |
1076 } // namespace net | 1078 } // namespace net |
OLD | NEW |