Index: content/browser/streams/stream.cc |
diff --git a/content/browser/streams/stream.cc b/content/browser/streams/stream.cc |
index 6026df9e7c759629ffcd661ab70c676cd4d1691b..a9d4333254407931d218b0bd142cc950b9b6b000 100644 |
--- a/content/browser/streams/stream.cc |
+++ b/content/browser/streams/stream.cc |
@@ -27,6 +27,7 @@ Stream::Stream(StreamRegistry* registry, |
can_add_data_(true), |
url_(url), |
data_length_(0), |
+ last_total_buffered_bytes_(0), |
registry_(registry), |
read_observer_(NULL), |
write_observer_(write_observer), |
@@ -67,19 +68,46 @@ void Stream::RemoveWriteObserver(StreamWriteObserver* observer) { |
write_observer_ = NULL; |
} |
+void Stream::Abort() { |
+ // Clear all buffer. It's safe to clear reader_ here since the same thread |
+ // is used for both input and output operation. |
+ writer_.reset(); |
+ reader_.reset(); |
+ can_add_data_ = false; |
+ registry_->UnregisterStream(url()); |
+} |
+ |
void Stream::AddData(scoped_refptr<net::IOBuffer> buffer, size_t size) { |
+ if (!writer_.get()) |
+ return; |
+ |
+ size_t current_buffered_bytes = writer_->GetTotalBufferedBytes(); |
+ if (!registry_->UpdateMemoryUsage(url(), current_buffered_bytes, size)) { |
+ Abort(); |
+ return; |
+ } |
+ |
+ // Now it's guaranteed that this doesn't overflow. This must be done before |
+ // Write() since GetTotalBufferedBytes() may return different value after |
+ // Write() call, so if we use the new value, information in this instance and |
+ // one in |registry_| become inconsistent. |
+ last_total_buffered_bytes_ = current_buffered_bytes + size; |
+ |
can_add_data_ = writer_->Write(buffer, size); |
} |
void Stream::AddData(const char* data, size_t size) { |
scoped_refptr<net::IOBuffer> io_buffer(new net::IOBuffer(size)); |
memcpy(io_buffer->data(), data, size); |
- can_add_data_ = writer_->Write(io_buffer, size); |
+ AddData(io_buffer, size); |
} |
void Stream::Finalize() { |
+ if (!writer_.get()) |
+ return; |
+ |
writer_->Close(0); |
- writer_.reset(NULL); |
+ writer_.reset(); |
// Continue asynchronously. |
base::MessageLoopProxy::current()->PostTask( |
@@ -95,6 +123,11 @@ Stream::StreamState Stream::ReadRawData(net::IOBuffer* buf, |
*bytes_read = 0; |
if (!data_.get()) { |
+ // TODO(tyoshino): Add STREAM_ABORTED type to tell the reader that this |
+ // stream is aborted. |
+ if (!reader_.get()) |
+ return STREAM_EMPTY; |
+ |
data_length_ = 0; |
data_bytes_read_ = 0; |
ByteStreamReader::StreamState state = reader_->Read(&data_, &data_length_); |