| 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" |
| (...skipping 260 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 271 if (bytes_read != 0) { | 271 if (bytes_read != 0) { |
| 272 JNIEnv* env = base::android::AttachCurrentThread(); | 272 JNIEnv* env = base::android::AttachCurrentThread(); |
| 273 cronet::Java_CronetUrlRequest_onReadCompleted( | 273 cronet::Java_CronetUrlRequest_onReadCompleted( |
| 274 env, owner_.obj(), read_buffer_->byte_buffer(), bytes_read, | 274 env, owner_.obj(), read_buffer_->byte_buffer(), bytes_read, |
| 275 read_buffer_->initial_position()); | 275 read_buffer_->initial_position()); |
| 276 // Free the read buffer. This lets the Java ByteBuffer be freed, if the | 276 // Free the read buffer. This lets the Java ByteBuffer be freed, if the |
| 277 // embedder releases it, too. | 277 // embedder releases it, too. |
| 278 read_buffer_ = nullptr; | 278 read_buffer_ = nullptr; |
| 279 } else { | 279 } else { |
| 280 JNIEnv* env = base::android::AttachCurrentThread(); | 280 JNIEnv* env = base::android::AttachCurrentThread(); |
| 281 cronet::Java_CronetUrlRequest_onSucceeded(env, owner_.obj()); | 281 cronet::Java_CronetUrlRequest_onSucceeded( |
| 282 env, owner_.obj(), url_request_->GetTotalReceivedBytes()); |
| 282 } | 283 } |
| 283 } | 284 } |
| 284 | 285 |
| 285 void CronetURLRequestAdapter::StartOnNetworkThread() { | 286 void CronetURLRequestAdapter::StartOnNetworkThread() { |
| 286 DCHECK(context_->IsOnNetworkThread()); | 287 DCHECK(context_->IsOnNetworkThread()); |
| 287 VLOG(1) << "Starting chromium request: " | 288 VLOG(1) << "Starting chromium request: " |
| 288 << initial_url_.possibly_invalid_spec().c_str() | 289 << initial_url_.possibly_invalid_spec().c_str() |
| 289 << " priority: " << RequestPriorityToString(initial_priority_); | 290 << " priority: " << RequestPriorityToString(initial_priority_); |
| 290 url_request_ = context_->GetURLRequestContext()->CreateRequest( | 291 url_request_ = context_->GetURLRequestContext()->CreateRequest( |
| 291 initial_url_, net::DEFAULT_PRIORITY, this); | 292 initial_url_, net::DEFAULT_PRIORITY, this); |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 335 VLOG(1) << "Error " << net::ErrorToString(net_error) | 336 VLOG(1) << "Error " << net::ErrorToString(net_error) |
| 336 << " on chromium request: " << initial_url_.possibly_invalid_spec(); | 337 << " on chromium request: " << initial_url_.possibly_invalid_spec(); |
| 337 JNIEnv* env = base::android::AttachCurrentThread(); | 338 JNIEnv* env = base::android::AttachCurrentThread(); |
| 338 cronet::Java_CronetUrlRequest_onError( | 339 cronet::Java_CronetUrlRequest_onError( |
| 339 env, owner_.obj(), net_error, | 340 env, owner_.obj(), net_error, |
| 340 ConvertUTF8ToJavaString(env, net::ErrorToString(net_error)).obj()); | 341 ConvertUTF8ToJavaString(env, net::ErrorToString(net_error)).obj()); |
| 341 return true; | 342 return true; |
| 342 } | 343 } |
| 343 | 344 |
| 344 } // namespace cronet | 345 } // namespace cronet |
| OLD | NEW |