Browser side of new ServiceWorker 'sync' event.

content/browser/service_worker/service_worker_version.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/service_worker/service_worker_version.h"
 
 #include "base/stl_util.h"
 #include "content/browser/service_worker/embedded_worker_instance.h"
 #include "content/browser/service_worker/embedded_worker_registry.h"
 #include "content/browser/service_worker/service_worker_context_core.h"
@@ skipping 128 matching lines @@
                  SERVICE_WORKER_FETCH_EVENT_RESULT_FALLBACK,
                  ServiceWorkerResponse());
     return;
   }
   ServiceWorkerFetchEventResult result;
   ServiceWorkerResponse response;
   ServiceWorkerHostMsg_FetchEventFinished::Read(&message, &result, &response);
   callback.Run(SERVICE_WORKER_OK, result, response);
 }
 
+void HandleSyncEventFinished(const StatusCallback& callback,
+                             ServiceWorkerStatusCode status,
+                             const IPC::Message& message) {
+  if (message.type() != ServiceWorkerHostMsg_SyncEventFinished::ID) {
+    NOTREACHED() << "Got unexpected response for SyncEvent: " << message.type();
+    callback.Run(SERVICE_WORKER_ERROR_FAILED);
+    return;
+  }
+  callback.Run(status);
+}
+
 }  // namespace
 
 ServiceWorkerVersion::ServiceWorkerVersion(
     ServiceWorkerRegistration* registration,
     EmbeddedWorkerRegistry* worker_registry,
     int64 version_id)
     : version_id_(version_id),
       status_(NEW),
       is_shutdown_(false),
       registration_(registration),
@@ skipping 165 matching lines @@
 
 void ServiceWorkerVersion::DispatchFetchEvent(
     const ServiceWorkerFetchRequest& request,
     const FetchCallback& callback) {
   DCHECK_EQ(ACTIVE, status()) << status();
   SendMessageAndRegisterCallback(
       ServiceWorkerMsg_FetchEvent(request),
       base::Bind(&HandleFetchResponse, callback));
 }
 
+void ServiceWorkerVersion::DispatchSyncEvent(const StatusCallback& callback) {
+  DCHECK_EQ(ACTIVE, status()) << status();
+  SendMessageAndRegisterCallback(
+      ServiceWorkerMsg_SyncEvent(),
+      base::Bind(&HandleSyncEventFinished, callback));
+}
+
 void ServiceWorkerVersion::AddProcessToWorker(int process_id) {
   DCHECK(!is_shutdown_);
   embedded_worker_->AddProcessReference(process_id);
 }
 
 void ServiceWorkerVersion::RemoveProcessToWorker(int process_id) {
   // We may have been shutdown.
   if (embedded_worker_)
     embedded_worker_->ReleaseProcessReference(process_id);
 }
@@ skipping 29 matching lines @@
   if (callback) {
     callback->Run(SERVICE_WORKER_OK, message);
     message_callbacks_.Remove(request_id);
     return;
   }
   NOTREACHED() << "Got unexpected message: " << request_id
                << " " << message.type();
 }
 
 }  // namespace content