| Index: components/cronet/android/cronet_upload_data_stream.cc
|
| diff --git a/components/cronet/android/cronet_upload_data_stream_adapter.cc b/components/cronet/android/cronet_upload_data_stream.cc
|
| similarity index 77%
|
| rename from components/cronet/android/cronet_upload_data_stream_adapter.cc
|
| rename to components/cronet/android/cronet_upload_data_stream.cc
|
| index 4ac38b9467237da8e3227a7e909ddd2d8fb5ff35..c933f403765bb8bb2e74a6fe71f1b01c1dca9ef9 100644
|
| --- a/components/cronet/android/cronet_upload_data_stream_adapter.cc
|
| +++ b/components/cronet/android/cronet_upload_data_stream.cc
|
| @@ -2,15 +2,14 @@
|
| // Use of this source code is governed by a BSD-style license that can be
|
| // found in the LICENSE file.
|
|
|
| -#include "components/cronet/android/cronet_upload_data_stream_adapter.h"
|
| +#include "components/cronet/android/cronet_upload_data_stream.h"
|
|
|
| #include "net/base/io_buffer.h"
|
| #include "net/base/net_errors.h"
|
|
|
| namespace cronet {
|
|
|
| -CronetUploadDataStreamAdapter::CronetUploadDataStreamAdapter(Delegate* delegate,
|
| - int64 size)
|
| +CronetUploadDataStream::CronetUploadDataStream(Delegate* delegate, int64 size)
|
| : UploadDataStream(size < 0, 0),
|
| size_(size),
|
| waiting_on_read_(false),
|
| @@ -22,12 +21,12 @@ CronetUploadDataStreamAdapter::CronetUploadDataStreamAdapter(Delegate* delegate,
|
| weak_factory_(this) {
|
| }
|
|
|
| -CronetUploadDataStreamAdapter::~CronetUploadDataStreamAdapter() {
|
| - delegate_->OnAdapterDestroyed();
|
| +CronetUploadDataStream::~CronetUploadDataStream() {
|
| + delegate_->OnUploadDataStreamDestroyed();
|
| }
|
|
|
| -int CronetUploadDataStreamAdapter::InitInternal() {
|
| - // ResetInternal should have been called before init, if the adapter was in
|
| +int CronetUploadDataStream::InitInternal() {
|
| + // ResetInternal should have been called before init, if the stream was in
|
| // use.
|
| DCHECK(!waiting_on_read_);
|
| DCHECK(!waiting_on_rewind_);
|
| @@ -57,8 +56,7 @@ int CronetUploadDataStreamAdapter::InitInternal() {
|
| return net::ERR_IO_PENDING;
|
| }
|
|
|
| -int CronetUploadDataStreamAdapter::ReadInternal(net::IOBuffer* buf,
|
| - int buf_len) {
|
| +int CronetUploadDataStream::ReadInternal(net::IOBuffer* buf, int buf_len) {
|
| // All pending operations should have completed before a read can start.
|
| DCHECK(!waiting_on_read_);
|
| DCHECK(!read_in_progress_);
|
| @@ -75,15 +73,14 @@ int CronetUploadDataStreamAdapter::ReadInternal(net::IOBuffer* buf,
|
| return net::ERR_IO_PENDING;
|
| }
|
|
|
| -void CronetUploadDataStreamAdapter::ResetInternal() {
|
| +void CronetUploadDataStream::ResetInternal() {
|
| // Consumer is not waiting on any operation. Note that the active operation,
|
| // if any, will continue.
|
| waiting_on_read_ = false;
|
| waiting_on_rewind_ = false;
|
| }
|
|
|
| -void CronetUploadDataStreamAdapter::OnReadSuccess(int bytes_read,
|
| - bool final_chunk) {
|
| +void CronetUploadDataStream::OnReadSuccess(int bytes_read, bool final_chunk) {
|
| DCHECK(read_in_progress_);
|
| DCHECK(!rewind_in_progress_);
|
| DCHECK(bytes_read > 0 || (final_chunk && bytes_read == 0));
|
| @@ -109,7 +106,7 @@ void CronetUploadDataStreamAdapter::OnReadSuccess(int bytes_read,
|
| OnReadCompleted(bytes_read);
|
| }
|
|
|
| -void CronetUploadDataStreamAdapter::OnRewindSuccess() {
|
| +void CronetUploadDataStream::OnRewindSuccess() {
|
| DCHECK(!waiting_on_read_);
|
| DCHECK(!read_in_progress_);
|
| DCHECK(rewind_in_progress_);
|
| @@ -127,7 +124,7 @@ void CronetUploadDataStreamAdapter::OnRewindSuccess() {
|
| OnInitCompleted(net::OK);
|
| }
|
|
|
| -void CronetUploadDataStreamAdapter::StartRewind() {
|
| +void CronetUploadDataStream::StartRewind() {
|
| DCHECK(!waiting_on_read_);
|
| DCHECK(!read_in_progress_);
|
| DCHECK(waiting_on_rewind_);
|
|
|