ServiceWorker: Enqueue state change events until the worker thread gets ready

content/browser/service_worker/service_worker_provider_host.h

Index: content/browser/service_worker/service_worker_provider_host.h
diff --git a/content/browser/service_worker/service_worker_provider_host.h b/content/browser/service_worker/service_worker_provider_host.h
index 03cb0c638d04a2e688e2a9d0843d0bac1efd9da2..99898a9e064c6746fd9739cf0f968030efc379a7 100644
--- a/content/browser/service_worker/service_worker_provider_host.h
+++ b/content/browser/service_worker/service_worker_provider_host.h
@@ -47,6 +47,8 @@ class CONTENT_EXPORT ServiceWorkerProviderHost
  public:
   typedef base::Callback<void(bool)> FocusCallback;
 
+  // If |render_frame_id| is MSG_ROUTING_NONE, this provider host works for the
+  // worker context.
   ServiceWorkerProviderHost(int render_process_id,
                             int render_frame_id,
                             int provider_id,
@@ -161,7 +163,8 @@ class CONTENT_EXPORT ServiceWorkerProviderHost
     return dispatcher_host_;
   }
 
-  // Called from ServiceWorkerRegistrationHandle.
+  // Sends event messages to the renderer. Events for the worker are queued up
+  // until the worker thread id is known via SetReadyToSendMessagesToWorker().
   void SendUpdateFoundMessage(
       const ServiceWorkerRegistrationObjectInfo& object_info);
   void SendSetVersionAttributesMessage(
@@ -170,12 +173,13 @@ class CONTENT_EXPORT ServiceWorkerProviderHost
       ServiceWorkerVersion* installing_version,
       ServiceWorkerVersion* waiting_version,
       ServiceWorkerVersion* active_version);
-
-  // Called from ServiceWorkerHandle.
   void SendServiceWorkerStateChangedMessage(
       int worker_handle_id,
       blink::WebServiceWorkerState state);
 
+  // Sets the worker thread id and flushes queued events.
+  void SetReadyToSendMessagesToWorker(int render_thread_id);
+
  private:
   friend class ServiceWorkerProviderHostTest;
   friend class ServiceWorkerWriteToCacheJobTest;
@@ -198,8 +202,12 @@ class CONTENT_EXPORT ServiceWorkerProviderHost
   void IncreaseProcessReference(const GURL& pattern);
   void DecreaseProcessReference(const GURL& pattern);
 
+  bool IsReadyToSendMessages() const;
+  void Send(IPC::Message* message) const;
+
   int render_process_id_;
   int render_frame_id_;
+  int render_thread_id_;
   int provider_id_;
   GURL document_url_;
   GURL topmost_frame_url_;
@@ -213,6 +221,8 @@ class CONTENT_EXPORT ServiceWorkerProviderHost
   ServiceWorkerDispatcherHost* dispatcher_host_;
   bool allow_association_;
 
+  std::vector<base::Closure> queued_events_;
+
   DISALLOW_COPY_AND_ASSIGN(ServiceWorkerProviderHost);
 };