Index: content/browser/service_worker/service_worker_version.cc |
diff --git a/content/browser/service_worker/service_worker_version.cc b/content/browser/service_worker/service_worker_version.cc |
index 77e01c1a470d7b9719000a9c2f73284d7ec5a4e6..66ca8830756abe28ea8e8b848c9ece3a822a8e9d 100644 |
--- a/content/browser/service_worker/service_worker_version.cc |
+++ b/content/browser/service_worker/service_worker_version.cc |
@@ -6,6 +6,7 @@ |
#include "base/command_line.h" |
#include "base/stl_util.h" |
+#include "base/strings/string16.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" |
@@ -429,6 +430,8 @@ bool ServiceWorkerVersion::OnMessageReceived(const IPC::Message& message) { |
OnFetchEventFinished) |
IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_SyncEventFinished, |
OnSyncEventFinished) |
+ IPC_MESSAGE_HANDLER(ServiceWorkerHostMsg_PostMessageToDocument, |
+ OnPostMessageToDocument) |
IPC_MESSAGE_UNHANDLED(handled = false) |
IPC_END_MESSAGE_MAP() |
return handled; |
@@ -561,4 +564,17 @@ int64 ServiceWorkerVersion::LookupInScriptCache(const GURL& url) { |
return found->second; |
} |
+void ServiceWorkerVersion::OnPostMessageToDocument( |
+ int client_id, |
+ const base::string16& message, |
+ const std::vector<int>& sent_message_port_ids) { |
+ ServiceWorkerProviderHost* provider_host = |
+ controllee_by_id_.Lookup(client_id); |
+ if (!provider_host) { |
+ // The client may already have been closed, just ignore. |
+ return; |
+ } |
+ provider_host->PostMessage(message, sent_message_port_ids); |
+} |
+ |
} // namespace content |