| Index: net/base/upload_data_stream.cc
|
| diff --git a/net/base/upload_data_stream.cc b/net/base/upload_data_stream.cc
|
| deleted file mode 100644
|
| index 936c9128833017c91e5738b4338974748ec7af4e..0000000000000000000000000000000000000000
|
| --- a/net/base/upload_data_stream.cc
|
| +++ /dev/null
|
| @@ -1,128 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "net/base/upload_data_stream.h"
|
| -
|
| -#include "base/callback_helpers.h"
|
| -#include "base/logging.h"
|
| -#include "net/base/io_buffer.h"
|
| -#include "net/base/net_errors.h"
|
| -
|
| -namespace net {
|
| -
|
| -UploadDataStream::UploadDataStream(bool is_chunked, int64 identifier)
|
| - : total_size_(0),
|
| - current_position_(0),
|
| - identifier_(identifier),
|
| - is_chunked_(is_chunked),
|
| - initialized_successfully_(false),
|
| - is_eof_(false) {
|
| -}
|
| -
|
| -UploadDataStream::~UploadDataStream() {
|
| -}
|
| -
|
| -int UploadDataStream::Init(const CompletionCallback& callback) {
|
| - Reset();
|
| - DCHECK(!initialized_successfully_);
|
| - DCHECK(callback_.is_null());
|
| - DCHECK(!callback.is_null() || IsInMemory());
|
| - int result = InitInternal();
|
| - if (result == ERR_IO_PENDING) {
|
| - DCHECK(!IsInMemory());
|
| - callback_ = callback;
|
| - } else {
|
| - OnInitCompleted(result);
|
| - }
|
| - return result;
|
| -}
|
| -
|
| -int UploadDataStream::Read(IOBuffer* buf,
|
| - int buf_len,
|
| - const CompletionCallback& callback) {
|
| - DCHECK(!callback.is_null() || IsInMemory());
|
| - DCHECK(initialized_successfully_);
|
| - DCHECK_GT(buf_len, 0);
|
| - if (is_eof_)
|
| - return 0;
|
| - int result = ReadInternal(buf, buf_len);
|
| - if (result == ERR_IO_PENDING) {
|
| - DCHECK(!IsInMemory());
|
| - callback_ = callback;
|
| - } else {
|
| - OnReadCompleted(result);
|
| - }
|
| - return result;
|
| -}
|
| -
|
| -bool UploadDataStream::IsEOF() const {
|
| - DCHECK(initialized_successfully_);
|
| - DCHECK(is_chunked_ || is_eof_ == (current_position_ == total_size_));
|
| - return is_eof_;
|
| -}
|
| -
|
| -void UploadDataStream::Reset() {
|
| - current_position_ = 0;
|
| - initialized_successfully_ = false;
|
| - is_eof_ = false;
|
| - total_size_ = 0;
|
| - callback_.Reset();
|
| - ResetInternal();
|
| -}
|
| -
|
| -void UploadDataStream::SetSize(uint64 size) {
|
| - DCHECK(!initialized_successfully_);
|
| - DCHECK(!is_chunked_);
|
| - total_size_ = size;
|
| -}
|
| -
|
| -void UploadDataStream::SetIsFinalChunk() {
|
| - DCHECK(initialized_successfully_);
|
| - DCHECK(is_chunked_);
|
| - DCHECK(!is_eof_);
|
| - is_eof_ = true;
|
| -}
|
| -
|
| -bool UploadDataStream::IsInMemory() const {
|
| - return false;
|
| -}
|
| -
|
| -const ScopedVector<UploadElementReader>*
|
| -UploadDataStream::GetElementReaders() const {
|
| - return NULL;
|
| -}
|
| -
|
| -void UploadDataStream::OnInitCompleted(int result) {
|
| - DCHECK_NE(ERR_IO_PENDING, result);
|
| - DCHECK(!initialized_successfully_);
|
| - DCHECK_EQ(0u, current_position_);
|
| - DCHECK(!is_eof_);
|
| -
|
| - if (result == OK) {
|
| - initialized_successfully_ = true;
|
| - if (!is_chunked_ && total_size_ == 0)
|
| - is_eof_ = true;
|
| - }
|
| - if (!callback_.is_null())
|
| - base::ResetAndReturn(&callback_).Run(result);
|
| -}
|
| -
|
| -void UploadDataStream::OnReadCompleted(int result) {
|
| - DCHECK_GE(result, 0);
|
| - DCHECK(initialized_successfully_);
|
| -
|
| - current_position_ += result;
|
| - if (!is_chunked_) {
|
| - DCHECK_LE(current_position_, total_size_);
|
| - if (current_position_ == total_size_)
|
| - is_eof_ = true;
|
| - }
|
| -
|
| - DCHECK(result > 0 || is_eof_);
|
| -
|
| - if (!callback_.is_null())
|
| - base::ResetAndReturn(&callback_).Run(result);
|
| -}
|
| -
|
| -} // namespace net
|
|
|