| Index: content/child/service_worker/service_worker_message_filter.h
|
| diff --git a/content/child/quota_message_filter.h b/content/child/service_worker/service_worker_message_filter.h
|
| similarity index 57%
|
| copy from content/child/quota_message_filter.h
|
| copy to content/child/service_worker/service_worker_message_filter.h
|
| index 5e90c6ccc83a1a61930010ea31d5a07e600d7d22..a994965b407364eb7bc0f637c7dfa7bbdfb2e550 100644
|
| --- a/content/child/quota_message_filter.h
|
| +++ b/content/child/service_worker/service_worker_message_filter.h
|
| @@ -1,51 +1,45 @@
|
| -// Copyright 2013 The Chromium Authors. All rights reserved.
|
| +// Copyright (c) 2012 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.
|
|
|
| -#ifndef CONTENT_CHILD_QUOTA_MESSAGE_FILTER_H_
|
| -#define CONTENT_CHILD_QUOTA_MESSAGE_FILTER_H_
|
| +#ifndef CONTENT_CHILD_SERVICE_WORKER_SERVICE_WORKER_MESSAGE_FILTER_H_
|
| +#define CONTENT_CHILD_SERVICE_WORKER_SERVICE_WORKER_MESSAGE_FILTER_H_
|
|
|
| #include <map>
|
|
|
| -#include "base/synchronization/lock.h"
|
| #include "ipc/ipc_channel_proxy.h"
|
|
|
| -namespace base {
|
| -class MessageLoopProxy;
|
| -}
|
| -
|
| namespace content {
|
| -
|
| class ThreadSafeSender;
|
| +class MessageLoopProxy;
|
|
|
| -class QuotaMessageFilter : public IPC::ChannelProxy::MessageFilter {
|
| +class ServiceWorkerMessageFilter : public IPC::ChannelProxy::MessageFilter {
|
| public:
|
| - explicit QuotaMessageFilter(ThreadSafeSender* thread_safe_sender);
|
| + explicit ServiceWorkerMessageFilter(ThreadSafeSender* thread_safe_sender);
|
|
|
| - // IPC::Listener implementation.
|
| + // IPC::Listener implementation
|
| virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE;
|
|
|
| // Registers { request_id, thread_id } map to the message filter.
|
| // This method can be called on any thread.
|
| void RegisterRequestID(int request_id, int thread_id);
|
| + void ClearThreadRequests(int thread_id);
|
|
|
| protected:
|
| - virtual ~QuotaMessageFilter();
|
| + virtual ~ServiceWorkerMessageFilter();
|
|
|
| private:
|
| typedef std::map<int, int> RequestIdToThreadId;
|
| + base::Lock request_id_map_lock_;
|
| + RequestIdToThreadId request_id_map_;
|
|
|
| void DispatchMessage(const IPC::Message& msg);
|
| -
|
| scoped_refptr<base::MessageLoopProxy> main_thread_loop_proxy_;
|
| scoped_refptr<ThreadSafeSender> thread_safe_sender_;
|
|
|
| - base::Lock request_id_map_lock_;
|
| - RequestIdToThreadId request_id_map_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(QuotaMessageFilter);
|
| + DISALLOW_COPY_AND_ASSIGN(ServiceWorkerMessageFilter);
|
| };
|
|
|
| } // namespace content
|
|
|
| -#endif // CONTENT_CHILD_QUOTA_MESSAGE_FILTER_H_
|
| +#endif // CONTENT_CHILD_SERVICE_WORKER_SERVICE_WORKER_MESSAGE_FILTER_H_
|
|
|