Index: extensions/browser/extension_service_worker_message_filter.cc |
diff --git a/extensions/browser/extension_service_worker_message_filter.cc b/extensions/browser/extension_service_worker_message_filter.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..cde978d689634e7ad46e57a412a214d9a77165df |
--- /dev/null |
+++ b/extensions/browser/extension_service_worker_message_filter.cc |
@@ -0,0 +1,48 @@ |
+// Copyright 2016 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 "extensions/browser/extension_service_worker_message_filter.h" |
+ |
+#include "extensions/browser/extension_function_dispatcher.h" |
+#include "extensions/common/extension_messages.h" |
+ |
+namespace extensions { |
+ |
+ExtensionServiceWorkerMessageFilter::ExtensionServiceWorkerMessageFilter( |
+ int render_process_id, |
+ content::BrowserContext* context) |
+ : content::BrowserMessageFilter(ExtensionWorkerMsgStart), |
+ render_process_id_(render_process_id), |
+ browser_context_(context), |
+ dispatcher_(new ExtensionFunctionDispatcher(context)) {} |
+ |
+ExtensionServiceWorkerMessageFilter::~ExtensionServiceWorkerMessageFilter() { |
+ DCHECK_CURRENTLY_ON(content::BrowserThread::IO); |
+} |
+ |
+void ExtensionServiceWorkerMessageFilter::OverrideThreadForMessage( |
+ const IPC::Message& message, |
+ content::BrowserThread::ID* thread) { |
+ if (message.type() == ExtensionHostMsg_RequestWorker::ID) { |
+ *thread = content::BrowserThread::UI; |
+ } |
+} |
+ |
+bool ExtensionServiceWorkerMessageFilter::OnMessageReceived( |
+ const IPC::Message& message) { |
+ bool handled = true; |
+ IPC_BEGIN_MESSAGE_MAP(ExtensionServiceWorkerMessageFilter, message) |
+ IPC_MESSAGE_HANDLER(ExtensionHostMsg_RequestWorker, OnRequestWorker) |
+ IPC_MESSAGE_UNHANDLED(handled = false) |
+ IPC_END_MESSAGE_MAP() |
+ return handled; |
+} |
+ |
+void ExtensionServiceWorkerMessageFilter::OnRequestWorker( |
+ const ExtensionHostMsg_Request_Params& params) { |
+ DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
Devlin
2016/04/13 19:46:31
DCHECK_CURRENTLY_ON?
lazyboy
2016/04/14 02:07:52
Done.
|
+ dispatcher_->Dispatch(params, nullptr, render_process_id_); |
+} |
+ |
+} // namespace extensions |