Index: content/child/threaded_data_provider.cc |
diff --git a/content/child/threaded_data_provider.cc b/content/child/threaded_data_provider.cc |
index 395e45227cf903cc4abdf102409a65863d97ea9e..64daeebb8e3f8f3bf793450d3081642f9aecf429 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 @@ |
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 @@ |
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 @@ |
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 @@ |
: 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 @@ |
// 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))); |