| 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 |