Add support for redirecting ResourceHandlers to a blob: URL

content/browser/loader/stream_resource_handler.cc

Index: content/browser/loader/stream_resource_handler.cc
diff --git a/content/browser/loader/stream_resource_handler.cc b/content/browser/loader/stream_resource_handler.cc
new file mode 100644
index 0000000000000000000000000000000000000000..a8bddc117cc099b333dc54a7d355c6d33edd92c4
--- /dev/null
+++ b/content/browser/loader/stream_resource_handler.cc
@@ -0,0 +1,113 @@
+// Copyright (c) 2013 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 "content/browser/loader/stream_resource_handler.h"
+
+#include "base/logging.h"
+#include "content/browser/streams/stream.h"
+#include "content/public/browser/resource_controller.h"
+#include "net/base/io_buffer.h"
+#include "net/url_request/url_request_status.h"
+
+namespace content {
+
+StreamResourceHandler::StreamResourceHandler(
+    net::URLRequest* request,
+    scoped_refptr<Stream> stream)
+    : request_(request),
+      stream_(stream),
+      read_buffer_(NULL) {
+  stream_->AddWriteObserver(this);
+}
+
+StreamResourceHandler::~StreamResourceHandler() {
+  stream_->RemoveWriteObserver(this);
+}
+
+bool StreamResourceHandler::OnUploadProgress(int request_id,
+                                             uint64 position,
+                                             uint64 size) {
+  return true;
+}
+
+bool StreamResourceHandler::OnRequestRedirected(int request_id,
+                                                const GURL& url,
+                                                ResourceResponse* resp,
+                                                bool* defer) {
+  return true;
+}
+
+bool StreamResourceHandler::OnResponseStarted(int request_id,
+                                              ResourceResponse* resp,
+                                              bool* defer) {
+  return true;
+}
+
+bool StreamResourceHandler::OnWillStart(int request_id,
+                                        const GURL& url,
+                                        bool* defer) {
+  return true;
+}
+
+bool StreamResourceHandler::OnWillRead(int request_id,
+                                       net::IOBuffer** buf,
+                                       int* buf_size,
+                                       int min_size) {
+  static const int kReadBufSize = 32768;
+
+  DCHECK(buf && buf_size);
+  if (!read_buffer_) {
+    read_buffer_ = new net::IOBuffer(kReadBufSize);
+  }
+  *buf = read_buffer_.get();
+  *buf_size = kReadBufSize;
+
+  return true;
+}
+
+bool StreamResourceHandler::OnReadCompleted(int request_id,
+                                            int bytes_read,
+                                            bool* defer) {
+  if (!bytes_read)
+    return true;
+
+  // We have more data to read.
+  DCHECK(read_buffer_);
+
+  // Release the ownership of the buffer, and store a reference
+  // to it. A new one will be allocated in OnWillRead().
+  net::IOBuffer* buffer = NULL;
+  read_buffer_.swap(&buffer);
+  stream_->AddData(buffer, bytes_read);
+
+  if (!stream_->can_add_data()) {
+    *defer = true;
+  }
+
+  return true;
+}
+
+bool StreamResourceHandler::OnResponseCompleted(
+    int request_id,
+    const net::URLRequestStatus& urs,
+    const std::string& sec_info) {
+  stream_->MarkComplete();
+  if (urs.status() != net::URLRequestStatus::SUCCESS)
+    return false;
+
+  return true;
+}
+
+void StreamResourceHandler::OnDataDownloaded(
+    int request_id,
+    int bytes_downloaded) {
+  NOTREACHED();
+}
+
+void StreamResourceHandler::OnSpaceAvailable(Stream* stream) {
+  controller()->Resume();
+}
+
+}  // namespace content
+