Use per-frame TaskRunner instead of thread's default in DataConsumerHandle

third_party/WebKit/Source/core/loader/DocumentThreadableLoader.cpp

 /*
  * Copyright (C) 2011, 2012 Google Inc. All rights reserved.
  * Copyright (C) 2013, Intel Corporation
  *
  * 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.
@@ skipping 49 matching lines @@
 #include <memory>
 
 namespace blink {
 
 namespace {
 
 class EmptyDataHandle final : public WebDataConsumerHandle {
 private:
     class EmptyDataReader final : public WebDataConsumerHandle::Reader {
     public:
-        explicit EmptyDataReader(WebDataConsumerHandle::Client* client) : m_factory(this)
+        explicit EmptyDataReader(WebDataConsumerHandle::Client* client, std::unique_ptr<WebTaskRunner> readerTaskRunner) : m_factory(this)
         {
-            Platform::current()->currentThread()->getWebTaskRunner()->postTask(BLINK_FROM_HERE, WTF::bind(&EmptyDataReader::notify, m_factory.createWeakPtr(), WTF::unretained(client)));
+            DCHECK(readerTaskRunner->runsTasksOnCurrentThread());
+            readerTaskRunner->postTask(BLINK_FROM_HERE, WTF::bind(&EmptyDataReader::notify, m_factory.createWeakPtr(), WTF::unretained(client)));
         }
     private:
         Result beginRead(const void** buffer, WebDataConsumerHandle::Flags, size_t *available) override
         {
             *available = 0;
             *buffer = nullptr;
             return Done;
         }
         Result endRead(size_t) override
         {
             return WebDataConsumerHandle::UnexpectedError;
         }
         void notify(WebDataConsumerHandle::Client* client)
         {
             client->didGetReadable();
         }
         WeakPtrFactory<EmptyDataReader> m_factory;
     };
 
-    std::unique_ptr<Reader> obtainReader(Client* client) override
+    std::unique_ptr<Reader> obtainReader(Client* client, std::unique_ptr<WebTaskRunner> readerTaskRunner) override
     {
-        return WTF::wrapUnique(new EmptyDataReader(client));
+        return WTF::wrapUnique(new EmptyDataReader(client, std::move(readerTaskRunner)));
     }
     const char* debugName() const override { return "EmptyDataHandle"; }
 };
 
 // No-CORS requests are allowed for all these contexts, and plugin contexts with
 // private permission when we set skipServiceWorker flag in PepperURLLoaderHost.
 bool IsNoCORSAllowedContext(WebURLRequest::RequestContext context, WebURLRequest::SkipServiceWorker skipServiceWorker)
 {
     switch (context) {
     case WebURLRequest::RequestContextAudio:
@@ skipping 910 matching lines @@
     return m_securityOrigin ? m_securityOrigin.get() : document().getSecurityOrigin();
 }
 
 Document& DocumentThreadableLoader::document() const
 {
     ASSERT(m_document);
     return *m_document;
 }
 
 } // namespace blink