OLD | NEW |
---|---|
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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.h" | 5 #include "net/websockets/websocket_stream.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/memory/scoped_ptr.h" | 8 #include "base/memory/scoped_ptr.h" |
9 #include "base/metrics/histogram.h" | 9 #include "base/metrics/histogram.h" |
10 #include "base/metrics/sparse_histogram.h" | 10 #include "base/metrics/sparse_histogram.h" |
11 #include "net/base/load_flags.h" | 11 #include "net/base/load_flags.h" |
12 #include "net/http/http_request_headers.h" | 12 #include "net/http/http_request_headers.h" |
13 #include "net/http/http_response_headers.h" | |
13 #include "net/http/http_status_code.h" | 14 #include "net/http/http_status_code.h" |
14 #include "net/url_request/url_request.h" | 15 #include "net/url_request/url_request.h" |
15 #include "net/url_request/url_request_context.h" | 16 #include "net/url_request/url_request_context.h" |
16 #include "net/websockets/websocket_errors.h" | 17 #include "net/websockets/websocket_errors.h" |
17 #include "net/websockets/websocket_event_interface.h" | 18 #include "net/websockets/websocket_event_interface.h" |
18 #include "net/websockets/websocket_handshake_constants.h" | 19 #include "net/websockets/websocket_handshake_constants.h" |
19 #include "net/websockets/websocket_handshake_stream_base.h" | 20 #include "net/websockets/websocket_handshake_stream_base.h" |
20 #include "net/websockets/websocket_handshake_stream_create_helper.h" | 21 #include "net/websockets/websocket_handshake_stream_create_helper.h" |
21 #include "net/websockets/websocket_test_util.h" | 22 #include "net/websockets/websocket_test_util.h" |
22 #include "url/gurl.h" | 23 #include "url/gurl.h" |
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
128 case URLRequestStatus::CANCELED: | 129 case URLRequestStatus::CANCELED: |
129 failure_message = "WebSocket opening handshake was canceled"; | 130 failure_message = "WebSocket opening handshake was canceled"; |
130 break; | 131 break; |
131 case URLRequestStatus::FAILED: | 132 case URLRequestStatus::FAILED: |
132 failure_message = | 133 failure_message = |
133 std::string("Error in connection establishment: ") + | 134 std::string("Error in connection establishment: ") + |
134 ErrorToString(url_request_.status().error()); | 135 ErrorToString(url_request_.status().error()); |
135 break; | 136 break; |
136 } | 137 } |
137 } | 138 } |
139 ReportFailureWithMessage(failure_message); | |
140 } | |
141 | |
142 void ReportFailureWithMessage(const std::string& failure_message) { | |
138 connect_delegate_->OnFailure(failure_message); | 143 connect_delegate_->OnFailure(failure_message); |
139 } | 144 } |
140 | 145 |
146 void OnFinishOpeningHandshake() { | |
tyoshino (SeeGerritForStatus)
2014/07/07 19:26:44
this looks similar to
WebSocketBasicHandshakeStrea
Adam Rice
2014/07/08 10:23:45
Yes. Factored out in a separate function used by b
| |
147 HttpResponseHeaders* headers = url_request_.response_headers(); | |
148 if (headers) { | |
149 connect_delegate_->OnFinishOpeningHandshake(make_scoped_ptr( | |
150 new WebSocketHandshakeResponseInfo(url_request_.url(), | |
151 headers->response_code(), | |
152 headers->GetStatusText(), | |
153 headers, | |
154 url_request_.response_time()))); | |
155 } | |
156 } | |
157 | |
141 WebSocketStream::ConnectDelegate* connect_delegate() const { | 158 WebSocketStream::ConnectDelegate* connect_delegate() const { |
142 return connect_delegate_.get(); | 159 return connect_delegate_.get(); |
143 } | 160 } |
144 | 161 |
145 private: | 162 private: |
146 // |delegate_| needs to be declared before |url_request_| so that it gets | 163 // |delegate_| needs to be declared before |url_request_| so that it gets |
147 // initialised first. | 164 // initialised first. |
148 scoped_ptr<Delegate> delegate_; | 165 scoped_ptr<Delegate> delegate_; |
149 | 166 |
150 // Deleting the StreamRequestImpl object deletes this URLRequest object, | 167 // Deleting the StreamRequestImpl object deletes this URLRequest object, |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
190 } | 207 } |
191 const int response_code = request->GetResponseCode(); | 208 const int response_code = request->GetResponseCode(); |
192 DVLOG(3) << "OnResponseStarted (response code " << response_code << ")"; | 209 DVLOG(3) << "OnResponseStarted (response code " << response_code << ")"; |
193 switch (response_code) { | 210 switch (response_code) { |
194 case HTTP_SWITCHING_PROTOCOLS: | 211 case HTTP_SWITCHING_PROTOCOLS: |
195 result_ = CONNECTED; | 212 result_ = CONNECTED; |
196 owner_->PerformUpgrade(); | 213 owner_->PerformUpgrade(); |
197 return; | 214 return; |
198 | 215 |
199 case HTTP_UNAUTHORIZED: | 216 case HTTP_UNAUTHORIZED: |
217 result_ = FAILED; | |
218 owner_->OnFinishOpeningHandshake(); | |
219 owner_->ReportFailureWithMessage( | |
220 "HTTP Authentication failed; no valid credentials available"); | |
221 return; | |
222 | |
200 case HTTP_PROXY_AUTHENTICATION_REQUIRED: | 223 case HTTP_PROXY_AUTHENTICATION_REQUIRED: |
224 result_ = FAILED; | |
225 owner_->OnFinishOpeningHandshake(); | |
226 owner_->ReportFailureWithMessage("Proxy authentication failed"); | |
201 return; | 227 return; |
202 | 228 |
203 default: | 229 default: |
204 result_ = FAILED; | 230 result_ = FAILED; |
205 owner_->ReportFailure(); | 231 owner_->ReportFailure(); |
206 } | 232 } |
207 } | 233 } |
208 | 234 |
209 void Delegate::OnAuthRequired(URLRequest* request, | 235 void Delegate::OnAuthRequired(URLRequest* request, |
210 AuthChallengeInfo* auth_info) { | 236 AuthChallengeInfo* auth_info) { |
(...skipping 67 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
278 new StreamRequestImpl(socket_url, | 304 new StreamRequestImpl(socket_url, |
279 url_request_context, | 305 url_request_context, |
280 origin, | 306 origin, |
281 connect_delegate.Pass(), | 307 connect_delegate.Pass(), |
282 create_helper.Pass())); | 308 create_helper.Pass())); |
283 request->Start(); | 309 request->Start(); |
284 return request.PassAs<WebSocketStreamRequest>(); | 310 return request.PassAs<WebSocketStreamRequest>(); |
285 } | 311 } |
286 | 312 |
287 } // namespace net | 313 } // namespace net |
OLD | NEW |