Add Stream support to WebBlobRegistry and FileAPIMessageFilter.

content/child/webblobregistry_impl.cc

 // Copyright 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/child/webblobregistry_impl.h"
 
 #include "base/memory/ref_counted.h"
 #include "base/message_loop.h"
 #include "base/shared_memory.h"
 #include "content/child/child_thread.h"
@@ skipping 15 matching lines @@
 
 WebBlobRegistryImpl::WebBlobRegistryImpl(ThreadSafeSender* sender)
     : sender_(sender) {
 }
 
 WebBlobRegistryImpl::~WebBlobRegistryImpl() {
 }
 
 void WebBlobRegistryImpl::SendData(const WebURL& url,
                                    const WebThreadSafeData& data,
                                    webkit_blob::BlobData::Item* item) {

[michaeln, 2013/06/24 20:48:17]

Do callers of this method use in any way the modified 'item' value?

If not, i think it would make sense to remove the ptr from the param list and to
just define one locally on the stack. Wdyt?

[tyoshino (SeeGerritForStatus), 2013/06/25 08:38:00]

One Item instance is shared between code for each type. There's no interaction
between them. Done.

   const size_t kLargeThresholdBytes = 250 * 1024;
   const size_t kMaxSharedMemoryBytes = 10 * 1024 * 1024;
 
   if (data.size() == 0)
     return;
   if (data.size() < kLargeThresholdBytes) {
     item->SetToBytes(data.data(), data.size());
     sender_->Send(new BlobHostMsg_AppendBlobDataItem(url, *item));
   } else {
     // We handle larger amounts of data via SharedMemory instead of
@@ skipping 65 matching lines @@
         }
         break;
       default:
         NOTREACHED();
     }
   }
   sender_->Send(new BlobHostMsg_FinishBuildingBlob(
       url, data.contentType().utf8().data()));
 }
 
+void WebBlobRegistryImpl::registerStreamURL(
+    const WebURL& url, const WebString& content_type) {
+  DCHECK(ChildThread::current()->message_loop() ==
+         base::MessageLoop::current());
+  sender_->Send(new BlobHostMsg_StartBuildingStream(url, type.utf8()));
+}
+
 void WebBlobRegistryImpl::registerBlobURL(
     const WebURL& url, const WebURL& src_url) {
   DCHECK(ChildThread::current()->message_loop() ==
          base::MessageLoop::current());
   sender_->Send(new BlobHostMsg_CloneBlob(url, src_url));
 }
 
+void WebBlobRegistryImpl::addDataToStream(const WebKit::WebURL& url,
+                                          WebKit::WebThreadSafeData& data) {
+  DCHECK(ChildThread::current()->message_loop() ==
+         base::MessageLoop::current());
+  webkit_blob::BlobData::Item item;
+  SendData(url, data, &item);
+}
+
+void WebBlobRegistryImpl::finalizeStream(const WebURL& url) {
+  DCHECK(ChildThread::current()->message_loop() ==
+         base::MessageLoop::current());
+  sender_->Send(new BlobHostMsg_FinishBuildingBlob(url, ""));
+}
+
 void WebBlobRegistryImpl::unregisterBlobURL(const WebURL& url) {
   DCHECK(ChildThread::current()->message_loop() ==
          base::MessageLoop::current());
   sender_->Send(new BlobHostMsg_RemoveBlob(url));
 }
 
 }  // namespace content