Index: content/browser/service_worker/embedded_worker_instance.cc |
diff --git a/content/browser/service_worker/embedded_worker_instance.cc b/content/browser/service_worker/embedded_worker_instance.cc |
index a376562913c51b7794f2be651eafa1826f256004..7cfd5cbbac994c693026549af6e21e7730739e33 100644 |
--- a/content/browser/service_worker/embedded_worker_instance.cc |
+++ b/content/browser/service_worker/embedded_worker_instance.cc |
@@ -6,6 +6,7 @@ |
#include "content/browser/service_worker/embedded_worker_registry.h" |
#include "content/common/service_worker/embedded_worker_messages.h" |
+#include "ipc/ipc_message.h" |
#include "url/gurl.h" |
namespace content { |
@@ -41,14 +42,11 @@ bool EmbeddedWorkerInstance::Stop() { |
return success; |
} |
-bool EmbeddedWorkerInstance::SendFetchRequest( |
- const ServiceWorkerFetchRequest& request) { |
+bool EmbeddedWorkerInstance::SendMessage(const IPC::Message& message) { |
DCHECK(status_ == RUNNING); |
- // TODO: Refine this code, the code around FetchEvent is currently very |
- // rough, mainly just for a placeholder for now. |
return registry_->Send(process_id_, |
- new EmbeddedWorkerContextMsg_FetchEvent( |
- thread_id_, embedded_worker_id_, request)); |
+ new EmbeddedWorkerContextMsg_SendMessageToWorker( |
+ thread_id_, embedded_worker_id_, message)); |
} |
void EmbeddedWorkerInstance::AddProcessReference(int process_id) { |
@@ -95,6 +93,10 @@ void EmbeddedWorkerInstance::OnStopped() { |
FOR_EACH_OBSERVER(Observer, observer_list_, OnStopped()); |
} |
+void EmbeddedWorkerInstance::OnMessageReceived(const IPC::Message& message) { |
+ FOR_EACH_OBSERVER(Observer, observer_list_, OnMessageReceived(message)); |
+} |
+ |
void EmbeddedWorkerInstance::AddObserver(Observer* observer) { |
observer_list_.AddObserver(observer); |
} |