OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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_SHARED_WORKER_SHARED_WORKER_HOST_H_ | 5 #ifndef CONTENT_BROWSER_SHARED_WORKER_SHARED_WORKER_HOST_H_ |
6 #define CONTENT_BROWSER_SHARED_WORKER_SHARED_WORKER_HOST_H_ | 6 #define CONTENT_BROWSER_SHARED_WORKER_SHARED_WORKER_HOST_H_ |
7 | 7 |
8 #include <list> | 8 #include <list> |
9 #include <memory> | 9 #include <memory> |
10 #include <utility> | 10 #include <utility> |
11 #include <vector> | 11 #include <vector> |
12 | 12 |
13 #include "base/macros.h" | 13 #include "base/macros.h" |
14 #include "base/memory/weak_ptr.h" | 14 #include "base/memory/weak_ptr.h" |
15 #include "base/strings/string16.h" | 15 #include "base/strings/string16.h" |
16 #include "base/time/time.h" | 16 #include "base/time/time.h" |
17 #include "content/browser/shared_worker/shared_worker_message_filter.h" | |
18 #include "content/browser/shared_worker/worker_document_set.h" | 17 #include "content/browser/shared_worker/worker_document_set.h" |
19 | 18 |
20 class GURL; | 19 class GURL; |
21 | 20 |
22 namespace IPC { | 21 namespace IPC { |
23 class Message; | 22 class Message; |
24 } | 23 } |
25 | 24 |
26 namespace content { | 25 namespace content { |
| 26 |
27 class SharedWorkerMessageFilter; | 27 class SharedWorkerMessageFilter; |
28 class SharedWorkerInstance; | 28 class SharedWorkerInstance; |
29 | 29 |
30 // The SharedWorkerHost is the interface that represents the browser side of | 30 // The SharedWorkerHost is the interface that represents the browser side of |
31 // the browser <-> worker communication channel. | 31 // the browser <-> worker communication channel. This is owned by |
| 32 // SharedWorkerServiceImpl and destructed when a worker context or worker's |
| 33 // message filter is closed. |
32 class SharedWorkerHost { | 34 class SharedWorkerHost { |
33 public: | 35 public: |
34 SharedWorkerHost(SharedWorkerInstance* instance, | 36 SharedWorkerHost(SharedWorkerInstance* instance, |
35 SharedWorkerMessageFilter* filter, | 37 SharedWorkerMessageFilter* filter, |
36 int worker_route_id); | 38 int worker_route_id); |
37 ~SharedWorkerHost(); | 39 ~SharedWorkerHost(); |
38 | 40 |
39 // Sends |message| to the SharedWorker. | |
40 bool Send(IPC::Message* message); | |
41 | |
42 // Starts the SharedWorker in the renderer process which is associated with | 41 // Starts the SharedWorker in the renderer process which is associated with |
43 // |filter_|. | 42 // |filter_|. |
44 void Start(bool pause_on_start); | 43 void Start(bool pause_on_start); |
45 | 44 |
46 // Returns true iff the given message from a renderer process was forwarded to | 45 // Returns true iff the given message from a renderer process was forwarded to |
47 // the worker. | 46 // the worker. |
48 bool FilterConnectionMessage(int route_id, | 47 bool FilterConnectionMessage(int route_id, |
49 int sent_message_port_id, | 48 int sent_message_port_id, |
50 SharedWorkerMessageFilter* incoming_filter); | 49 SharedWorkerMessageFilter* incoming_filter); |
51 | 50 |
(...skipping 25 matching lines...) Expand all Loading... |
77 | 76 |
78 // Terminates the given worker, i.e. based on a UI action. | 77 // Terminates the given worker, i.e. based on a UI action. |
79 void TerminateWorker(); | 78 void TerminateWorker(); |
80 | 79 |
81 void AddFilter(SharedWorkerMessageFilter* filter, int route_id); | 80 void AddFilter(SharedWorkerMessageFilter* filter, int route_id); |
82 | 81 |
83 SharedWorkerInstance* instance() { return instance_.get(); } | 82 SharedWorkerInstance* instance() { return instance_.get(); } |
84 WorkerDocumentSet* worker_document_set() const { | 83 WorkerDocumentSet* worker_document_set() const { |
85 return worker_document_set_.get(); | 84 return worker_document_set_.get(); |
86 } | 85 } |
87 SharedWorkerMessageFilter* container_render_filter() const { | 86 SharedWorkerMessageFilter* worker_render_filter() const { |
88 return container_render_filter_; | 87 return worker_render_filter_; |
89 } | 88 } |
90 int process_id() const { return worker_process_id_; } | 89 int process_id() const { return worker_process_id_; } |
91 int worker_route_id() const { return worker_route_id_; } | 90 int worker_route_id() const { return worker_route_id_; } |
92 bool IsAvailable() const; | 91 bool IsAvailable() const; |
93 | 92 |
94 private: | 93 private: |
95 // Unique identifier for a worker client. | 94 // Unique identifier for a worker client. |
96 class FilterInfo { | 95 class FilterInfo { |
97 public: | 96 public: |
98 FilterInfo(SharedWorkerMessageFilter* filter, int route_id) | 97 FilterInfo(SharedWorkerMessageFilter* filter, int route_id) |
(...skipping 18 matching lines...) Expand all Loading... |
117 bool HasFilter(SharedWorkerMessageFilter* filter, int route_id) const; | 116 bool HasFilter(SharedWorkerMessageFilter* filter, int route_id) const; |
118 void Connect(int route_id, | 117 void Connect(int route_id, |
119 int sent_message_port_id, | 118 int sent_message_port_id, |
120 SharedWorkerMessageFilter* incoming_filter); | 119 SharedWorkerMessageFilter* incoming_filter); |
121 void SetMessagePortID(SharedWorkerMessageFilter* filter, | 120 void SetMessagePortID(SharedWorkerMessageFilter* filter, |
122 int route_id, | 121 int route_id, |
123 int message_port_id); | 122 int message_port_id); |
124 void AllowFileSystemResponse(std::unique_ptr<IPC::Message> reply_msg, | 123 void AllowFileSystemResponse(std::unique_ptr<IPC::Message> reply_msg, |
125 bool allowed); | 124 bool allowed); |
126 | 125 |
| 126 // Sends |message| to the SharedWorker. |
| 127 bool Send(IPC::Message* message); |
| 128 |
127 std::unique_ptr<SharedWorkerInstance> instance_; | 129 std::unique_ptr<SharedWorkerInstance> instance_; |
128 scoped_refptr<WorkerDocumentSet> worker_document_set_; | 130 scoped_refptr<WorkerDocumentSet> worker_document_set_; |
129 FilterList filters_; | 131 FilterList filters_; |
130 SharedWorkerMessageFilter* container_render_filter_; | 132 |
| 133 // A message filter for a renderer process that hosts a worker. This is always |
| 134 // valid because this host is destructed immediately after the filter is |
| 135 // closed (see SharedWorkerServiceImpl::OnSharedWorkerMessageFilterClosing). |
| 136 SharedWorkerMessageFilter* worker_render_filter_; |
| 137 |
131 const int worker_process_id_; | 138 const int worker_process_id_; |
132 const int worker_route_id_; | 139 const int worker_route_id_; |
133 bool termination_message_sent_; | 140 bool termination_message_sent_ = false; |
134 bool closed_; | 141 bool closed_ = false; |
135 const base::TimeTicks creation_time_; | 142 const base::TimeTicks creation_time_; |
136 | 143 |
137 base::WeakPtrFactory<SharedWorkerHost> weak_factory_; | 144 base::WeakPtrFactory<SharedWorkerHost> weak_factory_; |
138 | 145 |
139 DISALLOW_COPY_AND_ASSIGN(SharedWorkerHost); | 146 DISALLOW_COPY_AND_ASSIGN(SharedWorkerHost); |
140 }; | 147 }; |
141 } // namespace content | 148 } // namespace content |
142 | 149 |
143 #endif // CONTENT_BROWSER_SHARED_WORKER_SHARED_WORKER_HOST_H_ | 150 #endif // CONTENT_BROWSER_SHARED_WORKER_SHARED_WORKER_HOST_H_ |
OLD | NEW |