Index: content/renderer/service_worker/cache_storage_message_filter.cc |
diff --git a/content/renderer/service_worker/cache_storage_message_filter.cc b/content/renderer/service_worker/cache_storage_message_filter.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..561854fa12bd1ceb22828b7945851ef1f7df7549 |
--- /dev/null |
+++ b/content/renderer/service_worker/cache_storage_message_filter.cc |
@@ -0,0 +1,38 @@ |
+// Copyright 2015 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 "content/renderer/service_worker/cache_storage_message_filter.h" |
+ |
+#include "content/child/thread_safe_sender.h" |
+#include "content/common/service_worker/cache_storage_messages.h" |
+#include "content/renderer/service_worker/service_worker_cache_storage_dispatcher.h" |
+ |
+namespace content { |
+ |
+CacheStorageMessageFilter::CacheStorageMessageFilter( |
+ ThreadSafeSender* thread_safe_sender) |
+ : WorkerThreadMessageFilter(thread_safe_sender) { |
+} |
+ |
+CacheStorageMessageFilter::~CacheStorageMessageFilter() { |
+} |
+ |
+bool CacheStorageMessageFilter::ShouldHandleMessage( |
+ const IPC::Message& msg) const { |
+ return IPC_MESSAGE_CLASS(msg) == CacheStorageMsgStart; |
+} |
+ |
+void CacheStorageMessageFilter::OnFilteredMessageReceived( |
+ const IPC::Message& msg) { |
+ ServiceWorkerCacheStorageDispatcher::ThreadSpecificInstance( |
+ thread_safe_sender())->OnMessageReceived(msg); |
+} |
+ |
+bool CacheStorageMessageFilter::GetWorkerThreadIdForMessage( |
+ const IPC::Message& msg, |
+ int* ipc_thread_id) { |
+ return PickleIterator(msg).ReadInt(ipc_thread_id); |
+} |
+ |
+} // namespace content |