summaryrefslogtreecommitdiffstats
path: root/content/child/threaded_data_provider.cc
diff options
context:
space:
mode:
Diffstat (limited to 'content/child/threaded_data_provider.cc')
-rw-r--r--content/child/threaded_data_provider.cc12
1 files changed, 6 insertions, 6 deletions
diff --git a/content/child/threaded_data_provider.cc b/content/child/threaded_data_provider.cc
index 395e452..64daeeb 100644
--- a/content/child/threaded_data_provider.cc
+++ b/content/child/threaded_data_provider.cc
@@ -7,8 +7,8 @@
#include "content/child/child_process.h"
#include "content/child/child_thread_impl.h"
#include "content/child/resource_dispatcher.h"
-#include "content/child/scheduler/webthread_impl_for_worker_scheduler.h"
#include "content/child/thread_safe_sender.h"
+#include "content/child/webthread_impl.h"
#include "content/common/resource_messages.h"
#include "ipc/ipc_sync_channel.h"
#include "third_party/WebKit/public/platform/WebThread.h"
@@ -23,7 +23,7 @@ class DataProviderMessageFilter : public IPC::MessageFilter {
DataProviderMessageFilter(
const scoped_refptr<base::MessageLoopProxy>& io_message_loop,
scoped_refptr<base::SingleThreadTaskRunner> main_thread_task_runner,
- const WebThreadImplForWorkerScheduler& background_thread,
+ const WebThreadImpl& background_thread,
const base::WeakPtr<ThreadedDataProvider>&
background_thread_resource_provider,
const base::WeakPtr<ThreadedDataProvider>& main_thread_resource_provider,
@@ -41,7 +41,7 @@ class DataProviderMessageFilter : public IPC::MessageFilter {
const scoped_refptr<base::MessageLoopProxy> io_message_loop_;
scoped_refptr<base::SingleThreadTaskRunner> main_thread_task_runner_;
- const WebThreadImplForWorkerScheduler& background_thread_;
+ const WebThreadImpl& background_thread_;
// This weakptr can only be dereferenced on the background thread.
base::WeakPtr<ThreadedDataProvider>
background_thread_resource_provider_;
@@ -54,7 +54,7 @@ class DataProviderMessageFilter : public IPC::MessageFilter {
DataProviderMessageFilter::DataProviderMessageFilter(
const scoped_refptr<base::MessageLoopProxy>& io_message_loop,
scoped_refptr<base::SingleThreadTaskRunner> main_thread_task_runner,
- const WebThreadImplForWorkerScheduler& background_thread,
+ const WebThreadImpl& background_thread,
const base::WeakPtr<ThreadedDataProvider>&
background_thread_resource_provider,
const base::WeakPtr<ThreadedDataProvider>& main_thread_resource_provider,
@@ -126,7 +126,7 @@ ThreadedDataProvider::ThreadedDataProvider(
: request_id_(request_id),
shm_buffer_(shm_buffer),
shm_size_(shm_size),
- background_thread_(static_cast<WebThreadImplForWorkerScheduler&>(
+ background_thread_(static_cast<WebThreadImpl&>(
*threaded_data_receiver->backgroundThread())),
ipc_channel_(ChildThreadImpl::current()->channel()),
threaded_data_receiver_(threaded_data_receiver),
@@ -186,7 +186,7 @@ void ThreadedDataProvider::Stop() {
// We should never end up with a different parser thread than from when the
// ThreadedDataProvider gets created.
DCHECK(current_background_thread ==
- static_cast<WebThreadImplForWorkerScheduler*>(&background_thread_));
+ static_cast<WebThreadImpl*>(&background_thread_));
background_thread_.TaskRunner()->PostTask(
FROM_HERE, base::Bind(&ThreadedDataProvider::StopOnBackgroundThread,
base::Unretained(this)));