| Index: content/browser/byte_stream.cc
|
| diff --git a/content/browser/byte_stream.cc b/content/browser/byte_stream.cc
|
| index f83e8c31641f7ee4a1763ec662e1d1d36439bb75..4b06ac54f5e8132202f512be6b6f2db45dcba44d 100644
|
| --- a/content/browser/byte_stream.cc
|
| +++ b/content/browser/byte_stream.cc
|
| @@ -55,7 +55,7 @@ class ByteStreamWriterImpl : public ByteStreamWriter {
|
| // Overridden from ByteStreamWriter.
|
| virtual bool Write(scoped_refptr<net::IOBuffer> buffer,
|
| size_t byte_count) OVERRIDE;
|
| - virtual void Close(DownloadInterruptReason status) OVERRIDE;
|
| + virtual void Close(int status) OVERRIDE;
|
| virtual void RegisterCallback(const base::Closure& source_callback) OVERRIDE;
|
|
|
| // PostTask target from |ByteStreamReaderImpl::MaybeUpdateInput|.
|
| @@ -67,7 +67,7 @@ class ByteStreamWriterImpl : public ByteStreamWriter {
|
| // Called from UpdateWindow when object existence has been validated.
|
| void UpdateWindowInternal(size_t bytes_consumed);
|
|
|
| - void PostToPeer(bool complete, DownloadInterruptReason status);
|
| + void PostToPeer(bool complete, int status);
|
|
|
| const size_t total_buffer_size_;
|
|
|
| @@ -113,7 +113,7 @@ class ByteStreamReaderImpl : public ByteStreamReader {
|
| // Overridden from ByteStreamReader.
|
| virtual StreamState Read(scoped_refptr<net::IOBuffer>* data,
|
| size_t* length) OVERRIDE;
|
| - virtual DownloadInterruptReason GetStatus() const OVERRIDE;
|
| + virtual int GetStatus() const OVERRIDE;
|
| virtual void RegisterCallback(const base::Closure& sink_callback) OVERRIDE;
|
|
|
| // PostTask target from |ByteStreamWriterImpl::MaybePostToPeer| and
|
| @@ -128,7 +128,7 @@ class ByteStreamReaderImpl : public ByteStreamReader {
|
| scoped_ptr<ContentVector> transfer_buffer,
|
| size_t transfer_buffer_bytes,
|
| bool source_complete,
|
| - DownloadInterruptReason status);
|
| + int status);
|
|
|
| private:
|
| // Called from TransferData once object existence has been validated.
|
| @@ -136,7 +136,7 @@ class ByteStreamReaderImpl : public ByteStreamReader {
|
| scoped_ptr<ContentVector> transfer_buffer,
|
| size_t transfer_buffer_bytes,
|
| bool source_complete,
|
| - DownloadInterruptReason status);
|
| + int status);
|
|
|
| void MaybeUpdateInput();
|
|
|
| @@ -150,7 +150,7 @@ class ByteStreamReaderImpl : public ByteStreamReader {
|
| ContentVector available_contents_;
|
|
|
| bool received_status_;
|
| - DownloadInterruptReason status_;
|
| + int status_;
|
|
|
| base::Closure data_available_callback_;
|
|
|
| @@ -210,13 +210,12 @@ bool ByteStreamWriterImpl::Write(
|
|
|
| // Arbitrarily, we buffer to a third of the total size before sending.
|
| if (input_contents_size_ > total_buffer_size_ / kFractionBufferBeforeSending)
|
| - PostToPeer(false, DOWNLOAD_INTERRUPT_REASON_NONE);
|
| + PostToPeer(false, 0 /* status */);
|
|
|
| return (input_contents_size_ + output_size_used_ <= total_buffer_size_);
|
| }
|
|
|
| -void ByteStreamWriterImpl::Close(
|
| - DownloadInterruptReason status) {
|
| +void ByteStreamWriterImpl::Close(int status) {
|
| DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
|
| PostToPeer(true, status);
|
| }
|
| @@ -252,8 +251,7 @@ void ByteStreamWriterImpl::UpdateWindowInternal(size_t bytes_consumed) {
|
| space_available_callback_.Run();
|
| }
|
|
|
| -void ByteStreamWriterImpl::PostToPeer(
|
| - bool complete, DownloadInterruptReason status) {
|
| +void ByteStreamWriterImpl::PostToPeer(bool complete, int status) {
|
| DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
|
| // Valid contexts in which to call.
|
| DCHECK(complete || 0 != input_contents_size_);
|
| @@ -286,7 +284,7 @@ ByteStreamReaderImpl::ByteStreamReaderImpl(
|
| my_task_runner_(task_runner),
|
| my_lifetime_flag_(lifetime_flag),
|
| received_status_(false),
|
| - status_(DOWNLOAD_INTERRUPT_REASON_NONE),
|
| + status_(0),
|
| unreported_consumed_bytes_(0),
|
| peer_(NULL) {
|
| DCHECK(my_lifetime_flag_.get());
|
| @@ -326,7 +324,7 @@ ByteStreamReaderImpl::Read(scoped_refptr<net::IOBuffer>* data,
|
| return STREAM_EMPTY;
|
| }
|
|
|
| -DownloadInterruptReason ByteStreamReaderImpl::GetStatus() const {
|
| +int ByteStreamReaderImpl::GetStatus() const {
|
| DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
|
| DCHECK(received_status_);
|
| return status_;
|
| @@ -346,7 +344,7 @@ void ByteStreamReaderImpl::TransferData(
|
| scoped_ptr<ContentVector> transfer_buffer,
|
| size_t buffer_size,
|
| bool source_complete,
|
| - DownloadInterruptReason status) {
|
| + int status) {
|
| // If our target is no longer alive, do nothing.
|
| if (!object_lifetime_flag->is_alive) return;
|
|
|
| @@ -358,7 +356,7 @@ void ByteStreamReaderImpl::TransferDataInternal(
|
| scoped_ptr<ContentVector> transfer_buffer,
|
| size_t buffer_size,
|
| bool source_complete,
|
| - DownloadInterruptReason status) {
|
| + int status) {
|
| DCHECK(my_task_runner_->RunsTasksOnCurrentThread());
|
|
|
| bool was_empty = available_contents_.empty();
|
|
|