OLD | NEW |
---|---|
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "components/cronet/android/cronet_url_request_adapter.h" | 5 #include "components/cronet/android/cronet_url_request_adapter.h" |
6 | 6 |
7 #include <limits> | 7 #include <limits> |
8 #include <utility> | 8 #include <utility> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
11 #include "base/bind.h" | 11 #include "base/bind.h" |
12 #include "base/location.h" | 12 #include "base/location.h" |
13 #include "base/logging.h" | 13 #include "base/logging.h" |
14 #include "components/cronet/android/cronet_url_request_context_adapter.h" | 14 #include "components/cronet/android/cronet_url_request_context_adapter.h" |
15 #include "components/cronet/android/io_buffer_with_byte_buffer.h" | 15 #include "components/cronet/android/io_buffer_with_byte_buffer.h" |
16 #include "components/cronet/android/url_request_error.h" | 16 #include "components/cronet/android/url_request_error.h" |
17 #include "jni/CronetUrlRequest_jni.h" | 17 #include "jni/CronetUrlRequest_jni.h" |
18 #include "net/base/load_flags.h" | 18 #include "net/base/load_flags.h" |
19 #include "net/base/load_states.h" | 19 #include "net/base/load_states.h" |
20 #include "net/base/net_errors.h" | 20 #include "net/base/net_errors.h" |
21 #include "net/base/request_priority.h" | 21 #include "net/base/request_priority.h" |
22 #include "net/cert/cert_status_flags.h" | 22 #include "net/cert/cert_status_flags.h" |
23 #include "net/http/http_response_headers.h" | 23 #include "net/http/http_response_headers.h" |
24 #include "net/http/http_status_code.h" | 24 #include "net/http/http_status_code.h" |
25 #include "net/http/http_util.h" | 25 #include "net/http/http_util.h" |
26 #include "net/proxy/proxy_server.h" | |
26 #include "net/quic/core/quic_protocol.h" | 27 #include "net/quic/core/quic_protocol.h" |
27 #include "net/ssl/ssl_info.h" | 28 #include "net/ssl/ssl_info.h" |
28 #include "net/url_request/redirect_info.h" | 29 #include "net/url_request/redirect_info.h" |
29 #include "net/url_request/url_request_context.h" | 30 #include "net/url_request/url_request_context.h" |
30 | 31 |
31 using base::android::ConvertUTF8ToJavaString; | 32 using base::android::ConvertUTF8ToJavaString; |
32 using base::android::JavaParamRef; | 33 using base::android::JavaParamRef; |
33 | 34 |
34 namespace cronet { | 35 namespace cronet { |
35 | 36 |
(...skipping 173 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
209 FROM_HERE, base::Bind(&CronetURLRequestAdapter::DestroyOnNetworkThread, | 210 FROM_HERE, base::Bind(&CronetURLRequestAdapter::DestroyOnNetworkThread, |
210 base::Unretained(this), jsend_on_canceled)); | 211 base::Unretained(this), jsend_on_canceled)); |
211 } | 212 } |
212 | 213 |
213 void CronetURLRequestAdapter::OnReceivedRedirect( | 214 void CronetURLRequestAdapter::OnReceivedRedirect( |
214 net::URLRequest* request, | 215 net::URLRequest* request, |
215 const net::RedirectInfo& redirect_info, | 216 const net::RedirectInfo& redirect_info, |
216 bool* defer_redirect) { | 217 bool* defer_redirect) { |
217 DCHECK(context_->IsOnNetworkThread()); | 218 DCHECK(context_->IsOnNetworkThread()); |
218 JNIEnv* env = base::android::AttachCurrentThread(); | 219 JNIEnv* env = base::android::AttachCurrentThread(); |
220 | |
221 const net::HostPortPair host_port_pair = | |
mmenke
2016/10/06 14:58:04
"host_port_pair" is too generic. proxy_host_port_
mmenke
2016/10/06 14:58:04
nit: Prevailing style is not to use const except
| |
222 !request->response_info().proxy_server.is_valid() || | |
223 request->response_info().proxy_server.is_direct() | |
224 ? net::HostPortPair() | |
225 : request->response_info().proxy_server.host_port_pair(); | |
mmenke
2016/10/06 14:58:04
I think this would be a lot easier to read as:
ne
| |
219 cronet::Java_CronetUrlRequest_onRedirectReceived( | 226 cronet::Java_CronetUrlRequest_onRedirectReceived( |
220 env, owner_.obj(), | 227 env, owner_.obj(), |
221 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(), | 228 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(), |
222 redirect_info.status_code, | 229 redirect_info.status_code, |
223 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) | 230 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) |
224 .obj(), | 231 .obj(), |
225 GetResponseHeaders(env).obj(), | 232 GetResponseHeaders(env).obj(), |
226 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, | 233 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, |
227 ConvertUTF8ToJavaString(env, | 234 ConvertUTF8ToJavaString(env, |
228 request->response_info().alpn_negotiated_protocol) | 235 request->response_info().alpn_negotiated_protocol) |
229 .obj(), | 236 .obj(), |
230 ConvertUTF8ToJavaString(env, | 237 ConvertUTF8ToJavaString(env, host_port_pair.ToString()).obj(), |
231 request->response_info().proxy_server.ToString()) | |
232 .obj(), | |
233 request->GetTotalReceivedBytes()); | 238 request->GetTotalReceivedBytes()); |
234 *defer_redirect = true; | 239 *defer_redirect = true; |
235 } | 240 } |
236 | 241 |
237 void CronetURLRequestAdapter::OnCertificateRequested( | 242 void CronetURLRequestAdapter::OnCertificateRequested( |
238 net::URLRequest* request, | 243 net::URLRequest* request, |
239 net::SSLCertRequestInfo* cert_request_info) { | 244 net::SSLCertRequestInfo* cert_request_info) { |
240 DCHECK(context_->IsOnNetworkThread()); | 245 DCHECK(context_->IsOnNetworkThread()); |
241 // Cronet does not support client certificates. | 246 // Cronet does not support client certificates. |
242 request->ContinueWithCertificate(nullptr, nullptr); | 247 request->ContinueWithCertificate(nullptr, nullptr); |
(...skipping 17 matching lines...) Expand all Loading... | |
260 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request, | 265 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request, |
261 int net_error) { | 266 int net_error) { |
262 DCHECK_NE(net::ERR_IO_PENDING, net_error); | 267 DCHECK_NE(net::ERR_IO_PENDING, net_error); |
263 DCHECK(context_->IsOnNetworkThread()); | 268 DCHECK(context_->IsOnNetworkThread()); |
264 | 269 |
265 if (net_error != net::OK) { | 270 if (net_error != net::OK) { |
266 ReportError(request, net_error); | 271 ReportError(request, net_error); |
267 return; | 272 return; |
268 } | 273 } |
269 JNIEnv* env = base::android::AttachCurrentThread(); | 274 JNIEnv* env = base::android::AttachCurrentThread(); |
275 const net::HostPortPair host_port_pair = | |
276 !request->response_info().proxy_server.is_valid() || | |
277 request->response_info().proxy_server.is_direct() | |
278 ? net::HostPortPair() | |
279 : request->response_info().proxy_server.host_port_pair(); | |
mmenke
2016/10/06 14:58:04
Same comments as above...Or better, can we make a
| |
270 cronet::Java_CronetUrlRequest_onResponseStarted( | 280 cronet::Java_CronetUrlRequest_onResponseStarted( |
271 env, owner_.obj(), request->GetResponseCode(), | 281 env, owner_.obj(), request->GetResponseCode(), |
272 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) | 282 ConvertUTF8ToJavaString(env, request->response_headers()->GetStatusText()) |
273 .obj(), | 283 .obj(), |
274 GetResponseHeaders(env).obj(), | 284 GetResponseHeaders(env).obj(), |
275 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, | 285 request->response_info().was_cached ? JNI_TRUE : JNI_FALSE, |
276 ConvertUTF8ToJavaString(env, | 286 ConvertUTF8ToJavaString(env, |
277 request->response_info().alpn_negotiated_protocol) | 287 request->response_info().alpn_negotiated_protocol) |
278 .obj(), | 288 .obj(), |
279 ConvertUTF8ToJavaString(env, | 289 ConvertUTF8ToJavaString(env, host_port_pair.ToString()).obj()); |
280 request->response_info().proxy_server.ToString()) | |
281 .obj()); | |
282 } | 290 } |
283 | 291 |
284 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request, | 292 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request, |
285 int bytes_read) { | 293 int bytes_read) { |
286 DCHECK(context_->IsOnNetworkThread()); | 294 DCHECK(context_->IsOnNetworkThread()); |
287 | 295 |
288 if (bytes_read < 0) { | 296 if (bytes_read < 0) { |
289 ReportError(request, bytes_read); | 297 ReportError(request, bytes_read); |
290 return; | 298 return; |
291 } | 299 } |
(...skipping 140 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
432 ConvertTime(base::TimeTicks::Now(), start_ticks, start_time), | 440 ConvertTime(base::TimeTicks::Now(), start_ticks, start_time), |
433 // TODO(mgersh): report total bytes sent | 441 // TODO(mgersh): report total bytes sent |
434 metrics.socket_reused, 0, url_request_->GetTotalReceivedBytes()); | 442 metrics.socket_reused, 0, url_request_->GetTotalReceivedBytes()); |
435 } | 443 } |
436 | 444 |
437 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() { | 445 net::URLRequest* CronetURLRequestAdapter::GetURLRequestForTesting() { |
438 return url_request_.get(); | 446 return url_request_.get(); |
439 } | 447 } |
440 | 448 |
441 } // namespace cronet | 449 } // namespace cronet |
OLD | NEW |