Chromium Code Reviews| 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 "cronet_url_request_adapter.h" | 5 #include "cronet_url_request_adapter.h" |
| 6 | 6 |
| 7 #include <limits> | 7 #include <limits> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/location.h" | 10 #include "base/location.h" |
| 11 #include "base/logging.h" | 11 #include "base/logging.h" |
| 12 #include "components/cronet/android/cronet_url_request_context_adapter.h" | 12 #include "components/cronet/android/cronet_url_request_context_adapter.h" |
| 13 #include "jni/CronetUrlRequest_jni.h" | 13 #include "jni/CronetUrlRequest_jni.h" |
| 14 #include "net/base/io_buffer.h" | 14 #include "net/base/io_buffer.h" |
| 15 #include "net/base/load_flags.h" | 15 #include "net/base/load_flags.h" |
| 16 #include "net/base/net_errors.h" | 16 #include "net/base/net_errors.h" |
| 17 #include "net/base/request_priority.h" | 17 #include "net/base/request_priority.h" |
| 18 #include "net/cert/cert_status_flags.h" | |
| 18 #include "net/http/http_response_headers.h" | 19 #include "net/http/http_response_headers.h" |
| 19 #include "net/http/http_status_code.h" | 20 #include "net/http/http_status_code.h" |
| 20 #include "net/http/http_util.h" | 21 #include "net/http/http_util.h" |
| 22 #include "net/ssl/ssl_info.h" | |
| 21 #include "net/url_request/redirect_info.h" | 23 #include "net/url_request/redirect_info.h" |
| 22 #include "net/url_request/url_request_context.h" | 24 #include "net/url_request/url_request_context.h" |
| 23 | 25 |
| 24 using base::android::ConvertUTF8ToJavaString; | 26 using base::android::ConvertUTF8ToJavaString; |
| 25 | 27 |
| 26 namespace cronet { | 28 namespace cronet { |
| 27 | 29 |
| 28 // Explicitly register static JNI functions. | 30 // Explicitly register static JNI functions. |
| 29 bool CronetUrlRequestAdapterRegisterJni(JNIEnv* env) { | 31 bool CronetUrlRequestAdapterRegisterJni(JNIEnv* env) { |
| 30 return RegisterNativesImpl(env); | 32 return RegisterNativesImpl(env); |
| (...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 88 CronetURLRequestAdapter::CronetURLRequestAdapter( | 90 CronetURLRequestAdapter::CronetURLRequestAdapter( |
| 89 CronetURLRequestContextAdapter* context, | 91 CronetURLRequestContextAdapter* context, |
| 90 JNIEnv* env, | 92 JNIEnv* env, |
| 91 jobject jurl_request, | 93 jobject jurl_request, |
| 92 const GURL& url, | 94 const GURL& url, |
| 93 net::RequestPriority priority) | 95 net::RequestPriority priority) |
| 94 : context_(context), | 96 : context_(context), |
| 95 initial_url_(url), | 97 initial_url_(url), |
| 96 initial_priority_(priority), | 98 initial_priority_(priority), |
| 97 initial_method_("GET"), | 99 initial_method_("GET"), |
| 98 load_flags_(context->default_load_flags()) { | 100 load_flags_(context->default_load_flags()), |
| 101 has_ssl_cert_error_(false) { | |
| 99 DCHECK(!context_->IsOnNetworkThread()); | 102 DCHECK(!context_->IsOnNetworkThread()); |
| 100 owner_.Reset(env, jurl_request); | 103 owner_.Reset(env, jurl_request); |
| 101 } | 104 } |
| 102 | 105 |
| 103 CronetURLRequestAdapter::~CronetURLRequestAdapter() { | 106 CronetURLRequestAdapter::~CronetURLRequestAdapter() { |
| 104 DCHECK(context_->IsOnNetworkThread()); | 107 DCHECK(context_->IsOnNetworkThread()); |
| 105 } | 108 } |
| 106 | 109 |
| 107 jboolean CronetURLRequestAdapter::SetHttpMethod(JNIEnv* env, | 110 jboolean CronetURLRequestAdapter::SetHttpMethod(JNIEnv* env, |
| 108 jobject jcaller, | 111 jobject jcaller, |
| (...skipping 157 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 266 JNIEnv* env = base::android::AttachCurrentThread(); | 269 JNIEnv* env = base::android::AttachCurrentThread(); |
| 267 cronet::Java_CronetUrlRequest_onReceivedRedirect( | 270 cronet::Java_CronetUrlRequest_onReceivedRedirect( |
| 268 env, owner_.obj(), | 271 env, owner_.obj(), |
| 269 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(), | 272 ConvertUTF8ToJavaString(env, redirect_info.new_url.spec()).obj(), |
| 270 redirect_info.status_code); | 273 redirect_info.status_code); |
| 271 *defer_redirect = true; | 274 *defer_redirect = true; |
| 272 } | 275 } |
| 273 | 276 |
| 274 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request) { | 277 void CronetURLRequestAdapter::OnResponseStarted(net::URLRequest* request) { |
| 275 DCHECK(context_->IsOnNetworkThread()); | 278 DCHECK(context_->IsOnNetworkThread()); |
| 276 if (MaybeReportError(request)) | 279 // If any ssl cert error is present, |
| 280 // CronetURLRequesAdapter::OnSSLCertificateError has propagated the error | |
| 281 // to the embedder, so do not report again. | |
| 282 if (has_ssl_cert_error_ || MaybeReportError(request)) | |
|
mmenke
2015/07/15 22:03:43
Why is this needed? OnSSLCertificateError calls C
| |
| 277 return; | 283 return; |
| 278 JNIEnv* env = base::android::AttachCurrentThread(); | 284 JNIEnv* env = base::android::AttachCurrentThread(); |
| 279 cronet::Java_CronetUrlRequest_onResponseStarted(env, owner_.obj(), | 285 cronet::Java_CronetUrlRequest_onResponseStarted(env, owner_.obj(), |
| 280 request->GetResponseCode()); | 286 request->GetResponseCode()); |
| 281 } | 287 } |
| 282 | 288 |
| 289 void CronetURLRequestAdapter::OnSSLCertificateError( | |
| 290 net::URLRequest* request, | |
| 291 const net::SSLInfo& ssl_info, | |
| 292 bool fatal) { | |
| 293 has_ssl_cert_error_ = true; | |
| 294 request->Cancel(); | |
| 295 int ssl_cert_net_error = net::MapCertStatusToNetError(ssl_info.cert_status); | |
| 296 JNIEnv* env = base::android::AttachCurrentThread(); | |
| 297 cronet::Java_CronetUrlRequest_onError( | |
| 298 env, owner_.obj(), ssl_cert_net_error, | |
| 299 ConvertUTF8ToJavaString(env, net::ErrorToString(ssl_cert_net_error)) | |
| 300 .obj()); | |
| 301 } | |
| 302 | |
| 283 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request, | 303 void CronetURLRequestAdapter::OnReadCompleted(net::URLRequest* request, |
| 284 int bytes_read) { | 304 int bytes_read) { |
| 285 DCHECK(context_->IsOnNetworkThread()); | 305 DCHECK(context_->IsOnNetworkThread()); |
| 286 if (MaybeReportError(request)) | 306 if (MaybeReportError(request)) |
| 287 return; | 307 return; |
| 288 if (bytes_read != 0) { | 308 if (bytes_read != 0) { |
| 289 JNIEnv* env = base::android::AttachCurrentThread(); | 309 JNIEnv* env = base::android::AttachCurrentThread(); |
| 290 cronet::Java_CronetUrlRequest_onReadCompleted( | 310 cronet::Java_CronetUrlRequest_onReadCompleted( |
| 291 env, owner_.obj(), read_buffer_->byte_buffer(), bytes_read, | 311 env, owner_.obj(), read_buffer_->byte_buffer(), bytes_read, |
| 292 read_buffer_->initial_position()); | 312 read_buffer_->initial_position()); |
| (...skipping 70 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 363 VLOG(1) << "Error " << net::ErrorToString(net_error) | 383 VLOG(1) << "Error " << net::ErrorToString(net_error) |
| 364 << " on chromium request: " << initial_url_.possibly_invalid_spec(); | 384 << " on chromium request: " << initial_url_.possibly_invalid_spec(); |
| 365 JNIEnv* env = base::android::AttachCurrentThread(); | 385 JNIEnv* env = base::android::AttachCurrentThread(); |
| 366 cronet::Java_CronetUrlRequest_onError( | 386 cronet::Java_CronetUrlRequest_onError( |
| 367 env, owner_.obj(), net_error, | 387 env, owner_.obj(), net_error, |
| 368 ConvertUTF8ToJavaString(env, net::ErrorToString(net_error)).obj()); | 388 ConvertUTF8ToJavaString(env, net::ErrorToString(net_error)).obj()); |
| 369 return true; | 389 return true; |
| 370 } | 390 } |
| 371 | 391 |
| 372 } // namespace cronet | 392 } // namespace cronet |
| OLD | NEW |