Chromium Code Reviews| Index: content/browser/service_worker/embedded_worker_instance.cc |
| diff --git a/content/browser/service_worker/embedded_worker_instance.cc b/content/browser/service_worker/embedded_worker_instance.cc |
| index aa9b94f326f4df643ad5fd4c5dab77f60ae4098a..b2237b90afd8aa292d539d9b9301570a55ca05d4 100644 |
| --- a/content/browser/service_worker/embedded_worker_instance.cc |
| +++ b/content/browser/service_worker/embedded_worker_instance.cc |
| @@ -103,20 +103,6 @@ void SetupOnUI( |
| base::Bind(callback, worker_devtools_agent_route_id, wait_for_debugger)); |
| } |
| -void SetupEventDispatcherOnUIThread( |
| - int process_id, |
| - int thread_id, |
| - mojom::ServiceWorkerEventDispatcherRequest request) { |
| - DCHECK(!ServiceWorkerUtils::IsMojoForServiceWorkerEnabled()); |
| - RenderProcessHost* rph = RenderProcessHost::FromID(process_id); |
| - // |rph| or its InterfaceProvider may be NULL in unit tests. |
| - if (!rph || !rph->GetRemoteInterfaces()) |
| - return; |
| - mojom::EmbeddedWorkerSetupPtr setup; |
| - rph->GetRemoteInterfaces()->GetInterface(&setup); |
| - setup->AttachServiceWorkerEventDispatcher(thread_id, std::move(request)); |
| -} |
| - |
| void CallDetach(EmbeddedWorkerInstance* instance) { |
| // This could be called on the UI thread if |client_| still be valid when the |
| // message loop on the UI thread gets destructed. |
| @@ -401,35 +387,12 @@ class EmbeddedWorkerInstance::StartTask { |
| params->worker_devtools_agent_route_id = worker_devtools_agent_route_id; |
| params->wait_for_debugger = wait_for_debugger; |
| - if (ServiceWorkerUtils::IsMojoForServiceWorkerEnabled()) |
| - SendMojoStartWorker(std::move(params)); |
| - else |
| - SendStartWorker(std::move(params)); |
| + SendStartWorker(std::move(params)); |
|
falken
2017/01/16 05:07:45
Can we collapse SendStartWorker into this function
shimazu
2017/01/16 05:49:53
Done.
|
| } |
| void SendStartWorker(std::unique_ptr<EmbeddedWorkerStartParams> params) { |
| - DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| - ServiceWorkerStatusCode status = instance_->registry_->SendStartWorker( |
| - std::move(params), instance_->process_id()); |
| - TRACE_EVENT_ASYNC_STEP_PAST1( |
| - "ServiceWorker", "EmbeddedWorkerInstance::Start", this, |
| - "SendStartWorker", "Status", ServiceWorkerStatusToString(status)); |
| - if (status != SERVICE_WORKER_OK) { |
| - StatusCallback callback = start_callback_; |
| - start_callback_.Reset(); |
| - instance_->OnStartFailed(callback, status); |
| - // |this| may be destroyed. |
| - return; |
| - } |
| - instance_->OnStartWorkerMessageSent(); |
| - |
| - // |start_callback_| will be called via RunStartCallback() when the script |
| - // is evaluated. |
| - } |
| - |
| - void SendMojoStartWorker(std::unique_ptr<EmbeddedWorkerStartParams> params) { |
| ServiceWorkerStatusCode status = |
| - instance_->SendMojoStartWorker(std::move(params)); |
| + instance_->SendStartWorker(std::move(params)); |
| if (status != SERVICE_WORKER_OK) { |
| StatusCallback callback = start_callback_; |
| start_callback_.Reset(); |
| @@ -500,11 +463,9 @@ void EmbeddedWorkerInstance::Start( |
| params->settings.v8_cache_options = GetV8CacheOptions(); |
| mojom::EmbeddedWorkerInstanceClientRequest request; |
| - if (ServiceWorkerUtils::IsMojoForServiceWorkerEnabled()) { |
| - request = mojo::MakeRequest(&client_); |
| - client_.set_connection_error_handler( |
| - base::Bind(&CallDetach, base::Unretained(this))); |
| - } |
| + request = mojo::MakeRequest(&client_); |
|
falken
2017/01/16 05:07:45
Can we initialize request in line 465?
shimazu
2017/01/16 05:49:53
Yes, that's right. Done.
|
| + client_.set_connection_error_handler( |
| + base::Bind(&CallDetach, base::Unretained(this))); |
| pending_dispatcher_request_ = std::move(dispatcher_request); |
| @@ -635,7 +596,7 @@ void EmbeddedWorkerInstance::OnRegisteredToDevToolsManager( |
| observer.OnRegisteredToDevToolsManager(); |
| } |
| -ServiceWorkerStatusCode EmbeddedWorkerInstance::SendMojoStartWorker( |
| +ServiceWorkerStatusCode EmbeddedWorkerInstance::SendStartWorker( |
| std::unique_ptr<EmbeddedWorkerStartParams> params) { |
| if (!context_) |
| return SERVICE_WORKER_ERROR_ABORT; |
| @@ -743,16 +704,6 @@ void EmbeddedWorkerInstance::OnThreadStarted(int thread_id) { |
| thread_id_ = thread_id; |
| for (auto& observer : listener_list_) |
| observer.OnThreadStarted(); |
| - |
| - // The pending request is sent at StartWorker if mojo for the service worker |
| - // is enabled. |
| - if (!ServiceWorkerUtils::IsMojoForServiceWorkerEnabled()) { |
| - DCHECK(pending_dispatcher_request_.is_pending()); |
| - BrowserThread::PostTask( |
| - BrowserThread::UI, FROM_HERE, |
| - base::Bind(SetupEventDispatcherOnUIThread, process_id(), thread_id_, |
| - base::Passed(&pending_dispatcher_request_))); |
| - } |
| } |
| void EmbeddedWorkerInstance::OnScriptLoadFailed() { |