Introduce WebTaskRunner Patch 3/5

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 22 matching lines @@
 
 #include "platform/ThreadSafeFunctional.h"
 #include "platform/blob/BlobData.h"
 #include "platform/blob/BlobURL.h"
 #include "platform/weborigin/SecurityOrigin.h"
 #include "platform/weborigin/SecurityOriginCache.h"
 #include "public/platform/Platform.h"
 #include "public/platform/WebBlobData.h"
 #include "public/platform/WebBlobRegistry.h"
 #include "public/platform/WebString.h"
+#include "public/platform/WebTaskRunner.h"
 #include "public/platform/WebTraceLocation.h"
 #include "wtf/Assertions.h"
 #include "wtf/HashMap.h"
 #include "wtf/MainThread.h"
 #include "wtf/RefPtr.h"
 #include "wtf/ThreadSpecific.h"
 #include "wtf/Threading.h"
 #include "wtf/text/StringHash.h"
 #include "wtf/text/WTFString.h"
 
@@ skipping 67 matching lines @@
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->registerStreamURL(url, type);
 }
 
 void BlobRegistry::registerStreamURL(const KURL& url, const String& type)
 {
     if (isMainThread())
         registerStreamURLTask(url, type);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&registerStreamURLTask, url, type));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&registerStreamURLTask, url, type));
 }
 
 static void registerStreamURLFromTask(const KURL& url, const KURL& srcURL)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->registerStreamURL(url, srcURL);
 }
 
 void BlobRegistry::registerStreamURL(SecurityOrigin* origin, const KURL& url, const KURL& srcURL)
 {
     saveToOriginMap(origin, url);
 
     if (isMainThread())
         registerStreamURLFromTask(url, srcURL);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&registerStreamURLFromTask, url, srcURL));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&registerStreamURLFromTask, url, srcURL));
 }
 
 static void addDataToStreamTask(const KURL& url, PassRefPtr<RawData> streamData)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->addDataToStream(url, streamData->data(), streamData->length());
 }
 
 void BlobRegistry::addDataToStream(const KURL& url, PassRefPtr<RawData> streamData)
 {
     if (isMainThread())
         addDataToStreamTask(url, streamData);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&addDataToStreamTask, url, streamData));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&addDataToStreamTask, url, streamData));
 }
 
 static void flushStreamTask(const KURL& url)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->flushStream(url);
 }
 
 void BlobRegistry::flushStream(const KURL& url)
 {
     if (isMainThread())
         flushStreamTask(url);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&flushStreamTask, url));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&flushStreamTask, url));
 }
 
 static void finalizeStreamTask(const KURL& url)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->finalizeStream(url);
 }
 
 void BlobRegistry::finalizeStream(const KURL& url)
 {
     if (isMainThread())
         finalizeStreamTask(url);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&finalizeStreamTask, url));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&finalizeStreamTask, url));
 }
 
 static void abortStreamTask(const KURL& url)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->abortStream(url);
 }
 
 void BlobRegistry::abortStream(const KURL& url)
 {
     if (isMainThread())
         abortStreamTask(url);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&abortStreamTask, url));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&abortStreamTask, url));
 }
 
 static void unregisterStreamURLTask(const KURL& url)
 {
     if (WebBlobRegistry* registry = blobRegistry())
         registry->unregisterStreamURL(url);
 }
 
 void BlobRegistry::unregisterStreamURL(const KURL& url)
 {
     removeFromOriginMap(url);
 
     if (isMainThread())
         unregisterStreamURLTask(url);
     else
-        Platform::current()->mainThread()->postTask(FROM_HERE, threadSafeBind(&unregisterStreamURLTask, url));
+        Platform::current()->mainThread()->taskRunner()->postTask(FROM_HERE, threadSafeBind(&unregisterStreamURLTask, url));
 }
 
 BlobOriginCache::BlobOriginCache()
 {
     SecurityOrigin::setCache(this);
 }
 
 SecurityOrigin* BlobOriginCache::cachedOrigin(const KURL& url)
 {
     if (url.protocolIs("blob"))
         return originMap()->get(url.string());
     return 0;
 }
 
 } // namespace blink