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 #include "content/browser/shared_worker/shared_worker_host.h" | 5 #include "content/browser/shared_worker/shared_worker_host.h" |
6 | 6 |
7 #include "content/browser/devtools/shared_worker_devtools_manager.h" | |
7 #include "content/browser/frame_host/render_frame_host_delegate.h" | 8 #include "content/browser/frame_host/render_frame_host_delegate.h" |
8 #include "content/browser/frame_host/render_frame_host_impl.h" | 9 #include "content/browser/frame_host/render_frame_host_impl.h" |
9 #include "content/browser/message_port_service.h" | 10 #include "content/browser/message_port_service.h" |
10 #include "content/browser/shared_worker/shared_worker_instance.h" | 11 #include "content/browser/shared_worker/shared_worker_instance.h" |
11 #include "content/browser/shared_worker/shared_worker_message_filter.h" | 12 #include "content/browser/shared_worker/shared_worker_message_filter.h" |
13 #include "content/browser/shared_worker/shared_worker_service_impl.h" | |
14 #include "content/common/devtools_messages.h" | |
12 #include "content/common/view_messages.h" | 15 #include "content/common/view_messages.h" |
13 #include "content/common/worker_messages.h" | 16 #include "content/common/worker_messages.h" |
14 #include "content/public/browser/browser_thread.h" | 17 #include "content/public/browser/browser_thread.h" |
15 #include "content/public/browser/content_browser_client.h" | 18 #include "content/public/browser/content_browser_client.h" |
19 #include "content/public/browser/render_process_host.h" | |
16 #include "content/public/common/content_client.h" | 20 #include "content/public/common/content_client.h" |
17 | 21 |
18 namespace content { | 22 namespace content { |
19 namespace { | 23 namespace { |
20 | 24 |
21 // Notifies RenderViewHost that one or more worker objects crashed. | 25 // Notifies RenderViewHost that one or more worker objects crashed. |
22 void WorkerCrashCallback(int render_process_unique_id, int render_frame_id) { | 26 void WorkerCrashCallback(int render_process_unique_id, int render_frame_id) { |
23 RenderFrameHostImpl* host = | 27 RenderFrameHostImpl* host = |
24 RenderFrameHostImpl::FromID(render_process_unique_id, render_frame_id); | 28 RenderFrameHostImpl::FromID(render_process_unique_id, render_frame_id); |
25 if (host) | 29 if (host) |
26 host->delegate()->WorkerCrashed(host); | 30 host->delegate()->WorkerCrashed(host); |
27 } | 31 } |
28 | 32 |
33 void WorkerScriptLoadedOnUI(int worker_process_id, int worker_route_id) { | |
34 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
35 SharedWorkerDevToolsManager::GetInstance()->WorkerContextStarted( | |
36 worker_process_id, worker_route_id); | |
37 } | |
38 | |
29 } // namespace | 39 } // namespace |
30 | 40 |
41 class WorkerDevToolsMessageHandler | |
42 : public IPC::Listener, | |
43 public base::RefCountedThreadSafe< | |
44 WorkerDevToolsMessageHandler, | |
45 content::BrowserThread::DeleteOnUIThread> { | |
46 public: | |
47 WorkerDevToolsMessageHandler() | |
48 : render_process_id_(0), route_id_(0), registered_(false) {} | |
49 void Register(int render_process_id, | |
50 int route_id, | |
51 const GURL& url, | |
52 const base::string16& name) { | |
53 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
54 RenderProcessHost* host = RenderProcessHost::FromID(render_process_id); | |
55 if (!host) | |
56 return; | |
57 host->AddRoute(route_id, this); | |
58 render_process_id_ = render_process_id; | |
59 route_id_ = route_id; | |
60 SharedWorkerDevToolsManager::GetInstance()->WorkerCreated( | |
61 render_process_id_, route_id_, url, name); | |
62 registered_ = true; | |
63 } | |
64 virtual bool OnMessageReceived(const IPC::Message& msg) OVERRIDE { | |
65 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
66 bool handled = true; | |
67 IPC_BEGIN_MESSAGE_MAP(WorkerDevToolsMessageHandler, msg) | |
yurys
2014/03/13 09:06:52
This messages are DevTools-specific and we should
horo
2014/03/14 08:53:20
Done.
| |
68 IPC_MESSAGE_HANDLER(DevToolsClientMsg_DispatchOnInspectorFrontend, | |
69 OnDispatchOnInspectorFrontend) | |
70 IPC_MESSAGE_HANDLER(DevToolsHostMsg_SaveAgentRuntimeState, | |
71 OnSaveAgentRumtimeState) | |
72 IPC_MESSAGE_UNHANDLED(handled = false) | |
73 IPC_END_MESSAGE_MAP() | |
74 return handled; | |
75 } | |
76 void OnDispatchOnInspectorFrontend(const std::string& message) { | |
77 SharedWorkerDevToolsManager::GetInstance()->ForwardToDevToolsClient( | |
78 render_process_id_, route_id_, message); | |
79 } | |
80 void OnSaveAgentRumtimeState(const std::string& state) { | |
81 SharedWorkerDevToolsManager::GetInstance()->SaveAgentRuntimeState( | |
82 render_process_id_, route_id_, state); | |
83 } | |
84 | |
85 private: | |
86 friend struct content::BrowserThread::DeleteOnThread< | |
87 content::BrowserThread::UI>; | |
88 friend class base::DeleteHelper<WorkerDevToolsMessageHandler>; | |
89 | |
90 virtual ~WorkerDevToolsMessageHandler() { | |
91 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI)); | |
92 SharedWorkerDevToolsManager::GetInstance()->WorkerDestroyed( | |
93 render_process_id_, route_id_); | |
94 if (!registered_) | |
95 return; | |
96 RenderProcessHost* host = RenderProcessHost::FromID(render_process_id_); | |
97 if (!host) | |
98 return; | |
99 host->RemoveRoute(route_id_); | |
100 } | |
101 | |
102 int render_process_id_; | |
103 int route_id_; | |
104 bool registered_; | |
105 DISALLOW_COPY_AND_ASSIGN(WorkerDevToolsMessageHandler); | |
106 }; | |
107 | |
31 SharedWorkerHost::SharedWorkerHost(SharedWorkerInstance* instance) | 108 SharedWorkerHost::SharedWorkerHost(SharedWorkerInstance* instance) |
32 : instance_(instance), | 109 : instance_(instance), |
110 dev_tools_handler_(new WorkerDevToolsMessageHandler()), | |
33 container_render_filter_(NULL), | 111 container_render_filter_(NULL), |
34 worker_route_id_(MSG_ROUTING_NONE) { | 112 worker_route_id_(MSG_ROUTING_NONE) { |
35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 113 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
36 } | 114 } |
37 | 115 |
38 SharedWorkerHost::~SharedWorkerHost() { | 116 SharedWorkerHost::~SharedWorkerHost() { |
39 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 117 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
40 // If we crashed, tell the RenderViewHosts. | 118 // If we crashed, tell the RenderViewHosts. |
41 if (instance_ && !instance_->load_failed()) { | 119 if (instance_ && !instance_->load_failed()) { |
42 const WorkerDocumentSet::DocumentInfoSet& parents = | 120 const WorkerDocumentSet::DocumentInfoSet& parents = |
43 instance_->worker_document_set()->documents(); | 121 instance_->worker_document_set()->documents(); |
44 for (WorkerDocumentSet::DocumentInfoSet::const_iterator parent_iter = | 122 for (WorkerDocumentSet::DocumentInfoSet::const_iterator parent_iter = |
45 parents.begin(); | 123 parents.begin(); |
46 parent_iter != parents.end(); | 124 parent_iter != parents.end(); |
47 ++parent_iter) { | 125 ++parent_iter) { |
48 BrowserThread::PostTask(BrowserThread::UI, | 126 BrowserThread::PostTask(BrowserThread::UI, |
49 FROM_HERE, | 127 FROM_HERE, |
50 base::Bind(&WorkerCrashCallback, | 128 base::Bind(&WorkerCrashCallback, |
51 parent_iter->render_process_id(), | 129 parent_iter->render_process_id(), |
52 parent_iter->render_frame_id())); | 130 parent_iter->render_frame_id())); |
53 } | 131 } |
54 } | 132 } |
133 SharedWorkerServiceImpl::GetInstance()->NotifyWorkerDestroyed( | |
134 worker_process_id_, worker_route_id_); | |
55 } | 135 } |
56 | 136 |
57 bool SharedWorkerHost::Send(IPC::Message* message) { | 137 bool SharedWorkerHost::Send(IPC::Message* message) { |
58 if (!container_render_filter_) { | 138 if (!container_render_filter_) { |
59 delete message; | 139 delete message; |
60 return false; | 140 return false; |
61 } | 141 } |
62 return container_render_filter_->Send(message); | 142 return container_render_filter_->Send(message); |
63 } | 143 } |
64 | 144 |
65 void SharedWorkerHost::Init(SharedWorkerMessageFilter* filter) { | 145 void SharedWorkerHost::Init(SharedWorkerMessageFilter* filter) { |
66 CHECK(instance_); | 146 CHECK(instance_); |
67 DCHECK(worker_route_id_ == MSG_ROUTING_NONE); | 147 DCHECK(worker_route_id_ == MSG_ROUTING_NONE); |
68 container_render_filter_ = filter; | 148 container_render_filter_ = filter; |
149 worker_process_id_ = filter->render_process_id(); | |
69 worker_route_id_ = filter->GetNextRoutingID(); | 150 worker_route_id_ = filter->GetNextRoutingID(); |
70 | 151 |
152 BrowserThread::PostTask(BrowserThread::UI, | |
153 FROM_HERE, | |
154 base::Bind(&WorkerDevToolsMessageHandler::Register, | |
155 dev_tools_handler_, | |
156 worker_process_id_, | |
157 worker_route_id_, | |
158 instance_->url(), | |
159 instance_->name())); | |
160 | |
71 WorkerProcessMsg_CreateWorker_Params params; | 161 WorkerProcessMsg_CreateWorker_Params params; |
72 params.url = instance_->url(); | 162 params.url = instance_->url(); |
73 params.name = instance_->name(); | 163 params.name = instance_->name(); |
74 params.content_security_policy = instance_->content_security_policy(); | 164 params.content_security_policy = instance_->content_security_policy(); |
75 params.security_policy_type = instance_->security_policy_type(); | 165 params.security_policy_type = instance_->security_policy_type(); |
76 params.route_id = worker_route_id_; | 166 params.route_id = worker_route_id_; |
77 Send(new WorkerProcessMsg_CreateWorker(params)); | 167 Send(new WorkerProcessMsg_CreateWorker(params)); |
78 | 168 |
79 for (SharedWorkerInstance::FilterList::const_iterator i = | 169 for (SharedWorkerInstance::FilterList::const_iterator i = |
80 instance_->filters().begin(); | 170 instance_->filters().begin(); |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
123 void SharedWorkerHost::WorkerContextClosed() { | 213 void SharedWorkerHost::WorkerContextClosed() { |
124 if (!instance_) | 214 if (!instance_) |
125 return; | 215 return; |
126 // Set the closed flag - this will stop any further messages from | 216 // Set the closed flag - this will stop any further messages from |
127 // being sent to the worker (messages can still be sent from the worker, | 217 // being sent to the worker (messages can still be sent from the worker, |
128 // for exception reporting, etc). | 218 // for exception reporting, etc). |
129 instance_->set_closed(true); | 219 instance_->set_closed(true); |
130 } | 220 } |
131 | 221 |
132 void SharedWorkerHost::WorkerContextDestroyed() { | 222 void SharedWorkerHost::WorkerContextDestroyed() { |
133 if (!instance_) | |
134 return; | |
135 instance_.reset(); | 223 instance_.reset(); |
136 } | 224 } |
137 | 225 |
138 void SharedWorkerHost::WorkerScriptLoaded() { | 226 void SharedWorkerHost::WorkerScriptLoaded() { |
139 // TODO(horo): implement this. | 227 BrowserThread::PostTask( |
228 BrowserThread::UI, | |
229 FROM_HERE, | |
230 base::Bind( | |
231 &WorkerScriptLoadedOnUI, worker_process_id_, worker_route_id_)); | |
140 } | 232 } |
141 | 233 |
142 void SharedWorkerHost::WorkerScriptLoadFailed() { | 234 void SharedWorkerHost::WorkerScriptLoadFailed() { |
143 if (!instance_) | 235 if (!instance_) |
144 return; | 236 return; |
145 instance_->set_load_failed(true); | 237 instance_->set_load_failed(true); |
146 for (SharedWorkerInstance::FilterList::const_iterator i = | 238 for (SharedWorkerInstance::FilterList::const_iterator i = |
147 instance_->filters().begin(); | 239 instance_->filters().begin(); |
148 i != instance_->filters().end(); ++i) { | 240 i != instance_->filters().end(); ++i) { |
149 i->filter()->Send(new ViewMsg_WorkerScriptLoadFailed(i->route_id())); | 241 i->filter()->Send(new ViewMsg_WorkerScriptLoadFailed(i->route_id())); |
(...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
248 documents.begin(); | 340 documents.begin(); |
249 doc != documents.end(); | 341 doc != documents.end(); |
250 ++doc) { | 342 ++doc) { |
251 result.push_back( | 343 result.push_back( |
252 std::make_pair(doc->render_process_id(), doc->render_frame_id())); | 344 std::make_pair(doc->render_process_id(), doc->render_frame_id())); |
253 } | 345 } |
254 return result; | 346 return result; |
255 } | 347 } |
256 | 348 |
257 } // namespace content | 349 } // namespace content |
OLD | NEW |