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 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
65 GetUnknownNodesFrom(root_node_manager_->root(), &to_send); | 65 GetUnknownNodesFrom(root_node_manager_->root(), &to_send); |
66 AllocationScope allocation_scope; | 66 AllocationScope allocation_scope; |
67 client()->OnConnectionEstablished( | 67 client()->OnConnectionEstablished( |
68 id_, | 68 id_, |
69 root_node_manager_->next_server_change_id(), | 69 root_node_manager_->next_server_change_id(), |
70 Array<INode>::From(to_send)); | 70 Array<INode>::From(to_send)); |
71 } | 71 } |
72 | 72 |
73 void ViewManagerConnection::OnConnectionError() {} | 73 void ViewManagerConnection::OnConnectionError() {} |
74 | 74 |
75 Node* ViewManagerConnection::GetNode(const NodeId& id) { | 75 const Node* ViewManagerConnection::GetNode(const NodeId& id) const { |
76 if (id_ == id.connection_id) { | 76 if (id_ == id.connection_id) { |
77 NodeMap::iterator i = node_map_.find(id.node_id); | 77 NodeMap::const_iterator i = node_map_.find(id.node_id); |
78 return i == node_map_.end() ? NULL : i->second; | 78 return i == node_map_.end() ? NULL : i->second; |
79 } | 79 } |
80 return root_node_manager_->GetNode(id); | 80 return root_node_manager_->GetNode(id); |
81 } | 81 } |
82 | 82 |
83 View* ViewManagerConnection::GetView(const ViewId& id) { | 83 View* ViewManagerConnection::GetView(const ViewId& id) { |
84 if (id_ == id.connection_id) { | 84 if (id_ == id.connection_id) { |
85 ViewMap::const_iterator i = view_map_.find(id.view_id); | 85 ViewMap::const_iterator i = view_map_.find(id.view_id); |
86 return i == view_map_.end() ? NULL : i->second; | 86 return i == view_map_.end() ? NULL : i->second; |
87 } | 87 } |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
146 } | 146 } |
147 } | 147 } |
148 | 148 |
149 void ViewManagerConnection::ProcessViewDeleted(const ViewId& view, | 149 void ViewManagerConnection::ProcessViewDeleted(const ViewId& view, |
150 bool originated_change) { | 150 bool originated_change) { |
151 if (originated_change) | 151 if (originated_change) |
152 return; | 152 return; |
153 client()->OnViewDeleted(ViewIdToTransportId(view)); | 153 client()->OnViewDeleted(ViewIdToTransportId(view)); |
154 } | 154 } |
155 | 155 |
| 156 bool ViewManagerConnection::CanDeleteNode(const NodeId& node_id) const { |
| 157 return node_id.connection_id == id_; |
| 158 } |
| 159 |
| 160 bool ViewManagerConnection::CanDeleteView(const ViewId& view_id) const { |
| 161 return view_id.connection_id == id_; |
| 162 } |
| 163 |
156 bool ViewManagerConnection::DeleteNodeImpl(ViewManagerConnection* source, | 164 bool ViewManagerConnection::DeleteNodeImpl(ViewManagerConnection* source, |
157 const NodeId& node_id) { | 165 const NodeId& node_id) { |
158 DCHECK_EQ(node_id.connection_id, id_); | 166 DCHECK_EQ(node_id.connection_id, id_); |
159 Node* node = GetNode(node_id); | 167 Node* node = GetNode(node_id); |
160 if (!node) | 168 if (!node) |
161 return false; | 169 return false; |
162 RootNodeManager::ScopedChange change( | 170 RootNodeManager::ScopedChange change( |
163 source, root_node_manager_, | 171 source, root_node_manager_, |
164 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, true); | 172 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, true); |
165 if (node->GetParent()) | 173 if (node->GetParent()) |
(...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
265 } | 273 } |
266 node_map_[node_id.node_id] = new Node(this, node_id); | 274 node_map_[node_id.node_id] = new Node(this, node_id); |
267 callback.Run(true); | 275 callback.Run(true); |
268 } | 276 } |
269 | 277 |
270 void ViewManagerConnection::DeleteNode( | 278 void ViewManagerConnection::DeleteNode( |
271 TransportNodeId transport_node_id, | 279 TransportNodeId transport_node_id, |
272 const Callback<void(bool)>& callback) { | 280 const Callback<void(bool)>& callback) { |
273 AllocationScope allocation_scope; | 281 AllocationScope allocation_scope; |
274 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 282 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
275 ViewManagerConnection* connection = root_node_manager_->GetConnection( | 283 bool did_delete = CanDeleteNode(node_id); |
276 node_id.connection_id); | 284 if (did_delete) { |
277 callback.Run(connection && | 285 ViewManagerConnection* connection = root_node_manager_->GetConnection( |
278 connection->DeleteNodeImpl(this, node_id)); | 286 node_id.connection_id); |
| 287 did_delete = connection && connection->DeleteNodeImpl(this, node_id); |
| 288 } |
| 289 callback.Run(did_delete); |
279 } | 290 } |
280 | 291 |
281 void ViewManagerConnection::AddNode( | 292 void ViewManagerConnection::AddNode( |
282 TransportNodeId parent_id, | 293 TransportNodeId parent_id, |
283 TransportNodeId child_id, | 294 TransportNodeId child_id, |
284 TransportChangeId server_change_id, | 295 TransportChangeId server_change_id, |
285 const Callback<void(bool)>& callback) { | 296 const Callback<void(bool)>& callback) { |
286 bool success = false; | 297 bool success = false; |
287 if (server_change_id == root_node_manager_->next_server_change_id()) { | 298 if (server_change_id == root_node_manager_->next_server_change_id()) { |
288 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); | 299 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); |
(...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
338 return; | 349 return; |
339 } | 350 } |
340 view_map_[view_id.view_id] = new View(view_id); | 351 view_map_[view_id.view_id] = new View(view_id); |
341 callback.Run(true); | 352 callback.Run(true); |
342 } | 353 } |
343 | 354 |
344 void ViewManagerConnection::DeleteView( | 355 void ViewManagerConnection::DeleteView( |
345 TransportViewId transport_view_id, | 356 TransportViewId transport_view_id, |
346 const Callback<void(bool)>& callback) { | 357 const Callback<void(bool)>& callback) { |
347 const ViewId view_id(ViewIdFromTransportId(transport_view_id)); | 358 const ViewId view_id(ViewIdFromTransportId(transport_view_id)); |
348 ViewManagerConnection* connection = root_node_manager_->GetConnection( | 359 bool did_delete = CanDeleteView(view_id); |
349 view_id.connection_id); | 360 if (did_delete) { |
350 callback.Run(connection && connection->DeleteViewImpl(this, view_id)); | 361 ViewManagerConnection* connection = root_node_manager_->GetConnection( |
| 362 view_id.connection_id); |
| 363 did_delete = (connection && connection->DeleteViewImpl(this, view_id)); |
| 364 } |
| 365 callback.Run(did_delete); |
351 } | 366 } |
352 | 367 |
353 void ViewManagerConnection::SetView( | 368 void ViewManagerConnection::SetView( |
354 TransportNodeId transport_node_id, | 369 TransportNodeId transport_node_id, |
355 TransportViewId transport_view_id, | 370 TransportViewId transport_view_id, |
356 const Callback<void(bool)>& callback) { | 371 const Callback<void(bool)>& callback) { |
357 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 372 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
358 callback.Run(SetViewImpl(node_id, ViewIdFromTransportId(transport_view_id))); | 373 callback.Run(SetViewImpl(node_id, ViewIdFromTransportId(transport_view_id))); |
359 } | 374 } |
360 | 375 |
(...skipping 24 matching lines...) Expand all Loading... |
385 | 400 |
386 void ViewManagerConnection::OnNodeViewReplaced(const Node* node, | 401 void ViewManagerConnection::OnNodeViewReplaced(const Node* node, |
387 const View* new_view, | 402 const View* new_view, |
388 const View* old_view) { | 403 const View* old_view) { |
389 root_node_manager_->ProcessNodeViewReplaced(node, new_view, old_view); | 404 root_node_manager_->ProcessNodeViewReplaced(node, new_view, old_view); |
390 } | 405 } |
391 | 406 |
392 } // namespace service | 407 } // namespace service |
393 } // namespace view_manager | 408 } // namespace view_manager |
394 } // namespace mojo | 409 } // namespace mojo |
OLD | NEW |