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 592f88b3095469d69db598ee3e20809836c127b5..8856044a7973394c2cf7059e76eea7f58af59aea 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; |
@@ -547,4 +550,17 @@ void ServiceWorkerVersion::OnSyncEventFinished( |
sync_callbacks_.Remove(request_id); |
} |
+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 |