Introduce Stream::flush [2/2 chromium]

content/browser/fileapi/fileapi_message_filter.cc

Index: content/browser/fileapi/fileapi_message_filter.cc
diff --git a/content/browser/fileapi/fileapi_message_filter.cc b/content/browser/fileapi/fileapi_message_filter.cc
index 3fe4199272afabde75ebb028962f04cb569f4a5d..17e3abe4592346db8818efc2915a8047e23c65da 100644
--- a/content/browser/fileapi/fileapi_message_filter.cc
+++ b/content/browser/fileapi/fileapi_message_filter.cc
@@ -185,6 +185,7 @@ bool FileAPIMessageFilter::OnMessageReceived(const IPC::Message& message) {
                         OnAppendBlobDataItemToStream)
     IPC_MESSAGE_HANDLER(StreamHostMsg_SyncAppendSharedMemory,
                         OnAppendSharedMemoryToStream)
+    IPC_MESSAGE_HANDLER(StreamHostMsg_Flush, OnFlushStream)
     IPC_MESSAGE_HANDLER(StreamHostMsg_FinishBuilding, OnFinishBuildingStream)
     IPC_MESSAGE_HANDLER(StreamHostMsg_AbortBuilding, OnAbortBuildingStream)
     IPC_MESSAGE_HANDLER(StreamHostMsg_Clone, OnCloneStream)
@@ -653,6 +654,13 @@ void FileAPIMessageFilter::OnAppendSharedMemoryToStream(
   stream->AddData(static_cast<char*>(shared_memory.memory()), buffer_size);
 }
 
+void FileAPIMessageFilter::OnFlushStream(const GURL& url) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+  scoped_refptr<Stream> stream(GetStreamForURL(url));
+  if (stream.get())

[jochen (gone - plz use gerrit), 2014/12/08 12:06:41]

when can this happen? Should we kill the renderer if this happens?

[horo, 2014/12/09 02:28:51]

When the reader of the stream stops reading, the stream will be unregistered
from the stream registry by Stream::CloseHandle().
So we have to check the existence of the stream.

+    stream->Flush();
+}
+
 void FileAPIMessageFilter::OnFinishBuildingStream(const GURL& url) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   scoped_refptr<Stream> stream(GetStreamForURL(url));