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 = CreateSessionParams(session_deps); |
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 = CreateSessionParams(session_deps); |
954 params.client_socket_factory = | 947 params.client_socket_factory = |
955 session_deps->deterministic_socket_factory.get(); | 948 session_deps->deterministic_socket_factory.get(); |
| 949 HttpNetworkSession* http_session = new HttpNetworkSession(params); |
| 950 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); |
| 951 pool_peer.EnableSendingInitialSettings(false); |
| 952 return http_session; |
| 953 } |
| 954 |
| 955 // static |
| 956 net::HttpNetworkSession::Params SpdySessionDependencies::CreateSessionParams( |
| 957 SpdySessionDependencies* session_deps) { |
| 958 net::HttpNetworkSession::Params params; |
956 params.host_resolver = session_deps->host_resolver.get(); | 959 params.host_resolver = session_deps->host_resolver.get(); |
957 params.cert_verifier = session_deps->cert_verifier.get(); | 960 params.cert_verifier = session_deps->cert_verifier.get(); |
958 params.proxy_service = session_deps->proxy_service.get(); | 961 params.proxy_service = session_deps->proxy_service.get(); |
959 params.ssl_config_service = session_deps->ssl_config_service; | 962 params.ssl_config_service = session_deps->ssl_config_service; |
960 params.http_auth_handler_factory = | 963 params.http_auth_handler_factory = |
961 session_deps->http_auth_handler_factory.get(); | 964 session_deps->http_auth_handler_factory.get(); |
962 params.http_server_properties = &session_deps->http_server_properties; | 965 params.http_server_properties = &session_deps->http_server_properties; |
963 HttpNetworkSession* http_session = new HttpNetworkSession(params); | 966 params.trusted_spdy_proxy = session_deps->trusted_spdy_proxy; |
964 SpdySessionPoolPeer pool_peer(http_session->spdy_session_pool()); | 967 params.net_log = session_deps->net_log; |
965 pool_peer.EnableSendingInitialSettings(false); | 968 return params; |
966 return http_session; | |
967 } | 969 } |
968 | 970 |
969 SpdyURLRequestContext::SpdyURLRequestContext() | 971 SpdyURLRequestContext::SpdyURLRequestContext() |
970 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { | 972 : ALLOW_THIS_IN_INITIALIZER_LIST(storage_(this)) { |
971 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); | 973 storage_.set_host_resolver(scoped_ptr<HostResolver>(new MockHostResolver)); |
972 storage_.set_cert_verifier(new MockCertVerifier); | 974 storage_.set_cert_verifier(new MockCertVerifier); |
973 storage_.set_proxy_service(ProxyService::CreateDirect()); | 975 storage_.set_proxy_service(ProxyService::CreateDirect()); |
974 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); | 976 storage_.set_ssl_config_service(new SSLConfigServiceDefaults); |
975 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( | 977 storage_.set_http_auth_handler_factory(HttpAuthHandlerFactory::CreateDefault( |
976 host_resolver())); | 978 host_resolver())); |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1021 } | 1023 } |
1022 | 1024 |
1023 SpdyTestStateHelper::~SpdyTestStateHelper() { | 1025 SpdyTestStateHelper::~SpdyTestStateHelper() { |
1024 SpdySession::ResetStaticSettingsToInit(); | 1026 SpdySession::ResetStaticSettingsToInit(); |
1025 // TODO(rch): save/restore this value | 1027 // TODO(rch): save/restore this value |
1026 BufferedSpdyFramer::set_enable_compression_default(true); | 1028 BufferedSpdyFramer::set_enable_compression_default(true); |
1027 } | 1029 } |
1028 | 1030 |
1029 } // namespace test_spdy2 | 1031 } // namespace test_spdy2 |
1030 } // namespace net | 1032 } // namespace net |
OLD | NEW |