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 "mojo/services/view_manager/view_manager_connection.h" | 5 #include "mojo/services/view_manager/view_manager_connection.h" |
6 | 6 |
7 #include "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "mojo/public/cpp/bindings/allocation_scope.h" | 8 #include "mojo/public/cpp/bindings/allocation_scope.h" |
9 #include "mojo/services/view_manager/node.h" | 9 #include "mojo/services/view_manager/node.h" |
10 #include "mojo/services/view_manager/root_node_manager.h" | 10 #include "mojo/services/view_manager/root_node_manager.h" |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
52 | 52 |
53 std::vector<Node*> children(node->GetChildren()); | 53 std::vector<Node*> children(node->GetChildren()); |
54 for (size_t i = 0 ; i < children.size(); ++i) { | 54 for (size_t i = 0 ; i < children.size(); ++i) { |
55 (*index)++; | 55 (*index)++; |
56 NodeToINode(children[i], array_builder, index); | 56 NodeToINode(children[i], array_builder, index); |
57 } | 57 } |
58 } | 58 } |
59 | 59 |
60 } // namespace | 60 } // namespace |
61 | 61 |
62 ViewManagerConnection::ViewManagerConnection() : id_(0) { | 62 ViewManagerConnection::ViewManagerConnection(RootNodeManager* root_node_manager) |
63 : root_node_manager_(root_node_manager), | |
64 id_(0) { | |
63 } | 65 } |
64 | 66 |
65 ViewManagerConnection::~ViewManagerConnection() { | 67 ViewManagerConnection::~ViewManagerConnection() { |
66 // Delete any views we own. | 68 // Delete any views we own. |
67 while (!view_map_.empty()) { | 69 while (!view_map_.empty()) { |
68 bool result = DeleteViewImpl(this, view_map_.begin()->second->id()); | 70 bool result = DeleteViewImpl(this, view_map_.begin()->second->id()); |
69 DCHECK(result); | 71 DCHECK(result); |
70 } | 72 } |
71 | 73 |
72 // We're about to destroy all our nodes. Detach any views from them. | 74 // We're about to destroy all our nodes. Detach any views from them. |
73 for (NodeMap::iterator i = node_map_.begin(); i != node_map_.end(); ++i) { | 75 for (NodeMap::iterator i = node_map_.begin(); i != node_map_.end(); ++i) { |
74 if (i->second->view()) { | 76 if (i->second->view()) { |
75 bool result = SetViewImpl(i->second->id(), ViewId()); | 77 bool result = SetViewImpl(i->second->id(), ViewId()); |
76 DCHECK(result); | 78 DCHECK(result); |
77 } | 79 } |
78 } | 80 } |
79 | 81 |
80 STLDeleteContainerPairSecondPointers(node_map_.begin(), node_map_.end()); | 82 STLDeleteContainerPairSecondPointers(node_map_.begin(), node_map_.end()); |
81 context()->RemoveConnection(this); | 83 root_node_manager_->RemoveConnection(this); |
82 } | 84 } |
83 | 85 |
84 void ViewManagerConnection::Initialize() { | 86 void ViewManagerConnection::OnConnectionError() {} |
85 DCHECK_EQ(0, id_); // Should only get Initialize() once. | 87 |
86 id_ = context()->GetAndAdvanceNextConnectionId(); | 88 void ViewManagerConnection::SetClient(IViewManagerClient* client) { |
87 context()->AddConnection(this); | 89 DCHECK_EQ(0, id_); // Should only get SetClient() once. |
88 client()->OnConnectionEstablished(id_, context()->next_server_change_id()); | 90 InterfaceImpl<IViewManager>::SetClient(client); |
darin (slow to review)
2014/05/14 20:00:21
It is this case that makes me wonder if the ViewMa
sky
2014/05/14 20:12:29
The clients don't know this information, only the
| |
91 id_ = root_node_manager_->GetAndAdvanceNextConnectionId(); | |
92 root_node_manager_->AddConnection(this); | |
93 client->OnConnectionEstablished( | |
94 id_, root_node_manager_->next_server_change_id()); | |
89 } | 95 } |
90 | 96 |
91 Node* ViewManagerConnection::GetNode(const NodeId& id) { | 97 Node* ViewManagerConnection::GetNode(const NodeId& id) { |
92 if (id_ == id.connection_id) { | 98 if (id_ == id.connection_id) { |
93 NodeMap::iterator i = node_map_.find(id.node_id); | 99 NodeMap::iterator i = node_map_.find(id.node_id); |
94 return i == node_map_.end() ? NULL : i->second; | 100 return i == node_map_.end() ? NULL : i->second; |
95 } | 101 } |
96 return context()->GetNode(id); | 102 return root_node_manager_->GetNode(id); |
97 } | 103 } |
98 | 104 |
99 View* ViewManagerConnection::GetView(const ViewId& id) { | 105 View* ViewManagerConnection::GetView(const ViewId& id) { |
100 if (id_ == id.connection_id) { | 106 if (id_ == id.connection_id) { |
101 ViewMap::const_iterator i = view_map_.find(id.view_id); | 107 ViewMap::const_iterator i = view_map_.find(id.view_id); |
102 return i == view_map_.end() ? NULL : i->second; | 108 return i == view_map_.end() ? NULL : i->second; |
103 } | 109 } |
104 return context()->GetView(id); | 110 return root_node_manager_->GetView(id); |
105 } | 111 } |
106 | 112 |
107 void ViewManagerConnection::NotifyNodeHierarchyChanged( | 113 void ViewManagerConnection::NotifyNodeHierarchyChanged( |
108 const NodeId& node, | 114 const NodeId& node, |
109 const NodeId& new_parent, | 115 const NodeId& new_parent, |
110 const NodeId& old_parent, | 116 const NodeId& old_parent, |
111 TransportChangeId server_change_id) { | 117 TransportChangeId server_change_id) { |
112 client()->OnNodeHierarchyChanged(NodeIdToTransportId(node), | 118 client()->OnNodeHierarchyChanged(NodeIdToTransportId(node), |
113 NodeIdToTransportId(new_parent), | 119 NodeIdToTransportId(new_parent), |
114 NodeIdToTransportId(old_parent), | 120 NodeIdToTransportId(old_parent), |
(...skipping 19 matching lines...) Expand all Loading... | |
134 client()->OnViewDeleted(ViewIdToTransportId(view)); | 140 client()->OnViewDeleted(ViewIdToTransportId(view)); |
135 } | 141 } |
136 | 142 |
137 bool ViewManagerConnection::DeleteNodeImpl(ViewManagerConnection* source, | 143 bool ViewManagerConnection::DeleteNodeImpl(ViewManagerConnection* source, |
138 const NodeId& node_id) { | 144 const NodeId& node_id) { |
139 DCHECK_EQ(node_id.connection_id, id_); | 145 DCHECK_EQ(node_id.connection_id, id_); |
140 Node* node = GetNode(node_id); | 146 Node* node = GetNode(node_id); |
141 if (!node) | 147 if (!node) |
142 return false; | 148 return false; |
143 RootNodeManager::ScopedChange change( | 149 RootNodeManager::ScopedChange change( |
144 source, context(), RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); | 150 source, root_node_manager_, |
151 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); | |
145 if (node->GetParent()) | 152 if (node->GetParent()) |
146 node->GetParent()->Remove(node); | 153 node->GetParent()->Remove(node); |
147 std::vector<Node*> children(node->GetChildren()); | 154 std::vector<Node*> children(node->GetChildren()); |
148 for (size_t i = 0; i < children.size(); ++i) | 155 for (size_t i = 0; i < children.size(); ++i) |
149 node->Remove(children[i]); | 156 node->Remove(children[i]); |
150 DCHECK(node->GetChildren().empty()); | 157 DCHECK(node->GetChildren().empty()); |
151 node_map_.erase(node_id.node_id); | 158 node_map_.erase(node_id.node_id); |
152 delete node; | 159 delete node; |
153 node = NULL; | 160 node = NULL; |
154 context()->NotifyNodeDeleted(node_id); | 161 root_node_manager_->NotifyNodeDeleted(node_id); |
155 return true; | 162 return true; |
156 } | 163 } |
157 | 164 |
158 bool ViewManagerConnection::DeleteViewImpl(ViewManagerConnection* source, | 165 bool ViewManagerConnection::DeleteViewImpl(ViewManagerConnection* source, |
159 const ViewId& view_id) { | 166 const ViewId& view_id) { |
160 DCHECK_EQ(view_id.connection_id, id_); | 167 DCHECK_EQ(view_id.connection_id, id_); |
161 View* view = GetView(view_id); | 168 View* view = GetView(view_id); |
162 if (!view) | 169 if (!view) |
163 return false; | 170 return false; |
164 RootNodeManager::ScopedChange change( | 171 RootNodeManager::ScopedChange change( |
165 source, context(), | 172 source, root_node_manager_, |
166 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID); | 173 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID); |
167 if (view->node()) | 174 if (view->node()) |
168 view->node()->SetView(NULL); | 175 view->node()->SetView(NULL); |
169 view_map_.erase(view_id.view_id); | 176 view_map_.erase(view_id.view_id); |
170 // Make a copy of |view_id| as once we delete view |view_id| may no longer be | 177 // Make a copy of |view_id| as once we delete view |view_id| may no longer be |
171 // valid. | 178 // valid. |
172 const ViewId view_id_copy(view_id); | 179 const ViewId view_id_copy(view_id); |
173 delete view; | 180 delete view; |
174 context()->NotifyViewDeleted(view_id_copy); | 181 root_node_manager_->NotifyViewDeleted(view_id_copy); |
175 return true; | 182 return true; |
176 } | 183 } |
177 | 184 |
178 bool ViewManagerConnection::SetViewImpl(const NodeId& node_id, | 185 bool ViewManagerConnection::SetViewImpl(const NodeId& node_id, |
179 const ViewId& view_id) { | 186 const ViewId& view_id) { |
180 Node* node = GetNode(node_id); | 187 Node* node = GetNode(node_id); |
181 if (!node) | 188 if (!node) |
182 return false; | 189 return false; |
183 View* view = GetView(view_id); | 190 View* view = GetView(view_id); |
184 if (!view && view_id != ViewId()) | 191 if (!view && view_id != ViewId()) |
185 return false; | 192 return false; |
186 RootNodeManager::ScopedChange change( | 193 RootNodeManager::ScopedChange change( |
187 this, context(), | 194 this, root_node_manager_, |
188 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID); | 195 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID); |
189 node->SetView(view); | 196 node->SetView(view); |
190 return true; | 197 return true; |
191 } | 198 } |
192 | 199 |
193 void ViewManagerConnection::CreateNode( | 200 void ViewManagerConnection::CreateNode( |
194 TransportNodeId transport_node_id, | 201 TransportNodeId transport_node_id, |
195 const Callback<void(bool)>& callback) { | 202 const Callback<void(bool)>& callback) { |
196 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 203 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
197 if (node_id.connection_id != id_ || | 204 if (node_id.connection_id != id_ || |
198 node_map_.find(node_id.node_id) != node_map_.end()) { | 205 node_map_.find(node_id.node_id) != node_map_.end()) { |
199 callback.Run(false); | 206 callback.Run(false); |
200 return; | 207 return; |
201 } | 208 } |
202 node_map_[node_id.node_id] = new Node(this, node_id); | 209 node_map_[node_id.node_id] = new Node(this, node_id); |
203 callback.Run(true); | 210 callback.Run(true); |
204 } | 211 } |
205 | 212 |
206 void ViewManagerConnection::DeleteNode( | 213 void ViewManagerConnection::DeleteNode( |
207 TransportNodeId transport_node_id, | 214 TransportNodeId transport_node_id, |
208 const Callback<void(bool)>& callback) { | 215 const Callback<void(bool)>& callback) { |
209 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 216 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
210 ViewManagerConnection* connection = context()->GetConnection( | 217 ViewManagerConnection* connection = root_node_manager_->GetConnection( |
211 node_id.connection_id); | 218 node_id.connection_id); |
212 callback.Run(connection && | 219 callback.Run(connection && |
213 connection->DeleteNodeImpl(this, node_id)); | 220 connection->DeleteNodeImpl(this, node_id)); |
214 } | 221 } |
215 | 222 |
216 void ViewManagerConnection::AddNode( | 223 void ViewManagerConnection::AddNode( |
217 TransportNodeId parent_id, | 224 TransportNodeId parent_id, |
218 TransportNodeId child_id, | 225 TransportNodeId child_id, |
219 TransportChangeId server_change_id, | 226 TransportChangeId server_change_id, |
220 const Callback<void(bool)>& callback) { | 227 const Callback<void(bool)>& callback) { |
221 bool success = false; | 228 bool success = false; |
222 if (server_change_id == context()->next_server_change_id()) { | 229 if (server_change_id == root_node_manager_->next_server_change_id()) { |
223 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); | 230 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); |
224 Node* child = GetNode(NodeIdFromTransportId(child_id)); | 231 Node* child = GetNode(NodeIdFromTransportId(child_id)); |
225 if (parent && child && child->GetParent() != parent && | 232 if (parent && child && child->GetParent() != parent && |
226 !child->window()->Contains(parent->window())) { | 233 !child->window()->Contains(parent->window())) { |
227 success = true; | 234 success = true; |
228 RootNodeManager::ScopedChange change( | 235 RootNodeManager::ScopedChange change( |
229 this, context(), | 236 this, root_node_manager_, |
230 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); | 237 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); |
231 parent->Add(child); | 238 parent->Add(child); |
232 } | 239 } |
233 } | 240 } |
234 callback.Run(success); | 241 callback.Run(success); |
235 } | 242 } |
236 | 243 |
237 void ViewManagerConnection::RemoveNodeFromParent( | 244 void ViewManagerConnection::RemoveNodeFromParent( |
238 TransportNodeId node_id, | 245 TransportNodeId node_id, |
239 TransportChangeId server_change_id, | 246 TransportChangeId server_change_id, |
240 const Callback<void(bool)>& callback) { | 247 const Callback<void(bool)>& callback) { |
241 bool success = false; | 248 bool success = false; |
242 if (server_change_id == context()->next_server_change_id()) { | 249 if (server_change_id == root_node_manager_->next_server_change_id()) { |
243 Node* node = GetNode(NodeIdFromTransportId(node_id)); | 250 Node* node = GetNode(NodeIdFromTransportId(node_id)); |
244 if (node && node->GetParent()) { | 251 if (node && node->GetParent()) { |
245 success = true; | 252 success = true; |
246 RootNodeManager::ScopedChange change( | 253 RootNodeManager::ScopedChange change( |
247 this, context(), | 254 this, root_node_manager_, |
248 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); | 255 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID); |
249 node->GetParent()->Remove(node); | 256 node->GetParent()->Remove(node); |
250 } | 257 } |
251 } | 258 } |
252 callback.Run(success); | 259 callback.Run(success); |
253 } | 260 } |
254 | 261 |
255 void ViewManagerConnection::GetNodeTree( | 262 void ViewManagerConnection::GetNodeTree( |
256 TransportNodeId node_id, | 263 TransportNodeId node_id, |
257 const Callback<void(Array<INode>)>& callback) { | 264 const Callback<void(Array<INode>)>& callback) { |
(...skipping 16 matching lines...) Expand all Loading... | |
274 return; | 281 return; |
275 } | 282 } |
276 view_map_[view_id.view_id] = new View(view_id); | 283 view_map_[view_id.view_id] = new View(view_id); |
277 callback.Run(true); | 284 callback.Run(true); |
278 } | 285 } |
279 | 286 |
280 void ViewManagerConnection::DeleteView( | 287 void ViewManagerConnection::DeleteView( |
281 TransportViewId transport_view_id, | 288 TransportViewId transport_view_id, |
282 const Callback<void(bool)>& callback) { | 289 const Callback<void(bool)>& callback) { |
283 const ViewId view_id(ViewIdFromTransportId(transport_view_id)); | 290 const ViewId view_id(ViewIdFromTransportId(transport_view_id)); |
284 ViewManagerConnection* connection = context()->GetConnection( | 291 ViewManagerConnection* connection = root_node_manager_->GetConnection( |
285 view_id.connection_id); | 292 view_id.connection_id); |
286 callback.Run(connection && connection->DeleteViewImpl(this, view_id)); | 293 callback.Run(connection && connection->DeleteViewImpl(this, view_id)); |
287 } | 294 } |
288 | 295 |
289 void ViewManagerConnection::SetView( | 296 void ViewManagerConnection::SetView( |
290 TransportNodeId transport_node_id, | 297 TransportNodeId transport_node_id, |
291 TransportViewId transport_view_id, | 298 TransportViewId transport_view_id, |
292 const Callback<void(bool)>& callback) { | 299 const Callback<void(bool)>& callback) { |
293 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 300 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
294 callback.Run(SetViewImpl(node_id, ViewIdFromTransportId(transport_view_id))); | 301 callback.Run(SetViewImpl(node_id, ViewIdFromTransportId(transport_view_id))); |
(...skipping 14 matching lines...) Expand all Loading... | |
309 SkBitmap bitmap; | 316 SkBitmap bitmap; |
310 gfx::PNGCodec::Decode(static_cast<const unsigned char*>(handle_data), | 317 gfx::PNGCodec::Decode(static_cast<const unsigned char*>(handle_data), |
311 buffer_size, &bitmap); | 318 buffer_size, &bitmap); |
312 view->SetBitmap(bitmap); | 319 view->SetBitmap(bitmap); |
313 UnmapBuffer(handle_data); | 320 UnmapBuffer(handle_data); |
314 } | 321 } |
315 | 322 |
316 void ViewManagerConnection::OnNodeHierarchyChanged(const NodeId& node, | 323 void ViewManagerConnection::OnNodeHierarchyChanged(const NodeId& node, |
317 const NodeId& new_parent, | 324 const NodeId& new_parent, |
318 const NodeId& old_parent) { | 325 const NodeId& old_parent) { |
319 context()->NotifyNodeHierarchyChanged(node, new_parent, old_parent); | 326 root_node_manager_->NotifyNodeHierarchyChanged(node, new_parent, old_parent); |
320 } | 327 } |
321 | 328 |
322 void ViewManagerConnection::OnNodeViewReplaced(const NodeId& node, | 329 void ViewManagerConnection::OnNodeViewReplaced(const NodeId& node, |
323 const ViewId& new_view_id, | 330 const ViewId& new_view_id, |
324 const ViewId& old_view_id) { | 331 const ViewId& old_view_id) { |
325 context()->NotifyNodeViewReplaced(node, new_view_id, old_view_id); | 332 root_node_manager_->NotifyNodeViewReplaced(node, new_view_id, old_view_id); |
326 } | 333 } |
327 | 334 |
328 } // namespace service | 335 } // namespace service |
329 } // namespace view_manager | 336 } // namespace view_manager |
330 } // namespace mojo | 337 } // namespace mojo |
OLD | NEW |