Introduce Stream::flush [1/2 blink]

Source/platform/blob/BlobRegistry.cpp

 /*
  * Copyright (C) 2010 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 194 matching lines @@
 {
     if (isMainThread()) {
         if (WebBlobRegistry* registry = blobRegistry())
             registry->addDataToStream(url, streamData->data(), streamData->length());
     } else {
         OwnPtr<BlobRegistryContext> context = adoptPtr(new BlobRegistryContext(url, streamData));
         callOnMainThread(&addDataToStreamTask, context.leakPtr());
     }
 }
 
+static void flushStreamTask(void* context)
+{
+    OwnPtr<BlobRegistryContext> blobRegistryContext = adoptPtr(static_cast<BlobRegistryContext*>(context));
+    if (WebBlobRegistry* registry = blobRegistry())
+        registry->flushStream(blobRegistryContext->url);
+}
+
+void BlobRegistry::flushStream(const KURL& url)
+{
+    if (isMainThread()) {
+        if (WebBlobRegistry* registry = blobRegistry())
+            registry->flushStream(url);
+    } else {
+        OwnPtr<BlobRegistryContext> context = adoptPtr(new BlobRegistryContext(url));
+        callOnMainThread(&flushStreamTask, context.leakPtr());
+    }
+}
+
 static void finalizeStreamTask(void* context)
 {
     OwnPtr<BlobRegistryContext> blobRegistryContext = adoptPtr(static_cast<BlobRegistryContext*>(context));
     if (WebBlobRegistry* registry = blobRegistry())
         registry->finalizeStream(blobRegistryContext->url);
 }
 
 void BlobRegistry::finalizeStream(const KURL& url)
 {
     if (isMainThread()) {
@@ skipping 49 matching lines @@
 }
 
 SecurityOrigin* BlobOriginCache::cachedOrigin(const KURL& url)
 {
     if (url.protocolIs("blob"))
         return originMap()->get(url.string());
     return 0;
 }
 
 } // namespace blink