| 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_service_impl.h" | 5 #include "mojo/services/view_manager/view_manager_service_impl.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "mojo/services/public/cpp/geometry/geometry_type_converters.h" | 8 #include "mojo/services/public/cpp/geometry/geometry_type_converters.h" |
| 9 #include "mojo/services/public/cpp/input_events/input_events_type_converters.h" | 9 #include "mojo/services/public/cpp/input_events/input_events_type_converters.h" |
| 10 #include "mojo/services/view_manager/node.h" | 10 #include "mojo/services/view_manager/node.h" |
| (...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 53 | 53 |
| 54 ViewManagerServiceImpl::~ViewManagerServiceImpl() { | 54 ViewManagerServiceImpl::~ViewManagerServiceImpl() { |
| 55 // Delete any views we created. | 55 // Delete any views we created. |
| 56 while (!view_map_.empty()) { | 56 while (!view_map_.empty()) { |
| 57 bool result = DeleteViewImpl(this, view_map_.begin()->second->id()); | 57 bool result = DeleteViewImpl(this, view_map_.begin()->second->id()); |
| 58 DCHECK(result); | 58 DCHECK(result); |
| 59 } | 59 } |
| 60 | 60 |
| 61 // Ditto the nodes. | 61 // Ditto the nodes. |
| 62 if (!node_map_.empty()) { | 62 if (!node_map_.empty()) { |
| 63 RootNodeManager::ScopedChange change( | 63 RootNodeManager::ScopedChange change(this, root_node_manager_, true); |
| 64 this, root_node_manager_, | |
| 65 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, true); | |
| 66 while (!node_map_.empty()) | 64 while (!node_map_.empty()) |
| 67 delete node_map_.begin()->second; | 65 delete node_map_.begin()->second; |
| 68 } | 66 } |
| 69 | 67 |
| 70 root_node_manager_->RemoveConnection(this); | 68 root_node_manager_->RemoveConnection(this); |
| 71 } | 69 } |
| 72 | 70 |
| 73 const Node* ViewManagerServiceImpl::GetNode(const NodeId& id) const { | 71 const Node* ViewManagerServiceImpl::GetNode(const NodeId& id) const { |
| 74 if (id_ == id.connection_id) { | 72 if (id_ == id.connection_id) { |
| 75 NodeMap::const_iterator i = node_map_.find(id.node_id); | 73 NodeMap::const_iterator i = node_map_.find(id.node_id); |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 108 client()->OnNodeBoundsChanged(node_id, | 106 client()->OnNodeBoundsChanged(node_id, |
| 109 Rect::From(old_bounds), | 107 Rect::From(old_bounds), |
| 110 Rect::From(new_bounds)); | 108 Rect::From(new_bounds)); |
| 111 } | 109 } |
| 112 } | 110 } |
| 113 | 111 |
| 114 void ViewManagerServiceImpl::ProcessNodeHierarchyChanged( | 112 void ViewManagerServiceImpl::ProcessNodeHierarchyChanged( |
| 115 const Node* node, | 113 const Node* node, |
| 116 const Node* new_parent, | 114 const Node* new_parent, |
| 117 const Node* old_parent, | 115 const Node* old_parent, |
| 118 Id server_change_id, | |
| 119 bool originated_change) { | 116 bool originated_change) { |
| 120 if (known_nodes_.count(NodeIdToTransportId(node->id())) > 0) { | 117 if (known_nodes_.count(NodeIdToTransportId(node->id())) > 0) { |
| 121 if (originated_change) | 118 if (originated_change) |
| 122 return; | 119 return; |
| 123 if (node->id().connection_id != id_ && !IsNodeDescendantOfRoots(node)) { | 120 if (node->id().connection_id != id_ && !IsNodeDescendantOfRoots(node)) { |
| 124 // Node was a descendant of roots and is no longer, treat it as though the | 121 // Node was a descendant of roots and is no longer, treat it as though the |
| 125 // node was deleted. | 122 // node was deleted. |
| 126 RemoveFromKnown(node, NULL); | 123 RemoveFromKnown(node, NULL); |
| 127 client()->OnNodeDeleted(NodeIdToTransportId(node->id()), | 124 client()->OnNodeDeleted(NodeIdToTransportId(node->id())); |
| 128 server_change_id); | |
| 129 root_node_manager_->OnConnectionMessagedClient(id_); | 125 root_node_manager_->OnConnectionMessagedClient(id_); |
| 130 return; | 126 return; |
| 131 } | 127 } |
| 132 } | 128 } |
| 133 | 129 |
| 134 if (originated_change || root_node_manager_->is_processing_delete_node()) | 130 if (originated_change || root_node_manager_->is_processing_delete_node()) |
| 135 return; | 131 return; |
| 136 std::vector<const Node*> to_send; | 132 std::vector<const Node*> to_send; |
| 137 if (!ShouldNotifyOnHierarchyChange(node, &new_parent, &old_parent, | 133 if (!ShouldNotifyOnHierarchyChange(node, &new_parent, &old_parent, |
| 138 &to_send)) { | 134 &to_send)) { |
| 139 if (root_node_manager_->IsProcessingChange()) { | |
| 140 client()->OnServerChangeIdAdvanced( | |
| 141 root_node_manager_->next_server_change_id() + 1); | |
| 142 } | |
| 143 return; | 135 return; |
| 144 } | 136 } |
| 145 const NodeId new_parent_id(new_parent ? new_parent->id() : NodeId()); | 137 const NodeId new_parent_id(new_parent ? new_parent->id() : NodeId()); |
| 146 const NodeId old_parent_id(old_parent ? old_parent->id() : NodeId()); | 138 const NodeId old_parent_id(old_parent ? old_parent->id() : NodeId()); |
| 147 DCHECK((node->id().connection_id == id_) || | 139 DCHECK((node->id().connection_id == id_) || |
| 148 (roots_.count(NodeIdToTransportId(node->id())) > 0) || | 140 (roots_.count(NodeIdToTransportId(node->id())) > 0) || |
| 149 (new_parent && IsNodeDescendantOfRoots(new_parent)) || | 141 (new_parent && IsNodeDescendantOfRoots(new_parent)) || |
| 150 (old_parent && IsNodeDescendantOfRoots(old_parent))); | 142 (old_parent && IsNodeDescendantOfRoots(old_parent))); |
| 151 client()->OnNodeHierarchyChanged(NodeIdToTransportId(node->id()), | 143 client()->OnNodeHierarchyChanged(NodeIdToTransportId(node->id()), |
| 152 NodeIdToTransportId(new_parent_id), | 144 NodeIdToTransportId(new_parent_id), |
| 153 NodeIdToTransportId(old_parent_id), | 145 NodeIdToTransportId(old_parent_id), |
| 154 server_change_id, | |
| 155 NodesToNodeDatas(to_send)); | 146 NodesToNodeDatas(to_send)); |
| 156 } | 147 } |
| 157 | 148 |
| 158 void ViewManagerServiceImpl::ProcessNodeReorder(const Node* node, | 149 void ViewManagerServiceImpl::ProcessNodeReorder(const Node* node, |
| 159 const Node* relative_node, | 150 const Node* relative_node, |
| 160 OrderDirection direction, | 151 OrderDirection direction, |
| 161 Id server_change_id, | |
| 162 bool originated_change) { | 152 bool originated_change) { |
| 163 if (originated_change || | 153 if (originated_change || |
| 164 !known_nodes_.count(NodeIdToTransportId(node->id())) || | 154 !known_nodes_.count(NodeIdToTransportId(node->id())) || |
| 165 !known_nodes_.count(NodeIdToTransportId(relative_node->id()))) { | 155 !known_nodes_.count(NodeIdToTransportId(relative_node->id()))) { |
| 166 return; | 156 return; |
| 167 } | 157 } |
| 168 | 158 |
| 169 client()->OnNodeReordered(NodeIdToTransportId(node->id()), | 159 client()->OnNodeReordered(NodeIdToTransportId(node->id()), |
| 170 NodeIdToTransportId(relative_node->id()), | 160 NodeIdToTransportId(relative_node->id()), |
| 171 direction, | 161 direction); |
| 172 server_change_id); | |
| 173 } | 162 } |
| 174 | 163 |
| 175 void ViewManagerServiceImpl::ProcessNodeViewReplaced( | 164 void ViewManagerServiceImpl::ProcessNodeViewReplaced( |
| 176 const Node* node, | 165 const Node* node, |
| 177 const View* new_view, | 166 const View* new_view, |
| 178 const View* old_view, | 167 const View* old_view, |
| 179 bool originated_change) { | 168 bool originated_change) { |
| 180 if (originated_change || !known_nodes_.count(NodeIdToTransportId(node->id()))) | 169 if (originated_change || !known_nodes_.count(NodeIdToTransportId(node->id()))) |
| 181 return; | 170 return; |
| 182 const Id new_view_id = new_view ? | 171 const Id new_view_id = new_view ? |
| 183 ViewIdToTransportId(new_view->id()) : 0; | 172 ViewIdToTransportId(new_view->id()) : 0; |
| 184 const Id old_view_id = old_view ? | 173 const Id old_view_id = old_view ? |
| 185 ViewIdToTransportId(old_view->id()) : 0; | 174 ViewIdToTransportId(old_view->id()) : 0; |
| 186 client()->OnNodeViewReplaced(NodeIdToTransportId(node->id()), | 175 client()->OnNodeViewReplaced(NodeIdToTransportId(node->id()), |
| 187 new_view_id, old_view_id); | 176 new_view_id, old_view_id); |
| 188 } | 177 } |
| 189 | 178 |
| 190 void ViewManagerServiceImpl::ProcessNodeDeleted(const NodeId& node, | 179 void ViewManagerServiceImpl::ProcessNodeDeleted(const NodeId& node, |
| 191 Id server_change_id, | |
| 192 bool originated_change) { | 180 bool originated_change) { |
| 193 node_map_.erase(node.node_id); | 181 node_map_.erase(node.node_id); |
| 194 | 182 |
| 195 const bool in_known = known_nodes_.erase(NodeIdToTransportId(node)) > 0; | 183 const bool in_known = known_nodes_.erase(NodeIdToTransportId(node)) > 0; |
| 196 const bool in_roots = roots_.erase(NodeIdToTransportId(node)) > 0; | 184 const bool in_roots = roots_.erase(NodeIdToTransportId(node)) > 0; |
| 197 | 185 |
| 198 if (in_roots && roots_.empty()) | 186 if (in_roots && roots_.empty()) |
| 199 roots_.insert(NodeIdToTransportId(InvalidNodeId())); | 187 roots_.insert(NodeIdToTransportId(InvalidNodeId())); |
| 200 | 188 |
| 201 if (originated_change) | 189 if (originated_change) |
| 202 return; | 190 return; |
| 203 | 191 |
| 204 if (in_known) { | 192 if (in_known) { |
| 205 client()->OnNodeDeleted(NodeIdToTransportId(node), server_change_id); | 193 client()->OnNodeDeleted(NodeIdToTransportId(node)); |
| 206 root_node_manager_->OnConnectionMessagedClient(id_); | 194 root_node_manager_->OnConnectionMessagedClient(id_); |
| 207 } else if (root_node_manager_->IsProcessingChange() && | 195 } else if (root_node_manager_->IsProcessingChange() && |
| 208 !root_node_manager_->DidConnectionMessageClient(id_)) { | 196 !root_node_manager_->DidConnectionMessageClient(id_)) { |
| 209 client()->OnServerChangeIdAdvanced( | |
| 210 root_node_manager_->next_server_change_id() + 1); | |
| 211 root_node_manager_->OnConnectionMessagedClient(id_); | 197 root_node_manager_->OnConnectionMessagedClient(id_); |
| 212 } | 198 } |
| 213 } | 199 } |
| 214 | 200 |
| 215 void ViewManagerServiceImpl::ProcessViewDeleted(const ViewId& view, | 201 void ViewManagerServiceImpl::ProcessViewDeleted(const ViewId& view, |
| 216 bool originated_change) { | 202 bool originated_change) { |
| 217 if (originated_change) | 203 if (originated_change) |
| 218 return; | 204 return; |
| 219 client()->OnViewDeleted(ViewIdToTransportId(view)); | 205 client()->OnViewDeleted(ViewIdToTransportId(view)); |
| 220 } | 206 } |
| (...skipping 133 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 354 roots_.find(NodeIdToTransportId(node->id())) != roots_.end()) && | 340 roots_.find(NodeIdToTransportId(node->id())) != roots_.end()) && |
| 355 node->IsVisible() != visibile; | 341 node->IsVisible() != visibile; |
| 356 } | 342 } |
| 357 | 343 |
| 358 bool ViewManagerServiceImpl::DeleteNodeImpl(ViewManagerServiceImpl* source, | 344 bool ViewManagerServiceImpl::DeleteNodeImpl(ViewManagerServiceImpl* source, |
| 359 const NodeId& node_id) { | 345 const NodeId& node_id) { |
| 360 DCHECK_EQ(node_id.connection_id, id_); | 346 DCHECK_EQ(node_id.connection_id, id_); |
| 361 Node* node = GetNode(node_id); | 347 Node* node = GetNode(node_id); |
| 362 if (!node) | 348 if (!node) |
| 363 return false; | 349 return false; |
| 364 RootNodeManager::ScopedChange change( | 350 RootNodeManager::ScopedChange change(source, root_node_manager_, true); |
| 365 source, root_node_manager_, | |
| 366 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, true); | |
| 367 delete node; | 351 delete node; |
| 368 return true; | 352 return true; |
| 369 } | 353 } |
| 370 | 354 |
| 371 bool ViewManagerServiceImpl::DeleteViewImpl(ViewManagerServiceImpl* source, | 355 bool ViewManagerServiceImpl::DeleteViewImpl(ViewManagerServiceImpl* source, |
| 372 const ViewId& view_id) { | 356 const ViewId& view_id) { |
| 373 DCHECK_EQ(view_id.connection_id, id_); | 357 DCHECK_EQ(view_id.connection_id, id_); |
| 374 View* view = GetView(view_id); | 358 View* view = GetView(view_id); |
| 375 if (!view) | 359 if (!view) |
| 376 return false; | 360 return false; |
| 377 RootNodeManager::ScopedChange change( | 361 RootNodeManager::ScopedChange change(source, root_node_manager_, false); |
| 378 source, root_node_manager_, | |
| 379 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID, false); | |
| 380 if (view->node()) | 362 if (view->node()) |
| 381 view->node()->SetView(NULL); | 363 view->node()->SetView(NULL); |
| 382 view_map_.erase(view_id.view_id); | 364 view_map_.erase(view_id.view_id); |
| 383 // Make a copy of |view_id| as once we delete view |view_id| may no longer be | 365 // Make a copy of |view_id| as once we delete view |view_id| may no longer be |
| 384 // valid. | 366 // valid. |
| 385 const ViewId view_id_copy(view_id); | 367 const ViewId view_id_copy(view_id); |
| 386 delete view; | 368 delete view; |
| 387 root_node_manager_->ProcessViewDeleted(view_id_copy); | 369 root_node_manager_->ProcessViewDeleted(view_id_copy); |
| 388 return true; | 370 return true; |
| 389 } | 371 } |
| 390 | 372 |
| 391 bool ViewManagerServiceImpl::SetViewImpl(Node* node, const ViewId& view_id) { | 373 bool ViewManagerServiceImpl::SetViewImpl(Node* node, const ViewId& view_id) { |
| 392 DCHECK(node); // CanSetView() should have verified node exists. | 374 DCHECK(node); // CanSetView() should have verified node exists. |
| 393 View* view = GetView(view_id); | 375 View* view = GetView(view_id); |
| 394 RootNodeManager::ScopedChange change( | 376 RootNodeManager::ScopedChange change(this, root_node_manager_, false); |
| 395 this, root_node_manager_, | |
| 396 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID, false); | |
| 397 node->SetView(view); | 377 node->SetView(view); |
| 398 return true; | 378 return true; |
| 399 } | 379 } |
| 400 | 380 |
| 401 void ViewManagerServiceImpl::GetUnknownNodesFrom( | 381 void ViewManagerServiceImpl::GetUnknownNodesFrom( |
| 402 const Node* node, | 382 const Node* node, |
| 403 std::vector<const Node*>* nodes) { | 383 std::vector<const Node*>* nodes) { |
| 404 const Id transport_id = NodeIdToTransportId(node->id()); | 384 const Id transport_id = NodeIdToTransportId(node->id()); |
| 405 if (known_nodes_.count(transport_id) == 1) | 385 if (known_nodes_.count(transport_id) == 1) |
| 406 return; | 386 return; |
| (...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 450 CHECK(roots_.count(transport_node_id) > 0); | 430 CHECK(roots_.count(transport_node_id) > 0); |
| 451 | 431 |
| 452 roots_.erase(transport_node_id); | 432 roots_.erase(transport_node_id); |
| 453 if (roots_.empty()) | 433 if (roots_.empty()) |
| 454 roots_.insert(NodeIdToTransportId(InvalidNodeId())); | 434 roots_.insert(NodeIdToTransportId(InvalidNodeId())); |
| 455 | 435 |
| 456 // No need to do anything if we created the node. | 436 // No need to do anything if we created the node. |
| 457 if (node_id.connection_id == id_) | 437 if (node_id.connection_id == id_) |
| 458 return; | 438 return; |
| 459 | 439 |
| 460 client()->OnNodeDeleted(transport_node_id, | 440 client()->OnNodeDeleted(transport_node_id); |
| 461 root_node_manager_->next_server_change_id()); | |
| 462 root_node_manager_->OnConnectionMessagedClient(id_); | 441 root_node_manager_->OnConnectionMessagedClient(id_); |
| 463 | 442 |
| 464 // This connection no longer knows about the node. Unparent any nodes that | 443 // This connection no longer knows about the node. Unparent any nodes that |
| 465 // were parented to nodes in the root. | 444 // were parented to nodes in the root. |
| 466 std::vector<Node*> local_nodes; | 445 std::vector<Node*> local_nodes; |
| 467 RemoveFromKnown(GetNode(node_id), &local_nodes); | 446 RemoveFromKnown(GetNode(node_id), &local_nodes); |
| 468 for (size_t i = 0; i < local_nodes.size(); ++i) | 447 for (size_t i = 0; i < local_nodes.size(); ++i) |
| 469 local_nodes[i]->GetParent()->Remove(local_nodes[i]); | 448 local_nodes[i]->GetParent()->Remove(local_nodes[i]); |
| 470 } | 449 } |
| 471 | 450 |
| (...skipping 93 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 565 error_code = ERROR_CODE_VALUE_IN_USE; | 544 error_code = ERROR_CODE_VALUE_IN_USE; |
| 566 } else { | 545 } else { |
| 567 node_map_[node_id.node_id] = new Node(root_node_manager_, node_id); | 546 node_map_[node_id.node_id] = new Node(root_node_manager_, node_id); |
| 568 known_nodes_.insert(transport_node_id); | 547 known_nodes_.insert(transport_node_id); |
| 569 } | 548 } |
| 570 callback.Run(error_code); | 549 callback.Run(error_code); |
| 571 } | 550 } |
| 572 | 551 |
| 573 void ViewManagerServiceImpl::DeleteNode( | 552 void ViewManagerServiceImpl::DeleteNode( |
| 574 Id transport_node_id, | 553 Id transport_node_id, |
| 575 Id server_change_id, | |
| 576 const Callback<void(bool)>& callback) { | 554 const Callback<void(bool)>& callback) { |
| 577 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 555 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
| 578 bool success = false; | 556 bool success = false; |
| 579 if (server_change_id == root_node_manager_->next_server_change_id() && | 557 if (CanDeleteNode(node_id)) { |
| 580 CanDeleteNode(node_id)) { | |
| 581 ViewManagerServiceImpl* connection = root_node_manager_->GetConnection( | 558 ViewManagerServiceImpl* connection = root_node_manager_->GetConnection( |
| 582 node_id.connection_id); | 559 node_id.connection_id); |
| 583 success = connection && connection->DeleteNodeImpl(this, node_id); | 560 success = connection && connection->DeleteNodeImpl(this, node_id); |
| 584 } | 561 } |
| 585 callback.Run(success); | 562 callback.Run(success); |
| 586 } | 563 } |
| 587 | 564 |
| 588 void ViewManagerServiceImpl::AddNode( | 565 void ViewManagerServiceImpl::AddNode( |
| 589 Id parent_id, | 566 Id parent_id, |
| 590 Id child_id, | 567 Id child_id, |
| 591 Id server_change_id, | |
| 592 const Callback<void(bool)>& callback) { | 568 const Callback<void(bool)>& callback) { |
| 593 bool success = false; | 569 bool success = false; |
| 594 if (server_change_id == root_node_manager_->next_server_change_id()) { | 570 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); |
| 595 Node* parent = GetNode(NodeIdFromTransportId(parent_id)); | 571 Node* child = GetNode(NodeIdFromTransportId(child_id)); |
| 596 Node* child = GetNode(NodeIdFromTransportId(child_id)); | 572 if (CanAddNode(parent, child)) { |
| 597 if (CanAddNode(parent, child)) { | 573 success = true; |
| 598 success = true; | 574 RootNodeManager::ScopedChange change(this, root_node_manager_, false); |
| 599 RootNodeManager::ScopedChange change( | 575 parent->Add(child); |
| 600 this, root_node_manager_, | |
| 601 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, false); | |
| 602 parent->Add(child); | |
| 603 } | |
| 604 } | 576 } |
| 605 callback.Run(success); | 577 callback.Run(success); |
| 606 } | 578 } |
| 607 | 579 |
| 608 void ViewManagerServiceImpl::RemoveNodeFromParent( | 580 void ViewManagerServiceImpl::RemoveNodeFromParent( |
| 609 Id node_id, | 581 Id node_id, |
| 610 Id server_change_id, | |
| 611 const Callback<void(bool)>& callback) { | 582 const Callback<void(bool)>& callback) { |
| 612 bool success = false; | 583 bool success = false; |
| 613 if (server_change_id == root_node_manager_->next_server_change_id()) { | 584 Node* node = GetNode(NodeIdFromTransportId(node_id)); |
| 614 Node* node = GetNode(NodeIdFromTransportId(node_id)); | 585 if (CanRemoveNodeFromParent(node)) { |
| 615 if (CanRemoveNodeFromParent(node)) { | 586 success = true; |
| 616 success = true; | 587 RootNodeManager::ScopedChange change(this, root_node_manager_, false); |
| 617 RootNodeManager::ScopedChange change( | 588 node->GetParent()->Remove(node); |
| 618 this, root_node_manager_, | |
| 619 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, false); | |
| 620 node->GetParent()->Remove(node); | |
| 621 } | |
| 622 } | 589 } |
| 623 callback.Run(success); | 590 callback.Run(success); |
| 624 } | 591 } |
| 625 | 592 |
| 626 void ViewManagerServiceImpl::ReorderNode(Id node_id, | 593 void ViewManagerServiceImpl::ReorderNode(Id node_id, |
| 627 Id relative_node_id, | 594 Id relative_node_id, |
| 628 OrderDirection direction, | 595 OrderDirection direction, |
| 629 Id server_change_id, | |
| 630 const Callback<void(bool)>& callback) { | 596 const Callback<void(bool)>& callback) { |
| 631 bool success = false; | 597 bool success = false; |
| 632 if (server_change_id == root_node_manager_->next_server_change_id()) { | 598 Node* node = GetNode(NodeIdFromTransportId(node_id)); |
| 633 Node* node = GetNode(NodeIdFromTransportId(node_id)); | 599 Node* relative_node = GetNode(NodeIdFromTransportId(relative_node_id)); |
| 634 Node* relative_node = GetNode(NodeIdFromTransportId(relative_node_id)); | 600 if (CanReorderNode(node, relative_node, direction)) { |
| 635 if (CanReorderNode(node, relative_node, direction)) { | 601 success = true; |
| 636 success = true; | 602 RootNodeManager::ScopedChange change(this, root_node_manager_, false); |
| 637 RootNodeManager::ScopedChange change( | 603 node->GetParent()->Reorder(node, relative_node, direction); |
| 638 this, root_node_manager_, | 604 root_node_manager_->ProcessNodeReorder(node, relative_node, direction); |
| 639 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, false); | |
| 640 node->GetParent()->Reorder(node, relative_node, direction); | |
| 641 root_node_manager_->ProcessNodeReorder(node, relative_node, direction); | |
| 642 } | |
| 643 } | 605 } |
| 644 callback.Run(success); | 606 callback.Run(success); |
| 645 } | 607 } |
| 646 | 608 |
| 647 void ViewManagerServiceImpl::GetNodeTree( | 609 void ViewManagerServiceImpl::GetNodeTree( |
| 648 Id node_id, | 610 Id node_id, |
| 649 const Callback<void(Array<NodeDataPtr>)>& callback) { | 611 const Callback<void(Array<NodeDataPtr>)>& callback) { |
| 650 Node* node = GetNode(NodeIdFromTransportId(node_id)); | 612 Node* node = GetNode(NodeIdFromTransportId(node_id)); |
| 651 std::vector<const Node*> nodes; | 613 std::vector<const Node*> nodes; |
| 652 if (CanGetNodeTree(node)) { | 614 if (CanGetNodeTree(node)) { |
| (...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 733 callback.Run(false); | 695 callback.Run(false); |
| 734 return; | 696 return; |
| 735 } | 697 } |
| 736 | 698 |
| 737 Node* node = GetNode(NodeIdFromTransportId(node_id)); | 699 Node* node = GetNode(NodeIdFromTransportId(node_id)); |
| 738 if (!node) { | 700 if (!node) { |
| 739 callback.Run(false); | 701 callback.Run(false); |
| 740 return; | 702 return; |
| 741 } | 703 } |
| 742 | 704 |
| 743 RootNodeManager::ScopedChange change( | 705 RootNodeManager::ScopedChange change(this, root_node_manager_, false); |
| 744 this, root_node_manager_, | |
| 745 RootNodeManager::CHANGE_TYPE_DONT_ADVANCE_SERVER_CHANGE_ID, false); | |
| 746 gfx::Rect old_bounds = node->window()->bounds(); | 706 gfx::Rect old_bounds = node->window()->bounds(); |
| 747 node->window()->SetBounds(bounds.To<gfx::Rect>()); | 707 node->window()->SetBounds(bounds.To<gfx::Rect>()); |
| 748 callback.Run(true); | 708 callback.Run(true); |
| 749 } | 709 } |
| 750 | 710 |
| 751 void ViewManagerServiceImpl::SetNodeVisibility( | 711 void ViewManagerServiceImpl::SetNodeVisibility( |
| 752 Id transport_node_id, | 712 Id transport_node_id, |
| 753 bool visible, | 713 bool visible, |
| 754 const Callback<void(bool)>& callback) { | 714 const Callback<void(bool)>& callback) { |
| 755 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 715 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 770 if (success) { | 730 if (success) { |
| 771 // Only allow a node to be the root for one connection. | 731 // Only allow a node to be the root for one connection. |
| 772 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); | 732 const NodeId node_id(NodeIdFromTransportId(transport_node_id)); |
| 773 ViewManagerServiceImpl* connection_by_url = | 733 ViewManagerServiceImpl* connection_by_url = |
| 774 root_node_manager_->GetConnectionByCreator(id_, url.To<std::string>()); | 734 root_node_manager_->GetConnectionByCreator(id_, url.To<std::string>()); |
| 775 ViewManagerServiceImpl* connection_with_node_as_root = | 735 ViewManagerServiceImpl* connection_with_node_as_root = |
| 776 root_node_manager_->GetConnectionWithRoot(node_id); | 736 root_node_manager_->GetConnectionWithRoot(node_id); |
| 777 if ((connection_by_url != connection_with_node_as_root || | 737 if ((connection_by_url != connection_with_node_as_root || |
| 778 (!connection_by_url && !connection_with_node_as_root)) && | 738 (!connection_by_url && !connection_with_node_as_root)) && |
| 779 (!connection_by_url || !connection_by_url->HasRoot(node_id))) { | 739 (!connection_by_url || !connection_by_url->HasRoot(node_id))) { |
| 780 RootNodeManager::ScopedChange change( | 740 RootNodeManager::ScopedChange change(this, root_node_manager_, true); |
| 781 this, root_node_manager_, | |
| 782 RootNodeManager::CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID, true); | |
| 783 // Never message the originating connection. | 741 // Never message the originating connection. |
| 784 root_node_manager_->OnConnectionMessagedClient(id_); | 742 root_node_manager_->OnConnectionMessagedClient(id_); |
| 785 if (connection_with_node_as_root) | 743 if (connection_with_node_as_root) |
| 786 connection_with_node_as_root->RemoveRoot(node_id); | 744 connection_with_node_as_root->RemoveRoot(node_id); |
| 787 if (connection_by_url) | 745 if (connection_by_url) |
| 788 connection_by_url->AddRoot(node_id); | 746 connection_by_url->AddRoot(node_id); |
| 789 else | 747 else |
| 790 root_node_manager_->Embed(id_, url, transport_node_id); | 748 root_node_manager_->Embed(id_, url, transport_node_id); |
| 791 change.SendServerChangeIdAdvanced(); | |
| 792 } else { | 749 } else { |
| 793 success = false; | 750 success = false; |
| 794 } | 751 } |
| 795 } | 752 } |
| 796 callback.Run(success); | 753 callback.Run(success); |
| 797 } | 754 } |
| 798 | 755 |
| 799 void ViewManagerServiceImpl::DispatchOnViewInputEvent(Id transport_view_id, | 756 void ViewManagerServiceImpl::DispatchOnViewInputEvent(Id transport_view_id, |
| 800 EventPtr event) { | 757 EventPtr event) { |
| 801 // We only allow the WM to dispatch events. At some point this function will | 758 // We only allow the WM to dispatch events. At some point this function will |
| (...skipping 19 matching lines...) Expand all Loading... |
| 821 if (roots_.empty()) { | 778 if (roots_.empty()) { |
| 822 GetUnknownNodesFrom(root_node_manager_->root(), &to_send); | 779 GetUnknownNodesFrom(root_node_manager_->root(), &to_send); |
| 823 } else { | 780 } else { |
| 824 for (NodeIdSet::const_iterator i = roots_.begin(); i != roots_.end(); ++i) | 781 for (NodeIdSet::const_iterator i = roots_.begin(); i != roots_.end(); ++i) |
| 825 GetUnknownNodesFrom(GetNode(NodeIdFromTransportId(*i)), &to_send); | 782 GetUnknownNodesFrom(GetNode(NodeIdFromTransportId(*i)), &to_send); |
| 826 } | 783 } |
| 827 | 784 |
| 828 client()->OnViewManagerConnectionEstablished( | 785 client()->OnViewManagerConnectionEstablished( |
| 829 id_, | 786 id_, |
| 830 creator_url_, | 787 creator_url_, |
| 831 root_node_manager_->next_server_change_id(), | |
| 832 NodesToNodeDatas(to_send)); | 788 NodesToNodeDatas(to_send)); |
| 833 } | 789 } |
| 834 | 790 |
| 835 } // namespace service | 791 } // namespace service |
| 836 } // namespace view_manager | 792 } // namespace view_manager |
| 837 } // namespace mojo | 793 } // namespace mojo |
| OLD | NEW |