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 1ffdd7760c1d2a547ceead5283fd4065d120dbf9..eaa8b465ce62cb93148775ba56114e2c35c6c3f3 100644 |
--- a/content/browser/service_worker/embedded_worker_instance.cc |
+++ b/content/browser/service_worker/embedded_worker_instance.cc |
@@ -44,11 +44,13 @@ ServiceWorkerStatusCode EmbeddedWorkerInstance::Stop() { |
} |
ServiceWorkerStatusCode EmbeddedWorkerInstance::SendMessage( |
+ int request_id, |
const IPC::Message& message) { |
DCHECK(status_ == RUNNING); |
return registry_->Send(process_id_, |
new EmbeddedWorkerContextMsg_SendMessageToWorker( |
- thread_id_, embedded_worker_id_, message)); |
+ thread_id_, embedded_worker_id_, |
+ request_id, message)); |
} |
void EmbeddedWorkerInstance::AddProcessReference(int process_id) { |
@@ -95,8 +97,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::OnMessageReceived(int request_id, |
+ const IPC::Message& message) { |
+ FOR_EACH_OBSERVER(Observer, observer_list_, |
+ OnMessageReceived(request_id, message)); |
} |
void EmbeddedWorkerInstance::AddObserver(Observer* observer) { |