Introduce WebTaskRunner Patch 3/5

Source/modules/fetch/DataConsumerHandleTestUtil.cpp

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "config.h"
 #include "modules/fetch/DataConsumerHandleTestUtil.h"
 
 #include "bindings/core/v8/DOMWrapperWorld.h"
 
 namespace blink {
@@ skipping 186 matching lines @@
     } else {
         m_offset += size;
     }
 }
 
 void DataConsumerHandleTestUtil::ReplayingHandle::Context::notify()
 {
     if (!m_client)
         return;
     ASSERT(m_readerThread);
-    m_readerThread->postTask(FROM_HERE, new Task(threadSafeBind(&Context::notifyInternal, this)));
+    m_readerThread->defaultTaskRunner()->postTask(FROM_HERE, new Task(threadSafeBind(&Context::notifyInternal, this)));
 }
 
 void DataConsumerHandleTestUtil::ReplayingHandle::Context::notifyInternal()
 {
     {
         MutexLocker locker(m_mutex);
         if (!m_client || !m_readerThread->isCurrentThread()) {
             // There is no client, or a new reader is attached.
             return;
         }
@@ skipping 36 matching lines @@
         size_t size;
         r = m_reader->read(buffer, sizeof(buffer), WebDataConsumerHandle::FlagNone, &size);
         if (r == WebDataConsumerHandle::ShouldWait)
             return;
         if (r != WebDataConsumerHandle::Ok)
             break;
         m_data.append(buffer, size);
     }
     OwnPtr<HandleReadResult> result = adoptPtr(new HandleReadResult(r, m_data));
     m_data.clear();
-    Platform::current()->currentThread()->postTask(FROM_HERE, new Task(bind(&HandleReader::runOnFinishedReading, this, result.release())));
+    Platform::current()->currentThread()->defaultTaskRunner()->postTask(FROM_HERE, new Task(bind(&HandleReader::runOnFinishedReading, this, result.release())));
     m_reader = nullptr;
 }
 
 void DataConsumerHandleTestUtil::HandleReader::runOnFinishedReading(PassOwnPtr<HandleReadResult> result)
 {
     ASSERT(m_onFinishedReading);
     (*m_onFinishedReading.release())(result);
 }
 
 DataConsumerHandleTestUtil::HandleTwoPhaseReader::HandleTwoPhaseReader(PassOwnPtr<WebDataConsumerHandle> handle, PassOwnPtr<OnFinishedReading> onFinishedReading)
@@ skipping 13 matching lines @@
             return;
         if (r != WebDataConsumerHandle::Ok)
             break;
         // Read smaller than available in order to test |endRead|.
         size_t readSize = std::min(size, std::max(size * 2 / 3, static_cast<size_t>(1)));
         m_data.append(static_cast<const char*>(buffer), readSize);
         m_reader->endRead(readSize);
     }
     OwnPtr<HandleReadResult> result = adoptPtr(new HandleReadResult(r, m_data));
     m_data.clear();
-    Platform::current()->currentThread()->postTask(FROM_HERE, new Task(bind(&HandleTwoPhaseReader::runOnFinishedReading, this, result.release())));
+    Platform::current()->currentThread()->defaultTaskRunner()->postTask(FROM_HERE, new Task(bind(&HandleTwoPhaseReader::runOnFinishedReading, this, result.release())));
     m_reader = nullptr;
 }
 
 void DataConsumerHandleTestUtil::HandleTwoPhaseReader::runOnFinishedReading(PassOwnPtr<HandleReadResult> result)
 {
     ASSERT(m_onFinishedReading);
     (*m_onFinishedReading.release())(result);
 }
 
 } // namespace blink