Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(234)

Side by Side Diff: components/cronet/android/cronet_upload_data_stream_adapter.cc

Issue 1144153004: components: Remove use of MessageLoopProxy and deprecated MessageLoop APIs (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebased. Created 5 years, 6 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 "components/cronet/android/cronet_upload_data_stream_adapter.h" 5 #include "components/cronet/android/cronet_upload_data_stream_adapter.h"
6 6
7 #include <string> 7 #include <string>
8 8
9 #include "base/android/jni_android.h" 9 #include "base/android/jni_android.h"
10 #include "base/android/jni_string.h" 10 #include "base/android/jni_string.h"
11 #include "base/bind.h" 11 #include "base/bind.h"
12 #include "base/logging.h" 12 #include "base/logging.h"
13 #include "base/message_loop/message_loop_proxy.h"
14 #include "base/single_thread_task_runner.h" 13 #include "base/single_thread_task_runner.h"
14 #include "base/thread_task_runner_handle.h"
15 #include "components/cronet/android/cronet_url_request_adapter.h" 15 #include "components/cronet/android/cronet_url_request_adapter.h"
16 #include "jni/CronetUploadDataStream_jni.h" 16 #include "jni/CronetUploadDataStream_jni.h"
17 17
18 namespace cronet { 18 namespace cronet {
19 19
20 CronetUploadDataStreamAdapter::CronetUploadDataStreamAdapter( 20 CronetUploadDataStreamAdapter::CronetUploadDataStreamAdapter(
21 JNIEnv* env, 21 JNIEnv* env,
22 jobject jupload_data_stream) { 22 jobject jupload_data_stream) {
23 jupload_data_stream_.Reset(env, jupload_data_stream); 23 jupload_data_stream_.Reset(env, jupload_data_stream);
24 } 24 }
25 25
26 CronetUploadDataStreamAdapter::~CronetUploadDataStreamAdapter() { 26 CronetUploadDataStreamAdapter::~CronetUploadDataStreamAdapter() {
27 } 27 }
28 28
29 void CronetUploadDataStreamAdapter::InitializeOnNetworkThread( 29 void CronetUploadDataStreamAdapter::InitializeOnNetworkThread(
30 base::WeakPtr<CronetUploadDataStream> upload_data_stream) { 30 base::WeakPtr<CronetUploadDataStream> upload_data_stream) {
31 DCHECK(!upload_data_stream_); 31 DCHECK(!upload_data_stream_);
32 DCHECK(!network_task_runner_.get()); 32 DCHECK(!network_task_runner_.get());
33 33
34 upload_data_stream_ = upload_data_stream; 34 upload_data_stream_ = upload_data_stream;
35 network_task_runner_ = base::MessageLoopProxy::current(); 35 network_task_runner_ = base::ThreadTaskRunnerHandle::Get();
36 DCHECK(network_task_runner_); 36 DCHECK(network_task_runner_);
37 } 37 }
38 38
39 void CronetUploadDataStreamAdapter::Read(net::IOBuffer* buffer, int buf_len) { 39 void CronetUploadDataStreamAdapter::Read(net::IOBuffer* buffer, int buf_len) {
40 DCHECK(upload_data_stream_); 40 DCHECK(upload_data_stream_);
41 DCHECK(network_task_runner_); 41 DCHECK(network_task_runner_);
42 DCHECK(network_task_runner_->BelongsToCurrentThread()); 42 DCHECK(network_task_runner_->BelongsToCurrentThread());
43 DCHECK_GT(buf_len, 0); 43 DCHECK_GT(buf_len, 0);
44 DCHECK(!buffer_.get()); 44 DCHECK(!buffer_.get());
45 buffer_ = buffer; 45 buffer_ = buffer;
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after
140 jclass jcronet_url_request_adapter, 140 jclass jcronet_url_request_adapter,
141 jlong jupload_data_stream_adapter) { 141 jlong jupload_data_stream_adapter) {
142 CronetUploadDataStreamAdapter* adapter = 142 CronetUploadDataStreamAdapter* adapter =
143 reinterpret_cast<CronetUploadDataStreamAdapter*>( 143 reinterpret_cast<CronetUploadDataStreamAdapter*>(
144 jupload_data_stream_adapter); 144 jupload_data_stream_adapter);
145 DCHECK(adapter != nullptr); 145 DCHECK(adapter != nullptr);
146 delete adapter; 146 delete adapter;
147 } 147 }
148 148
149 } // namespace cronet 149 } // namespace cronet
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698