OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/websockets/websocket_stream_create_test_base.h" | 5 #include "net/websockets/websocket_stream_create_test_base.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/callback.h" | 9 #include "base/callback.h" |
10 #include "base/macros.h" | 10 #include "base/macros.h" |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
106 url_request_context_host_.AddSSLSocketDataProvider(std::move(ssl_data_[i])); | 106 url_request_context_host_.AddSSLSocketDataProvider(std::move(ssl_data_[i])); |
107 } | 107 } |
108 ssl_data_.clear(); | 108 ssl_data_.clear(); |
109 std::unique_ptr<WebSocketStream::ConnectDelegate> connect_delegate( | 109 std::unique_ptr<WebSocketStream::ConnectDelegate> connect_delegate( |
110 new TestConnectDelegate(this, connect_run_loop_.QuitClosure())); | 110 new TestConnectDelegate(this, connect_run_loop_.QuitClosure())); |
111 WebSocketStream::ConnectDelegate* delegate = connect_delegate.get(); | 111 WebSocketStream::ConnectDelegate* delegate = connect_delegate.get(); |
112 std::unique_ptr<WebSocketHandshakeStreamCreateHelper> create_helper( | 112 std::unique_ptr<WebSocketHandshakeStreamCreateHelper> create_helper( |
113 new DeterministicKeyWebSocketHandshakeStreamCreateHelper(delegate, | 113 new DeterministicKeyWebSocketHandshakeStreamCreateHelper(delegate, |
114 sub_protocols)); | 114 sub_protocols)); |
115 stream_request_ = CreateAndConnectStreamForTesting( | 115 stream_request_ = CreateAndConnectStreamForTesting( |
116 GURL(socket_url), std::move(create_helper), origin, | 116 GURL(socket_url), std::move(create_helper), origin, "", |
117 url_request_context_host_.GetURLRequestContext(), BoundNetLog(), | 117 url_request_context_host_.GetURLRequestContext(), BoundNetLog(), |
118 std::move(connect_delegate), | 118 std::move(connect_delegate), |
119 timer ? std::move(timer) | 119 timer ? std::move(timer) |
120 : std::unique_ptr<base::Timer>(new base::Timer(false, false))); | 120 : std::unique_ptr<base::Timer>(new base::Timer(false, false))); |
121 } | 121 } |
122 | 122 |
123 std::vector<HeaderKeyValuePair> | 123 std::vector<HeaderKeyValuePair> |
124 WebSocketStreamCreateTestBase::RequestHeadersToVector( | 124 WebSocketStreamCreateTestBase::RequestHeadersToVector( |
125 const HttpRequestHeaders& headers) { | 125 const HttpRequestHeaders& headers) { |
126 HttpRequestHeaders::Iterator it(headers); | 126 HttpRequestHeaders::Iterator it(headers); |
(...skipping 16 matching lines...) Expand all Loading... |
143 | 143 |
144 void WebSocketStreamCreateTestBase::WaitUntilConnectDone() { | 144 void WebSocketStreamCreateTestBase::WaitUntilConnectDone() { |
145 connect_run_loop_.Run(); | 145 connect_run_loop_.Run(); |
146 } | 146 } |
147 | 147 |
148 std::vector<std::string> WebSocketStreamCreateTestBase::NoSubProtocols() { | 148 std::vector<std::string> WebSocketStreamCreateTestBase::NoSubProtocols() { |
149 return std::vector<std::string>(); | 149 return std::vector<std::string>(); |
150 } | 150 } |
151 | 151 |
152 } // namespace net | 152 } // namespace net |
OLD | NEW |