Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(501)

Side by Side Diff: mojo/services/view_manager/view_manager_connection.cc

Issue 275363002: Internalize ServiceConnector<> (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Move ViewManagerConnection initialization to SetClient() Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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
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
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
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
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
OLDNEW
« no previous file with comments | « mojo/services/view_manager/view_manager_connection.h ('k') | mojo/services/view_manager/view_manager_connection_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698