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