Add method to abort Stream construction to BlobRegistry

Source/core/fileapi/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 255 matching lines @@
 {
     if (isMainThread()) {
         if (WebBlobRegistry* registry = blobRegistry())
             registry->finalizeStream(url);
     } else {
         OwnPtr<BlobRegistryContext> context = adoptPtr(new BlobRegistryContext(url));
         callOnMainThread(&finalizeStreamTask, context.leakPtr());
     }
 }
 
+static void abortStreamTask(void* context)
+{
+    OwnPtr<BlobRegistryContext> blobRegistryContext = adoptPtr(static_cast<BlobRegistryContext*>(context));
+    if (WebBlobRegistry* registry = blobRegistry())
+        registry->abortStream(blobRegistryContext->url);
+}
+
+void BlobRegistry::abortStream(const KURL& url)
+{
+    if (isMainThread()) {
+        if (WebBlobRegistry* registry = blobRegistry())
+            registry->abortStream(url);
+    } else {
+        OwnPtr<BlobRegistryContext> context = adoptPtr(new BlobRegistryContext(url));
+        callOnMainThread(&abortStreamTask, context.leakPtr());
+    }
+}
+
 static void unregisterStreamURLTask(void* context)
 {
     OwnPtr<BlobRegistryContext> blobRegistryContext = adoptPtr(static_cast<BlobRegistryContext*>(context));
     if (WebBlobRegistry* registry = blobRegistry())
         registry->unregisterStreamURL(blobRegistryContext->url);
 }
 
 void BlobRegistry::unregisterStreamURL(const KURL& url)
 {
     removeFromOriginMap(url);
@@ skipping 13 matching lines @@
 }
 
 SecurityOrigin* BlobOriginCache::cachedOrigin(const KURL& url)
 {
     if (url.protocolIs("blob"))
         return originMap()->get(url.string());
     return 0;
 }
 
 } // namespace WebCore