Index: content/child/threaded_data_provider.cc |
diff --git a/content/child/threaded_data_provider.cc b/content/child/threaded_data_provider.cc |
index ccfe8918cc4037161e020bd3f7fc1b1a1e03d3cd..69ed34b0795dc5854cf9295621ebd0759c0cc826 100644 |
--- a/content/child/threaded_data_provider.cc |
+++ b/content/child/threaded_data_provider.cc |
@@ -5,7 +5,7 @@ |
#include "content/child/threaded_data_provider.h" |
#include "content/child/child_process.h" |
-#include "content/child/child_thread.h" |
+#include "content/child/child_thread_impl.h" |
#include "content/child/resource_dispatcher.h" |
#include "content/child/thread_safe_sender.h" |
#include "content/child/webthread_impl.h" |
@@ -127,12 +127,12 @@ ThreadedDataProvider::ThreadedDataProvider( |
shm_size_(shm_size), |
background_thread_(static_cast<WebThreadImpl&>( |
*threaded_data_receiver->backgroundThread())), |
- ipc_channel_(ChildThread::current()->channel()), |
+ ipc_channel_(ChildThreadImpl::current()->channel()), |
threaded_data_receiver_(threaded_data_receiver), |
resource_filter_active_(false), |
main_thread_task_runner_(main_thread_task_runner), |
main_thread_weak_factory_(this) { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
DCHECK(ipc_channel_); |
DCHECK(threaded_data_receiver_); |
DCHECK(main_thread_task_runner_.get()); |
@@ -146,19 +146,19 @@ ThreadedDataProvider::ThreadedDataProvider( |
background_thread_weak_factory_->GetWeakPtr(), |
main_thread_weak_factory_.GetWeakPtr(), request_id); |
- ChildThread::current()->channel()->AddFilter(filter_.get()); |
+ ChildThreadImpl::current()->channel()->AddFilter(filter_.get()); |
} |
ThreadedDataProvider::~ThreadedDataProvider() { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
- ChildThread::current()->channel()->RemoveFilter(filter_.get()); |
+ ChildThreadImpl::current()->channel()->RemoveFilter(filter_.get()); |
delete threaded_data_receiver_; |
} |
void DestructOnMainThread(ThreadedDataProvider* data_provider) { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
// The ThreadedDataProvider must be destructed on the main thread to |
// be threadsafe when removing the message filter and releasing the shared |
@@ -167,7 +167,7 @@ void DestructOnMainThread(ThreadedDataProvider* data_provider) { |
} |
void ThreadedDataProvider::Stop() { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
// Make sure we don't get called by on the main thread anymore via weak |
// pointers we've passed to the filter. |
@@ -207,7 +207,7 @@ void ThreadedDataProvider::StopOnBackgroundThread() { |
} |
void ThreadedDataProvider::OnResourceMessageFilterAddedMainThread() { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
DCHECK(background_thread_weak_factory_); |
// We bounce this message from the I/O thread via the main thread and then |
@@ -264,7 +264,7 @@ void ThreadedDataProvider::OnReceivedDataOnBackgroundThread( |
void ThreadedDataProvider::OnReceivedDataOnForegroundThread( |
const char* data, int data_length, int encoded_data_length) { |
- DCHECK(ChildThread::current()); |
+ DCHECK(ChildThreadImpl::current()); |
background_thread_.message_loop()->PostTask(FROM_HERE, |
base::Bind(&ThreadedDataProvider::ForwardAndACKData, |