| Index: third_party/WebKit/Source/web/WebSharedWorkerImpl.cpp
|
| diff --git a/third_party/WebKit/Source/web/WebSharedWorkerImpl.cpp b/third_party/WebKit/Source/web/WebSharedWorkerImpl.cpp
|
| index 9f0e0963d6edaa02f0cde45b4c88bd069791d8ba..f3fb22692a7bcfc26132fde42c41c9c265ff827f 100644
|
| --- a/third_party/WebKit/Source/web/WebSharedWorkerImpl.cpp
|
| +++ b/third_party/WebKit/Source/web/WebSharedWorkerImpl.cpp
|
| @@ -46,6 +46,7 @@
|
| #include "core/workers/WorkerInspectorProxy.h"
|
| #include "core/workers/WorkerLoaderProxy.h"
|
| #include "core/workers/WorkerScriptLoader.h"
|
| +#include "core/workers/WorkerTaskRunners.h"
|
| #include "core/workers/WorkerThreadStartupData.h"
|
| #include "platform/CrossThreadFunctional.h"
|
| #include "platform/heap/Handle.h"
|
| @@ -254,7 +255,10 @@ void WebSharedWorkerImpl::PostTaskToWorkerGlobalScope(
|
| const WebTraceLocation& location,
|
| std::unique_ptr<WTF::CrossThreadClosure> task) {
|
| DCHECK(IsMainThread());
|
| - worker_thread_->PostTask(location, std::move(task));
|
| + GetWorkerThread()
|
| + ->GetWorkerTaskRunners()
|
| + ->Get(TaskType::kNetworking)
|
| + ->PostTask(location, std::move(task));
|
| }
|
|
|
| ThreadableLoadingContext* WebSharedWorkerImpl::GetThreadableLoadingContext() {
|
| @@ -268,11 +272,14 @@ ThreadableLoadingContext* WebSharedWorkerImpl::GetThreadableLoadingContext() {
|
| void WebSharedWorkerImpl::Connect(
|
| std::unique_ptr<WebMessagePortChannel> web_channel) {
|
| DCHECK(IsMainThread());
|
| - GetWorkerThread()->PostTask(
|
| - BLINK_FROM_HERE,
|
| - CrossThreadBind(&WebSharedWorkerImpl::ConnectTaskOnWorkerThread,
|
| - WTF::CrossThreadUnretained(this),
|
| - WTF::Passed(std::move(web_channel))));
|
| + GetWorkerThread()
|
| + ->GetWorkerTaskRunners()
|
| + ->Get(TaskType::kDOMManipulation)
|
| + ->PostTask(
|
| + BLINK_FROM_HERE,
|
| + CrossThreadBind(&WebSharedWorkerImpl::ConnectTaskOnWorkerThread,
|
| + WTF::CrossThreadUnretained(this),
|
| + WTF::Passed(std::move(web_channel))));
|
| }
|
|
|
| void WebSharedWorkerImpl::ConnectTaskOnWorkerThread(
|
|
|