OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ |
6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ |
7 | 7 |
8 #include <vector> | 8 #include <vector> |
9 | 9 |
10 #include "base/id_map.h" | 10 #include "base/id_map.h" |
11 #include "base/memory/weak_ptr.h" | 11 #include "base/memory/weak_ptr.h" |
12 #include "base/strings/string16.h" | 12 #include "base/strings/string16.h" |
13 #include "content/browser/service_worker/service_worker_registration_status.h" | 13 #include "content/browser/service_worker/service_worker_registration_status.h" |
14 #include "content/public/browser/browser_message_filter.h" | 14 #include "content/public/browser/browser_message_filter.h" |
15 | 15 |
16 class GURL; | 16 class GURL; |
17 struct EmbeddedWorkerHostMsg_ReportConsoleMessage_Params; | 17 struct EmbeddedWorkerHostMsg_ReportConsoleMessage_Params; |
18 | 18 |
19 namespace content { | 19 namespace content { |
20 | 20 |
21 class MessagePortMessageFilter; | 21 class MessagePortMessageFilter; |
22 class ServiceWorkerContextCore; | 22 class ServiceWorkerContextCore; |
23 class ServiceWorkerContextWrapper; | 23 class ServiceWorkerContextWrapper; |
24 class ServiceWorkerHandle; | 24 class ServiceWorkerHandle; |
25 class ServiceWorkerProviderHost; | 25 class ServiceWorkerProviderHost; |
26 class ServiceWorkerRegistration; | 26 class ServiceWorkerRegistration; |
| 27 class ServiceWorkerRegistrationHandle; |
27 | 28 |
28 class CONTENT_EXPORT ServiceWorkerDispatcherHost : public BrowserMessageFilter { | 29 class CONTENT_EXPORT ServiceWorkerDispatcherHost : public BrowserMessageFilter { |
29 public: | 30 public: |
30 ServiceWorkerDispatcherHost( | 31 ServiceWorkerDispatcherHost( |
31 int render_process_id, | 32 int render_process_id, |
32 MessagePortMessageFilter* message_port_message_filter); | 33 MessagePortMessageFilter* message_port_message_filter); |
33 | 34 |
34 void Init(ServiceWorkerContextWrapper* context_wrapper); | 35 void Init(ServiceWorkerContextWrapper* context_wrapper); |
35 | 36 |
36 // BrowserMessageFilter implementation | 37 // BrowserMessageFilter implementation |
37 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE; | 38 virtual void OnFilterAdded(IPC::Sender* sender) OVERRIDE; |
38 virtual void OnDestruct() const OVERRIDE; | 39 virtual void OnDestruct() const OVERRIDE; |
39 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; | 40 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; |
40 | 41 |
41 // IPC::Sender implementation | 42 // IPC::Sender implementation |
42 | 43 |
43 // Send() queues the message until the underlying sender is ready. This | 44 // Send() queues the message until the underlying sender is ready. This |
44 // class assumes that Send() can only fail after that when the renderer | 45 // class assumes that Send() can only fail after that when the renderer |
45 // process has terminated, at which point the whole instance will eventually | 46 // process has terminated, at which point the whole instance will eventually |
46 // be destroyed. | 47 // be destroyed. |
47 virtual bool Send(IPC::Message* message) OVERRIDE; | 48 virtual bool Send(IPC::Message* message) OVERRIDE; |
48 | 49 |
49 void RegisterServiceWorkerHandle(scoped_ptr<ServiceWorkerHandle> handle); | 50 void RegisterServiceWorkerHandle(scoped_ptr<ServiceWorkerHandle> handle); |
| 51 void RegisterServiceWorkerRegistrationHandle( |
| 52 scoped_ptr<ServiceWorkerRegistrationHandle> handle); |
50 | 53 |
51 MessagePortMessageFilter* message_port_message_filter() { | 54 MessagePortMessageFilter* message_port_message_filter() { |
52 return message_port_message_filter_; | 55 return message_port_message_filter_; |
53 } | 56 } |
54 | 57 |
55 protected: | 58 protected: |
56 virtual ~ServiceWorkerDispatcherHost(); | 59 virtual ~ServiceWorkerDispatcherHost(); |
57 | 60 |
58 private: | 61 private: |
59 friend class BrowserThread; | 62 friend class BrowserThread; |
(...skipping 25 matching lines...) Expand all Loading... |
85 int column_number, | 88 int column_number, |
86 const GURL& source_url); | 89 const GURL& source_url); |
87 void OnReportConsoleMessage( | 90 void OnReportConsoleMessage( |
88 int embedded_worker_id, | 91 int embedded_worker_id, |
89 const EmbeddedWorkerHostMsg_ReportConsoleMessage_Params& params); | 92 const EmbeddedWorkerHostMsg_ReportConsoleMessage_Params& params); |
90 void OnPostMessage(int handle_id, | 93 void OnPostMessage(int handle_id, |
91 const base::string16& message, | 94 const base::string16& message, |
92 const std::vector<int>& sent_message_port_ids); | 95 const std::vector<int>& sent_message_port_ids); |
93 void OnIncrementServiceWorkerRefCount(int handle_id); | 96 void OnIncrementServiceWorkerRefCount(int handle_id); |
94 void OnDecrementServiceWorkerRefCount(int handle_id); | 97 void OnDecrementServiceWorkerRefCount(int handle_id); |
| 98 void OnIncrementRegistrationRefCount(int registration_handle_id); |
| 99 void OnDecrementRegistrationRefCount(int registration_handle_id); |
95 void OnPostMessageToWorker(int handle_id, | 100 void OnPostMessageToWorker(int handle_id, |
96 const base::string16& message, | 101 const base::string16& message, |
97 const std::vector<int>& sent_message_port_ids); | 102 const std::vector<int>& sent_message_port_ids); |
98 void OnServiceWorkerObjectDestroyed(int handle_id); | 103 void OnServiceWorkerObjectDestroyed(int handle_id); |
99 | 104 |
100 ServiceWorkerHandle* FindHandle(int provider_id, int64 version_id); | 105 ServiceWorkerHandle* FindHandle( |
| 106 int provider_id, |
| 107 int64 version_id); |
| 108 ServiceWorkerRegistrationHandle* FindRegistrationHandle( |
| 109 int provider_id, |
| 110 int64 registration_id); |
101 | 111 |
102 // Callbacks from ServiceWorkerContextCore | 112 // Callbacks from ServiceWorkerContextCore |
103 void RegistrationComplete(int thread_id, | 113 void RegistrationComplete(int thread_id, |
104 int provider_id, | 114 int provider_id, |
105 int request_id, | 115 int request_id, |
106 ServiceWorkerStatusCode status, | 116 ServiceWorkerStatusCode status, |
107 int64 registration_id, | 117 int64 registration_id, |
108 int64 version_id); | 118 int64 version_id); |
109 | 119 |
110 void UnregistrationComplete(int thread_id, | 120 void UnregistrationComplete(int thread_id, |
111 int request_id, | 121 int request_id, |
112 ServiceWorkerStatusCode status); | 122 ServiceWorkerStatusCode status); |
113 | 123 |
114 void SendRegistrationError(int thread_id, | 124 void SendRegistrationError(int thread_id, |
115 int request_id, | 125 int request_id, |
116 ServiceWorkerStatusCode status); | 126 ServiceWorkerStatusCode status); |
117 | 127 |
118 ServiceWorkerContextCore* GetContext(); | 128 ServiceWorkerContextCore* GetContext(); |
119 | 129 |
120 int render_process_id_; | 130 int render_process_id_; |
121 MessagePortMessageFilter* const message_port_message_filter_; | 131 MessagePortMessageFilter* const message_port_message_filter_; |
122 scoped_refptr<ServiceWorkerContextWrapper> context_wrapper_; | 132 scoped_refptr<ServiceWorkerContextWrapper> context_wrapper_; |
123 | 133 |
124 IDMap<ServiceWorkerHandle, IDMapOwnPointer> handles_; | 134 IDMap<ServiceWorkerHandle, IDMapOwnPointer> handles_; |
| 135 IDMap<ServiceWorkerRegistrationHandle, IDMapOwnPointer> registration_handles_; |
125 | 136 |
126 bool channel_ready_; // True after BrowserMessageFilter::sender_ != NULL. | 137 bool channel_ready_; // True after BrowserMessageFilter::sender_ != NULL. |
127 ScopedVector<IPC::Message> pending_messages_; | 138 ScopedVector<IPC::Message> pending_messages_; |
128 | 139 |
129 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerDispatcherHost); | 140 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerDispatcherHost); |
130 }; | 141 }; |
131 | 142 |
132 } // namespace content | 143 } // namespace content |
133 | 144 |
134 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ | 145 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_DISPATCHER_HOST_H_ |
OLD | NEW |