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_EMBEDDED_WORKER_REGISTRY_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_REGISTRY_H_ |
6 #define CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_REGISTRY_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_REGISTRY_H_ |
7 | 7 |
8 #include <map> | 8 #include <map> |
9 #include <memory> | 9 #include <memory> |
10 #include <set> | 10 #include <set> |
(...skipping 10 matching lines...) Expand all Loading... |
21 class GURL; | 21 class GURL; |
22 | 22 |
23 namespace IPC { | 23 namespace IPC { |
24 class Message; | 24 class Message; |
25 class Sender; | 25 class Sender; |
26 } | 26 } |
27 | 27 |
28 namespace content { | 28 namespace content { |
29 | 29 |
30 class EmbeddedWorkerInstance; | 30 class EmbeddedWorkerInstance; |
31 struct EmbeddedWorkerStartParams; | |
32 class MessagePortMessageFilter; | 31 class MessagePortMessageFilter; |
33 class ServiceWorkerContextCore; | 32 class ServiceWorkerContextCore; |
34 | 33 |
35 // Acts as a thin stub between MessageFilter and each EmbeddedWorkerInstance, | 34 // Acts as a thin stub between MessageFilter and each EmbeddedWorkerInstance, |
36 // which sends/receives messages to/from each EmbeddedWorker in child process. | 35 // which sends/receives messages to/from each EmbeddedWorker in child process. |
37 // | 36 // |
38 // Hangs off ServiceWorkerContextCore (its reference is also held by each | 37 // Hangs off ServiceWorkerContextCore (its reference is also held by each |
39 // EmbeddedWorkerInstance). Operated only on IO thread. | 38 // EmbeddedWorkerInstance). Operated only on IO thread. |
40 class CONTENT_EXPORT EmbeddedWorkerRegistry | 39 class CONTENT_EXPORT EmbeddedWorkerRegistry |
41 : public NON_EXPORTED_BASE(base::RefCounted<EmbeddedWorkerRegistry>) { | 40 : public NON_EXPORTED_BASE(base::RefCounted<EmbeddedWorkerRegistry>) { |
42 public: | 41 public: |
43 typedef base::Callback<void(ServiceWorkerStatusCode)> StatusCallback; | 42 typedef base::Callback<void(ServiceWorkerStatusCode)> StatusCallback; |
44 | 43 |
45 static scoped_refptr<EmbeddedWorkerRegistry> Create( | 44 static scoped_refptr<EmbeddedWorkerRegistry> Create( |
46 const base::WeakPtr<ServiceWorkerContextCore>& contxet); | 45 const base::WeakPtr<ServiceWorkerContextCore>& contxet); |
47 | 46 |
48 // Used for DeleteAndStartOver. Creates a new registry which takes over | 47 // Used for DeleteAndStartOver. Creates a new registry which takes over |
49 // |next_embedded_worker_id_| and |process_sender_map_| from |old_registry|. | 48 // |next_embedded_worker_id_| and |process_sender_map_| from |old_registry|. |
50 static scoped_refptr<EmbeddedWorkerRegistry> Create( | 49 static scoped_refptr<EmbeddedWorkerRegistry> Create( |
51 const base::WeakPtr<ServiceWorkerContextCore>& context, | 50 const base::WeakPtr<ServiceWorkerContextCore>& context, |
52 EmbeddedWorkerRegistry* old_registry); | 51 EmbeddedWorkerRegistry* old_registry); |
53 | 52 |
54 bool OnMessageReceived(const IPC::Message& message, int process_id); | 53 bool OnMessageReceived(const IPC::Message& message, int process_id); |
55 | 54 |
56 // Creates and removes a new worker instance entry for bookkeeping. | 55 // Creates and removes a new worker instance entry for bookkeeping. |
57 // This doesn't actually start or stop the worker. | 56 // This doesn't actually start or stop the worker. |
58 std::unique_ptr<EmbeddedWorkerInstance> CreateWorker(); | 57 std::unique_ptr<EmbeddedWorkerInstance> CreateWorker(); |
59 | 58 |
60 // Called from EmbeddedWorkerInstance, relayed to the child process. | 59 // Called from EmbeddedWorkerInstance, relayed to the child process. |
61 ServiceWorkerStatusCode SendStartWorker( | |
62 std::unique_ptr<EmbeddedWorkerStartParams> params, | |
63 int process_id); | |
64 ServiceWorkerStatusCode StopWorker(int process_id, | 60 ServiceWorkerStatusCode StopWorker(int process_id, |
65 int embedded_worker_id); | 61 int embedded_worker_id); |
66 | 62 |
67 // Stop all active workers, even if they're handling events. | 63 // Stop all active workers, even if they're handling events. |
68 void Shutdown(); | 64 void Shutdown(); |
69 | 65 |
70 // Called back from EmbeddedWorker in the child process, relayed via | 66 // Called back from EmbeddedWorker in the child process, relayed via |
71 // ServiceWorkerDispatcherHost. | 67 // ServiceWorkerDispatcherHost. |
72 void OnWorkerReadyForInspection(int process_id, int embedded_worker_id); | 68 void OnWorkerReadyForInspection(int process_id, int embedded_worker_id); |
73 void OnWorkerScriptLoaded(int process_id, int embedded_worker_id); | 69 void OnWorkerScriptLoaded(int process_id, int embedded_worker_id); |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
156 | 152 |
157 int next_embedded_worker_id_; | 153 int next_embedded_worker_id_; |
158 const int initial_embedded_worker_id_; | 154 const int initial_embedded_worker_id_; |
159 | 155 |
160 DISALLOW_COPY_AND_ASSIGN(EmbeddedWorkerRegistry); | 156 DISALLOW_COPY_AND_ASSIGN(EmbeddedWorkerRegistry); |
161 }; | 157 }; |
162 | 158 |
163 } // namespace content | 159 } // namespace content |
164 | 160 |
165 #endif // CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_REGISTRY_H_ | 161 #endif // CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_REGISTRY_H_ |
OLD | NEW |