| Index: components/cronet/android/cronet_upload_data_stream_delegate.cc
|
| diff --git a/components/cronet/android/cronet_upload_data_stream_delegate.cc b/components/cronet/android/cronet_upload_data_stream_delegate.cc
|
| index 3c4b006cb6918e21e0a2f93a1f20f527b11b2dd1..9a8f61bc593479487acb5b138dfb3238d1ca6e30 100644
|
| --- a/components/cronet/android/cronet_upload_data_stream_delegate.cc
|
| +++ b/components/cronet/android/cronet_upload_data_stream_delegate.cc
|
| @@ -29,17 +29,17 @@ CronetUploadDataStreamDelegate::~CronetUploadDataStreamDelegate() {
|
| }
|
|
|
| void CronetUploadDataStreamDelegate::InitializeOnNetworkThread(
|
| - base::WeakPtr<CronetUploadDataStreamAdapter> adapter) {
|
| - DCHECK(!adapter_);
|
| + base::WeakPtr<CronetUploadDataStream> upload_data_stream) {
|
| + DCHECK(!upload_data_stream_);
|
| DCHECK(!network_task_runner_.get());
|
|
|
| - adapter_ = adapter;
|
| + upload_data_stream_ = upload_data_stream;
|
| network_task_runner_ = base::MessageLoopProxy::current();
|
| DCHECK(network_task_runner_);
|
| }
|
|
|
| void CronetUploadDataStreamDelegate::Read(net::IOBuffer* buffer, int buf_len) {
|
| - DCHECK(adapter_);
|
| + DCHECK(upload_data_stream_);
|
| DCHECK(network_task_runner_);
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
| DCHECK_GT(buf_len, 0);
|
| @@ -56,22 +56,22 @@ void CronetUploadDataStreamDelegate::Read(net::IOBuffer* buffer, int buf_len) {
|
| }
|
|
|
| void CronetUploadDataStreamDelegate::Rewind() {
|
| - DCHECK(adapter_);
|
| + DCHECK(upload_data_stream_);
|
| DCHECK(network_task_runner_->BelongsToCurrentThread());
|
|
|
| JNIEnv* env = base::android::AttachCurrentThread();
|
| Java_CronetUploadDataStream_rewind(env, jupload_data_stream_.obj());
|
| }
|
|
|
| -void CronetUploadDataStreamDelegate::OnAdapterDestroyed() {
|
| - // If the CronetUploadDataStreamAdapter was never initialized, |adapter_|
|
| - // and |network_task_runner_| will be NULL.
|
| +void CronetUploadDataStreamDelegate::OnUploadDataStreamDestroyed() {
|
| + // If CronetUploadDataStream::InitInternal was never called,
|
| + // |upload_data_stream_| and |network_task_runner_| will be NULL.
|
| DCHECK(!network_task_runner_ ||
|
| network_task_runner_->BelongsToCurrentThread());
|
|
|
| JNIEnv* env = base::android::AttachCurrentThread();
|
| - Java_CronetUploadDataStream_onAdapterDestroyed(env,
|
| - jupload_data_stream_.obj());
|
| + Java_CronetUploadDataStream_onUploadDataStreamDestroyed(
|
| + env, jupload_data_stream_.obj());
|
| }
|
|
|
| void CronetUploadDataStreamDelegate::OnReadSucceeded(JNIEnv* env,
|
| @@ -83,8 +83,8 @@ void CronetUploadDataStreamDelegate::OnReadSucceeded(JNIEnv* env,
|
|
|
| buffer_ = nullptr;
|
| network_task_runner_->PostTask(
|
| - FROM_HERE, base::Bind(&CronetUploadDataStreamAdapter::OnReadSuccess,
|
| - adapter_, bytes_read, final_chunk));
|
| + FROM_HERE, base::Bind(&CronetUploadDataStream::OnReadSuccess,
|
| + upload_data_stream_, bytes_read, final_chunk));
|
| }
|
|
|
| void CronetUploadDataStreamDelegate::OnRewindSucceeded(JNIEnv* env,
|
| @@ -93,7 +93,8 @@ void CronetUploadDataStreamDelegate::OnRewindSucceeded(JNIEnv* env,
|
|
|
| network_task_runner_->PostTask(
|
| FROM_HERE,
|
| - base::Bind(&CronetUploadDataStreamAdapter::OnRewindSuccess, adapter_));
|
| + base::Bind(&CronetUploadDataStream::OnRewindSuccess,
|
| + upload_data_stream_));
|
| }
|
|
|
| bool CronetUploadDataStreamDelegateRegisterJni(JNIEnv* env) {
|
| @@ -111,10 +112,10 @@ static jlong AttachUploadDataToRequest(JNIEnv* env,
|
| CronetUploadDataStreamDelegate* delegate =
|
| new CronetUploadDataStreamDelegate(env, jupload_data_stream);
|
|
|
| - scoped_ptr<CronetUploadDataStreamAdapter> upload_adapter(
|
| - new CronetUploadDataStreamAdapter(delegate, jlength));
|
| + scoped_ptr<CronetUploadDataStream> upload_data_stream(
|
| + new CronetUploadDataStream(delegate, jlength));
|
|
|
| - request_adapter->SetUpload(upload_adapter.Pass());
|
| + request_adapter->SetUpload(upload_data_stream.Pass());
|
|
|
| return reinterpret_cast<jlong>(delegate);
|
| }
|
| @@ -126,15 +127,15 @@ static jlong CreateDelegateForTesting(JNIEnv* env,
|
| return reinterpret_cast<jlong>(delegate);
|
| }
|
|
|
| -static jlong CreateAdapterForTesting(JNIEnv* env,
|
| - jobject jupload_data_stream,
|
| - jlong jlength,
|
| - jlong jdelegate) {
|
| +static jlong CreateUploadDataStreamForTesting(JNIEnv* env,
|
| + jobject jupload_data_stream,
|
| + jlong jlength,
|
| + jlong jdelegate) {
|
| CronetUploadDataStreamDelegate* delegate =
|
| reinterpret_cast<CronetUploadDataStreamDelegate*>(jdelegate);
|
| - CronetUploadDataStreamAdapter* upload_adapter =
|
| - new CronetUploadDataStreamAdapter(delegate, jlength);
|
| - return reinterpret_cast<jlong>(upload_adapter);
|
| + CronetUploadDataStream* upload_data_stream =
|
| + new CronetUploadDataStream(delegate, jlength);
|
| + return reinterpret_cast<jlong>(upload_data_stream);
|
| }
|
|
|
| static void DestroyDelegate(JNIEnv* env,
|
|
|