Index: content/child/resource_scheduling_filter.cc |
diff --git a/content/child/resource_scheduling_filter.cc b/content/child/resource_scheduling_filter.cc |
index 6445c00a2b55b2545944b177ae7d380930679c58..843cd8713f4c58047c2a4699a9a88875d51e5acf 100644 |
--- a/content/child/resource_scheduling_filter.cc |
+++ b/content/child/resource_scheduling_filter.cc |
@@ -9,31 +9,8 @@ |
#include "content/child/resource_dispatcher.h" |
#include "ipc/ipc_message.h" |
#include "ipc/ipc_message_start.h" |
-#include "third_party/WebKit/public/platform/WebTaskRunner.h" |
-#include "third_party/WebKit/public/platform/WebTraceLocation.h" |
namespace content { |
- |
-namespace { |
-class DispatchMessageTask : public blink::WebTaskRunner::Task { |
- public: |
- DispatchMessageTask( |
- base::WeakPtr<ResourceSchedulingFilter> resource_scheduling_filter, |
- const IPC::Message& message) |
- : resource_scheduling_filter_(resource_scheduling_filter), |
- message_(message) {} |
- |
- void run() override { |
- if (!resource_scheduling_filter_.get()) |
- return; |
- resource_scheduling_filter_->DispatchMessage(message_); |
- } |
- |
- private: |
- base::WeakPtr<ResourceSchedulingFilter> resource_scheduling_filter_; |
- const IPC::Message message_; |
-}; |
-} // namespace |
ResourceSchedulingFilter::ResourceSchedulingFilter( |
const scoped_refptr<base::SingleThreadTaskRunner>& main_thread_task_runner, |
@@ -49,40 +26,10 @@ |
} |
bool ResourceSchedulingFilter::OnMessageReceived(const IPC::Message& message) { |
- base::AutoLock lock(request_id_to_task_runner_map_lock_); |
- int request_id; |
- |
- base::PickleIterator pickle_iterator(message); |
- if (!pickle_iterator.ReadInt(&request_id)) { |
- NOTREACHED() << "malformed resource message"; |
- return true; |
- } |
- // Dispatch the message on the request id specific task runner, if there is |
- // one, or on the general main_thread_task_runner if there isn't. |
- RequestIdToTaskRunnerMap::const_iterator iter = |
- request_id_to_task_runner_map_.find(request_id); |
- if (iter != request_id_to_task_runner_map_.end()) { |
- // TODO(alexclarke): Find a way to let blink and chromium FROM_HERE coexist. |
- iter->second->postTask( |
- blink::WebTraceLocation(__FUNCTION__, __FILE__), |
- new DispatchMessageTask(weak_ptr_factory_.GetWeakPtr(), message)); |
- } else { |
- main_thread_task_runner_->PostTask( |
- FROM_HERE, base::Bind(&ResourceSchedulingFilter::DispatchMessage, |
- weak_ptr_factory_.GetWeakPtr(), message)); |
- } |
+ main_thread_task_runner_->PostTask( |
+ FROM_HERE, base::Bind(&ResourceSchedulingFilter::DispatchMessage, |
+ weak_ptr_factory_.GetWeakPtr(), message)); |
return true; |
-} |
- |
-void ResourceSchedulingFilter::SetRequestIdTaskRunner( |
- int id, scoped_ptr<blink::WebTaskRunner> web_task_runner) { |
- base::AutoLock lock(request_id_to_task_runner_map_lock_); |
- request_id_to_task_runner_map_.insert(id, web_task_runner.Pass()); |
-} |
- |
-void ResourceSchedulingFilter::ClearRequestIdTaskRunner(int id) { |
- base::AutoLock lock(request_id_to_task_runner_map_lock_); |
- request_id_to_task_runner_map_.erase(id); |
} |
bool ResourceSchedulingFilter::GetSupportedMessageClasses( |