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

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

Issue 2283243002: Allow direct executors in cronet. (Closed)
Patch Set: Created 4 years, 3 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 #include <utility> 8 #include <utility>
9 9
10 #include "base/android/jni_android.h" 10 #include "base/android/jni_android.h"
(...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after
74 Java_CronetUploadDataStream_onUploadDataStreamDestroyed(env, 74 Java_CronetUploadDataStream_onUploadDataStreamDestroyed(env,
75 jupload_data_stream_); 75 jupload_data_stream_);
76 // |this| is invalid here since the Java call above effectively destroys it. 76 // |this| is invalid here since the Java call above effectively destroys it.
77 } 77 }
78 78
79 void CronetUploadDataStreamAdapter::OnReadSucceeded( 79 void CronetUploadDataStreamAdapter::OnReadSucceeded(
80 JNIEnv* env, 80 JNIEnv* env,
81 const JavaParamRef<jobject>& jcaller, 81 const JavaParamRef<jobject>& jcaller,
82 int bytes_read, 82 int bytes_read,
83 bool final_chunk) { 83 bool final_chunk) {
84 DCHECK(!network_task_runner_->BelongsToCurrentThread());
85 DCHECK(bytes_read > 0 || (final_chunk && bytes_read == 0)); 84 DCHECK(bytes_read > 0 || (final_chunk && bytes_read == 0));
86 85
87 buffer_ = nullptr; 86 buffer_ = nullptr;
88 network_task_runner_->PostTask( 87 network_task_runner_->PostTask(
89 FROM_HERE, base::Bind(&CronetUploadDataStream::OnReadSuccess, 88 FROM_HERE, base::Bind(&CronetUploadDataStream::OnReadSuccess,
90 upload_data_stream_, bytes_read, final_chunk)); 89 upload_data_stream_, bytes_read, final_chunk));
91 } 90 }
92 91
93 void CronetUploadDataStreamAdapter::OnRewindSucceeded( 92 void CronetUploadDataStreamAdapter::OnRewindSucceeded(
94 JNIEnv* env, 93 JNIEnv* env,
95 const JavaParamRef<jobject>& jcaller) { 94 const JavaParamRef<jobject>& jcaller) {
96 DCHECK(!network_task_runner_->BelongsToCurrentThread());
97 95
98 network_task_runner_->PostTask( 96 network_task_runner_->PostTask(
99 FROM_HERE, 97 FROM_HERE,
100 base::Bind(&CronetUploadDataStream::OnRewindSuccess, 98 base::Bind(&CronetUploadDataStream::OnRewindSuccess,
101 upload_data_stream_)); 99 upload_data_stream_));
102 } 100 }
103 101
104 void CronetUploadDataStreamAdapter::Destroy(JNIEnv* env, 102 void CronetUploadDataStreamAdapter::Destroy(JNIEnv* env,
105 const JavaParamRef<jobject>& jobj) { 103 const JavaParamRef<jobject>& jobj) {
106 delete this; 104 delete this;
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after
144 jlong jlength, 142 jlong jlength,
145 jlong jadapter) { 143 jlong jadapter) {
146 CronetUploadDataStreamAdapter* adapter = 144 CronetUploadDataStreamAdapter* adapter =
147 reinterpret_cast<CronetUploadDataStreamAdapter*>(jadapter); 145 reinterpret_cast<CronetUploadDataStreamAdapter*>(jadapter);
148 CronetUploadDataStream* upload_data_stream = 146 CronetUploadDataStream* upload_data_stream =
149 new CronetUploadDataStream(adapter, jlength); 147 new CronetUploadDataStream(adapter, jlength);
150 return reinterpret_cast<jlong>(upload_data_stream); 148 return reinterpret_cast<jlong>(upload_data_stream);
151 } 149 }
152 150
153 } // namespace cronet 151 } // namespace cronet
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698