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/root_node_manager.h" | 5 #include "mojo/services/view_manager/root_node_manager.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "mojo/services/view_manager/view_manager_connection.h" | 8 #include "mojo/services/view_manager/view_manager_connection.h" |
9 #include "ui/aura/env.h" | 9 #include "ui/aura/env.h" |
10 | 10 |
11 namespace mojo { | 11 namespace mojo { |
12 namespace view_manager { | 12 namespace view_manager { |
13 namespace service { | 13 namespace service { |
14 namespace { | 14 namespace { |
15 | 15 |
16 // Id for the root node. | 16 // Id for the root node. |
17 const TransportConnectionSpecificNodeId kRootId = 1; | 17 const TransportConnectionSpecificNodeId kRootId = 1; |
18 | 18 |
19 // Used to identify an invalid connection. | 19 // Used to identify an invalid connection. |
20 const TransportConnectionId kNoConnection = 0; | 20 const TransportConnectionId kNoConnection = 0; |
21 | 21 |
22 } // namespace | 22 } // namespace |
23 | 23 |
24 RootNodeManager::ScopedChange::ScopedChange( | 24 RootNodeManager::ScopedChange::ScopedChange( |
25 ViewManagerConnection* connection, | 25 ViewManagerConnection* connection, |
26 RootNodeManager* root, | 26 RootNodeManager* root, |
27 RootNodeManager::ChangeType change_type) | 27 RootNodeManager::ChangeType change_type, |
| 28 bool is_delete_node) |
28 : root_(root), | 29 : root_(root), |
29 change_type_(change_type) { | 30 change_type_(change_type) { |
30 root_->PrepareForChange(connection); | 31 root_->PrepareForChange(connection, is_delete_node); |
31 } | 32 } |
32 | 33 |
33 RootNodeManager::ScopedChange::~ScopedChange() { | 34 RootNodeManager::ScopedChange::~ScopedChange() { |
34 root_->FinishChange(change_type_); | 35 root_->FinishChange(change_type_); |
35 } | 36 } |
36 | 37 |
37 RootNodeManager::Context::Context() { | 38 RootNodeManager::Context::Context() { |
38 // Pass in false as native viewport creates the PlatformEventSource. | 39 // Pass in false as native viewport creates the PlatformEventSource. |
39 aura::Env::CreateInstance(false); | 40 aura::Env::CreateInstance(false); |
40 } | 41 } |
41 | 42 |
42 RootNodeManager::Context::~Context() { | 43 RootNodeManager::Context::~Context() { |
43 } | 44 } |
44 | 45 |
45 RootNodeManager::RootNodeManager(Shell* shell) | 46 RootNodeManager::RootNodeManager(Shell* shell) |
46 : next_connection_id_(1), | 47 : next_connection_id_(1), |
47 next_server_change_id_(1), | 48 next_server_change_id_(1), |
48 change_source_(kNoConnection), | 49 change_source_(kNoConnection), |
| 50 is_processing_delete_node_(false), |
49 root_view_manager_(shell, this), | 51 root_view_manager_(shell, this), |
50 root_(this, NodeId(0, kRootId)) { | 52 root_(this, NodeId(0, kRootId)) { |
51 } | 53 } |
52 | 54 |
53 RootNodeManager::~RootNodeManager() { | 55 RootNodeManager::~RootNodeManager() { |
54 // All the connections should have been destroyed. | 56 // All the connections should have been destroyed. |
55 DCHECK(connection_map_.empty()); | 57 DCHECK(connection_map_.empty()); |
56 } | 58 } |
57 | 59 |
58 TransportConnectionId RootNodeManager::GetAndAdvanceNextConnectionId() { | 60 TransportConnectionId RootNodeManager::GetAndAdvanceNextConnectionId() { |
(...skipping 22 matching lines...) Expand all Loading... |
81 return &root_; | 83 return &root_; |
82 ConnectionMap::iterator i = connection_map_.find(id.connection_id); | 84 ConnectionMap::iterator i = connection_map_.find(id.connection_id); |
83 return i == connection_map_.end() ? NULL : i->second->GetNode(id); | 85 return i == connection_map_.end() ? NULL : i->second->GetNode(id); |
84 } | 86 } |
85 | 87 |
86 View* RootNodeManager::GetView(const ViewId& id) { | 88 View* RootNodeManager::GetView(const ViewId& id) { |
87 ConnectionMap::iterator i = connection_map_.find(id.connection_id); | 89 ConnectionMap::iterator i = connection_map_.find(id.connection_id); |
88 return i == connection_map_.end() ? NULL : i->second->GetView(id); | 90 return i == connection_map_.end() ? NULL : i->second->GetView(id); |
89 } | 91 } |
90 | 92 |
91 void RootNodeManager::NotifyNodeHierarchyChanged(const NodeId& node, | 93 void RootNodeManager::ProcessNodeHierarchyChanged(const NodeId& node, |
92 const NodeId& new_parent, | 94 const NodeId& new_parent, |
93 const NodeId& old_parent) { | 95 const NodeId& old_parent) { |
94 // TODO(sky): make a macro for this. | 96 // TODO(sky): make a macro for this. |
95 for (ConnectionMap::iterator i = connection_map_.begin(); | 97 for (ConnectionMap::iterator i = connection_map_.begin(); |
96 i != connection_map_.end(); ++i) { | 98 i != connection_map_.end(); ++i) { |
97 if (ShouldNotifyConnection(i->first)) { | 99 i->second->ProcessNodeHierarchyChanged( |
98 i->second->NotifyNodeHierarchyChanged( | 100 node, new_parent, old_parent, next_server_change_id_, |
99 node, new_parent, old_parent, next_server_change_id_); | 101 IsChangeSource(i->first)); |
100 } | |
101 } | 102 } |
102 } | 103 } |
103 | 104 |
104 void RootNodeManager::NotifyNodeViewReplaced(const NodeId& node, | 105 void RootNodeManager::ProcessNodeViewReplaced(const NodeId& node, |
105 const ViewId& new_view_id, | 106 const ViewId& new_view_id, |
106 const ViewId& old_view_id) { | 107 const ViewId& old_view_id) { |
107 // TODO(sky): make a macro for this. | 108 // TODO(sky): make a macro for this. |
108 for (ConnectionMap::iterator i = connection_map_.begin(); | 109 for (ConnectionMap::iterator i = connection_map_.begin(); |
109 i != connection_map_.end(); ++i) { | 110 i != connection_map_.end(); ++i) { |
110 if (ShouldNotifyConnection(i->first)) | 111 i->second->ProcessNodeViewReplaced(node, new_view_id, old_view_id, |
111 i->second->NotifyNodeViewReplaced(node, new_view_id, old_view_id); | 112 IsChangeSource(i->first)); |
112 } | 113 } |
113 } | 114 } |
114 | 115 |
115 void RootNodeManager::NotifyNodeDeleted(const NodeId& node) { | 116 void RootNodeManager::ProcessNodeDeleted(const NodeId& node) { |
116 // TODO(sky): make a macro for this. | 117 // TODO(sky): make a macro for this. |
117 for (ConnectionMap::iterator i = connection_map_.begin(); | 118 for (ConnectionMap::iterator i = connection_map_.begin(); |
118 i != connection_map_.end(); ++i) { | 119 i != connection_map_.end(); ++i) { |
119 if (ShouldNotifyConnection(i->first)) | 120 i->second->ProcessNodeDeleted(node, next_server_change_id_, |
120 i->second->NotifyNodeDeleted(node, next_server_change_id_); | 121 IsChangeSource(i->first)); |
121 } | 122 } |
122 } | 123 } |
123 | 124 |
124 void RootNodeManager::NotifyViewDeleted(const ViewId& view) { | 125 void RootNodeManager::ProcessViewDeleted(const ViewId& view) { |
125 // TODO(sky): make a macro for this. | 126 // TODO(sky): make a macro for this. |
126 for (ConnectionMap::iterator i = connection_map_.begin(); | 127 for (ConnectionMap::iterator i = connection_map_.begin(); |
127 i != connection_map_.end(); ++i) { | 128 i != connection_map_.end(); ++i) { |
128 if (ShouldNotifyConnection(i->first)) | 129 i->second->ProcessViewDeleted(view, IsChangeSource(i->first)); |
129 i->second->NotifyViewDeleted(view); | |
130 } | 130 } |
131 } | 131 } |
132 | 132 |
133 void RootNodeManager::PrepareForChange(ViewManagerConnection* connection) { | 133 void RootNodeManager::PrepareForChange(ViewManagerConnection* connection, |
| 134 bool is_delete_node) { |
134 // Should only ever have one change in flight. | 135 // Should only ever have one change in flight. |
135 DCHECK_EQ(kNoConnection, change_source_); | 136 DCHECK_EQ(kNoConnection, change_source_); |
136 change_source_ = connection->id(); | 137 change_source_ = connection->id(); |
| 138 is_processing_delete_node_ = is_delete_node; |
137 } | 139 } |
138 | 140 |
139 void RootNodeManager::FinishChange(ChangeType change_type) { | 141 void RootNodeManager::FinishChange(ChangeType change_type) { |
140 // PrepareForChange/FinishChange should be balanced. | 142 // PrepareForChange/FinishChange should be balanced. |
141 DCHECK_NE(kNoConnection, change_source_); | 143 DCHECK_NE(kNoConnection, change_source_); |
142 change_source_ = 0; | 144 change_source_ = 0; |
| 145 is_processing_delete_node_ = false; |
143 if (change_type == CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID) | 146 if (change_type == CHANGE_TYPE_ADVANCE_SERVER_CHANGE_ID) |
144 next_server_change_id_++; | 147 next_server_change_id_++; |
145 } | 148 } |
146 | 149 |
147 bool RootNodeManager::ShouldNotifyConnection( | |
148 TransportConnectionId connection_id) const { | |
149 // Don't notify the source that originated the change. | |
150 return connection_id != change_source_; | |
151 } | |
152 | |
153 void RootNodeManager::OnNodeHierarchyChanged(const NodeId& node, | 150 void RootNodeManager::OnNodeHierarchyChanged(const NodeId& node, |
154 const NodeId& new_parent, | 151 const NodeId& new_parent, |
155 const NodeId& old_parent) { | 152 const NodeId& old_parent) { |
156 if (!root_view_manager_.in_setup()) | 153 if (!root_view_manager_.in_setup()) |
157 NotifyNodeHierarchyChanged(node, new_parent, old_parent); | 154 ProcessNodeHierarchyChanged(node, new_parent, old_parent); |
158 } | 155 } |
159 | 156 |
160 void RootNodeManager::OnNodeViewReplaced(const NodeId& node, | 157 void RootNodeManager::OnNodeViewReplaced(const NodeId& node, |
161 const ViewId& new_view_id, | 158 const ViewId& new_view_id, |
162 const ViewId& old_view_id) { | 159 const ViewId& old_view_id) { |
163 NotifyNodeViewReplaced(node, new_view_id, old_view_id); | 160 ProcessNodeViewReplaced(node, new_view_id, old_view_id); |
164 } | 161 } |
165 | 162 |
166 } // namespace service | 163 } // namespace service |
167 } // namespace view_manager | 164 } // namespace view_manager |
168 } // namespace mojo | 165 } // namespace mojo |
OLD | NEW |