[DONT COMMIT] WIP: WorkerClientsInitializer

third_party/WebKit/Source/core/exported/WebSharedWorkerImpl.cpp

 /*
  * Copyright (C) 2009 Google Inc. All rights reserved.
  *
  * Redistribution and use in source and binary forms, with or without
  * modification, are permitted provided that the following conditions are
  * met:
  *
  *     * Redistributions of source code must retain the above copyright
  * notice, this list of conditions and the following disclaimer.
  *     * Redistributions in binary form must reproduce the above
@@ skipping 29 matching lines @@
 #include "core/frame/WebLocalFrameBase.h"
 #include "core/inspector/ConsoleMessage.h"
 #include "core/loader/FrameLoadRequest.h"
 #include "core/loader/FrameLoader.h"
 #include "core/loader/ThreadableLoadingContext.h"
 #include "core/loader/WorkerFetchContext.h"
 #include "core/probe/CoreProbes.h"
 #include "core/workers/ParentFrameTaskRunners.h"
 #include "core/workers/SharedWorkerGlobalScope.h"
 #include "core/workers/SharedWorkerThread.h"
-#include "core/workers/WorkerClients.h"
 #include "core/workers/WorkerContentSettingsClient.h"
 #include "core/workers/WorkerGlobalScope.h"
 #include "core/workers/WorkerInspectorProxy.h"
 #include "core/workers/WorkerScriptLoader.h"
 #include "core/workers/WorkerThreadStartupData.h"
 #include "platform/CrossThreadFunctional.h"
 #include "platform/RuntimeEnabledFeatures.h"
 #include "platform/heap/Handle.h"
 #include "platform/heap/Persistent.h"
 #include "platform/loader/fetch/ResourceResponse.h"
@@ skipping 10 matching lines @@
 #include "public/platform/WebURLRequest.h"
 #include "public/platform/WebWorkerFetchContext.h"
 #include "public/platform/modules/serviceworker/WebServiceWorkerNetworkProvider.h"
 #include "public/web/WebDevToolsAgent.h"
 #include "public/web/WebFrame.h"
 #include "public/web/WebSettings.h"
 #include "public/web/WebView.h"
 
 namespace blink {
 
-namespace {
-
-// Vector of callbacks for the OnScriptLoaderFinished method.
-using WorkerClientsCreatedCallbackVector =
-    WTF::Vector<WebSharedWorkerImpl::WorkerClientsCreatedCallback>;
-WorkerClientsCreatedCallbackVector& GetWorkerClientsCreatedCallbackVector() {
-  DEFINE_STATIC_LOCAL(WorkerClientsCreatedCallbackVector, callback_vector, ());
-  return callback_vector;
-}
-
-}  // namespace
-
 // TODO(toyoshim): Share implementation with WebEmbeddedWorkerImpl as much as
 // possible.
 
+template class CORE_TEMPLATE_EXPORT
+    WorkerClientsInitializer<WebSharedWorkerImpl>;
+
 WebSharedWorkerImpl::WebSharedWorkerImpl(WebSharedWorkerClient* client)
     : web_view_(nullptr),
       main_frame_(nullptr),
       asked_to_terminate_(false),
       worker_inspector_proxy_(WorkerInspectorProxy::Create()),
       client_(client),
       pause_worker_context_on_start_(false),
       is_paused_on_start_(false),
       creation_address_space_(kWebAddressSpacePublic) {
   DCHECK(IsMainThread());
@@ skipping 150 matching lines @@
   TerminateWorkerThread();
 }
 
 void WebSharedWorkerImpl::DidTerminateWorkerThread() {
   DCHECK(IsMainThread());
   client_->WorkerContextDestroyed();
   // The lifetime of this proxy is controlled by the worker context.
   delete this;
 }
 
-void WebSharedWorkerImpl::RegisterWorkerClientsCreatedCallback(
-    WorkerClientsCreatedCallback callback) {
-  GetWorkerClientsCreatedCallbackVector().push_back(callback);
-}
-
 void WebSharedWorkerImpl::Connect(
     std::unique_ptr<WebMessagePortChannel> web_channel) {
   DCHECK(IsMainThread());
   // The HTML spec requires to queue a connect event using the DOM manipulation
   // task source.
   // https://html.spec.whatwg.org/multipage/workers.html#shared-workers-and-the-sharedworker-interface
   TaskRunnerHelper::Get(TaskType::kDOMManipulation, GetWorkerThread())
       ->PostTask(
           BLINK_FROM_HERE,
           CrossThreadBind(&WebSharedWorkerImpl::ConnectTaskOnWorkerThread,
@@ skipping 50 matching lines @@
     delete this;
     return;
   }
 
   // FIXME: this document's origin is pristine and without any extra privileges
   // (e.g. GrantUniversalAccess) that can be overriden in regular documents
   // via WebPreference by embedders. (crbug.com/254993)
   SecurityOrigin* starter_origin = loading_document_->GetSecurityOrigin();
 
   WorkerClients* worker_clients = WorkerClients::Create();
-  DCHECK(!GetWorkerClientsCreatedCallbackVector().IsEmpty());
-  for (auto& callback : GetWorkerClientsCreatedCallbackVector()) {
-    callback(worker_clients);
-  }
+  WorkerClientsInitializer<WebSharedWorkerImpl>::Run(worker_clients);
 
   WebSecurityOrigin web_security_origin(loading_document_->GetSecurityOrigin());
   ProvideContentSettingsClientToWorker(
       worker_clients,
       client_->CreateWorkerContentSettingsClient(web_security_origin));
 
   if (RuntimeEnabledFeatures::OffMainThreadFetchEnabled()) {
     std::unique_ptr<WebWorkerFetchContext> web_worker_fetch_context =
         client_->CreateWorkerFetchContext(
             WebLocalFrameBase::FromFrame(main_frame_->GetFrame())
@@ skipping 94 matching lines @@
     devtools_agent->DispatchOnInspectorBackend(session_id, call_id, method,
                                                message);
   }
 }
 
 WebSharedWorker* WebSharedWorker::Create(WebSharedWorkerClient* client) {
   return new WebSharedWorkerImpl(client);
 }
 
 }  // namespace blink