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

Side by Side Diff: third_party/WebKit/Source/core/dom/MutationObserver.cpp

Issue 1773813007: blink: Rename modules/ method to prefix with get when they collide. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: clash-modules: rebase-fixes Created 4 years, 9 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
OLDNEW
1 /* 1 /*
2 * Copyright (C) 2011 Google Inc. All rights reserved. 2 * Copyright (C) 2011 Google Inc. All rights reserved.
3 * 3 *
4 * Redistribution and use in source and binary forms, with or without 4 * Redistribution and use in source and binary forms, with or without
5 * modification, are permitted provided that the following conditions are 5 * modification, are permitted provided that the following conditions are
6 * met: 6 * met:
7 * 7 *
8 * * Redistributions of source code must retain the above copyright 8 * * Redistributions of source code must retain the above copyright
9 * notice, this list of conditions and the following disclaimer. 9 * notice, this list of conditions and the following disclaimer.
10 * * Redistributions in binary form must reproduce the above 10 * * Redistributions in binary form must reproduce the above
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after
64 , m_priority(s_observerPriority++) 64 , m_priority(s_observerPriority++)
65 { 65 {
66 } 66 }
67 67
68 MutationObserver::~MutationObserver() 68 MutationObserver::~MutationObserver()
69 { 69 {
70 #if !ENABLE(OILPAN) 70 #if !ENABLE(OILPAN)
71 ASSERT(m_registrations.isEmpty()); 71 ASSERT(m_registrations.isEmpty());
72 #endif 72 #endif
73 if (!m_records.isEmpty()) 73 if (!m_records.isEmpty())
74 InspectorInstrumentation::didClearAllMutationRecords(m_callback->executi onContext(), this); 74 InspectorInstrumentation::didClearAllMutationRecords(m_callback->getExec utionContext(), this);
75 } 75 }
76 76
77 void MutationObserver::observe(Node* node, const MutationObserverInit& observerI nit, ExceptionState& exceptionState) 77 void MutationObserver::observe(Node* node, const MutationObserverInit& observerI nit, ExceptionState& exceptionState)
78 { 78 {
79 ASSERT(node); 79 ASSERT(node);
80 80
81 MutationObserverOptions options = 0; 81 MutationObserverOptions options = 0;
82 82
83 if (observerInit.hasAttributeOldValue() && observerInit.attributeOldValue()) 83 if (observerInit.hasAttributeOldValue() && observerInit.attributeOldValue())
84 options |= AttributeOldValue; 84 options |= AttributeOldValue;
(...skipping 43 matching lines...) Expand 10 before | Expand all | Expand 10 after
128 return; 128 return;
129 } 129 }
130 130
131 node->registerMutationObserver(*this, options, attributeFilter); 131 node->registerMutationObserver(*this, options, attributeFilter);
132 } 132 }
133 133
134 MutationRecordVector MutationObserver::takeRecords() 134 MutationRecordVector MutationObserver::takeRecords()
135 { 135 {
136 MutationRecordVector records; 136 MutationRecordVector records;
137 records.swap(m_records); 137 records.swap(m_records);
138 InspectorInstrumentation::didClearAllMutationRecords(m_callback->executionCo ntext(), this); 138 InspectorInstrumentation::didClearAllMutationRecords(m_callback->getExecutio nContext(), this);
139 return records; 139 return records;
140 } 140 }
141 141
142 void MutationObserver::disconnect() 142 void MutationObserver::disconnect()
143 { 143 {
144 m_records.clear(); 144 m_records.clear();
145 InspectorInstrumentation::didClearAllMutationRecords(m_callback->executionCo ntext(), this); 145 InspectorInstrumentation::didClearAllMutationRecords(m_callback->getExecutio nContext(), this);
146 MutationObserverRegistrationSet registrations(m_registrations); 146 MutationObserverRegistrationSet registrations(m_registrations);
147 for (auto& registration : registrations) { 147 for (auto& registration : registrations) {
148 // The registration may be already unregistered while iteration. 148 // The registration may be already unregistered while iteration.
149 // Only call unregister if it is still in the original set. 149 // Only call unregister if it is still in the original set.
150 if (m_registrations.contains(registration)) 150 if (m_registrations.contains(registration))
151 registration->unregister(); 151 registration->unregister();
152 } 152 }
153 ASSERT(m_registrations.isEmpty()); 153 ASSERT(m_registrations.isEmpty());
154 } 154 }
155 155
(...skipping 27 matching lines...) Expand all
183 Microtask::enqueueMicrotask(WTF::bind(&MutationObserver::deliverMutation s)); 183 Microtask::enqueueMicrotask(WTF::bind(&MutationObserver::deliverMutation s));
184 184
185 activeMutationObservers().add(observer); 185 activeMutationObservers().add(observer);
186 } 186 }
187 187
188 void MutationObserver::enqueueMutationRecord(PassRefPtrWillBeRawPtr<MutationReco rd> mutation) 188 void MutationObserver::enqueueMutationRecord(PassRefPtrWillBeRawPtr<MutationReco rd> mutation)
189 { 189 {
190 ASSERT(isMainThread()); 190 ASSERT(isMainThread());
191 m_records.append(mutation); 191 m_records.append(mutation);
192 activateObserver(this); 192 activateObserver(this);
193 InspectorInstrumentation::didEnqueueMutationRecord(m_callback->executionCont ext(), this); 193 InspectorInstrumentation::didEnqueueMutationRecord(m_callback->getExecutionC ontext(), this);
194 } 194 }
195 195
196 void MutationObserver::setHasTransientRegistration() 196 void MutationObserver::setHasTransientRegistration()
197 { 197 {
198 ASSERT(isMainThread()); 198 ASSERT(isMainThread());
199 activateObserver(this); 199 activateObserver(this);
200 } 200 }
201 201
202 WillBeHeapHashSet<RawPtrWillBeMember<Node>> MutationObserver::getObservedNodes() const 202 WillBeHeapHashSet<RawPtrWillBeMember<Node>> MutationObserver::getObservedNodes() const
203 { 203 {
204 WillBeHeapHashSet<RawPtrWillBeMember<Node>> observedNodes; 204 WillBeHeapHashSet<RawPtrWillBeMember<Node>> observedNodes;
205 for (const auto& registration : m_registrations) 205 for (const auto& registration : m_registrations)
206 registration->addRegistrationNodesToSet(observedNodes); 206 registration->addRegistrationNodesToSet(observedNodes);
207 return observedNodes; 207 return observedNodes;
208 } 208 }
209 209
210 bool MutationObserver::shouldBeSuspended() const 210 bool MutationObserver::shouldBeSuspended() const
211 { 211 {
212 return m_callback->executionContext() && m_callback->executionContext()->act iveDOMObjectsAreSuspended(); 212 return m_callback->getExecutionContext() && m_callback->getExecutionContext( )->activeDOMObjectsAreSuspended();
213 } 213 }
214 214
215 void MutationObserver::deliver() 215 void MutationObserver::deliver()
216 { 216 {
217 ASSERT(!shouldBeSuspended()); 217 ASSERT(!shouldBeSuspended());
218 218
219 // Calling clearTransientRegistrations() can modify m_registrations, so it's necessary 219 // Calling clearTransientRegistrations() can modify m_registrations, so it's necessary
220 // to make a copy of the transient registrations before operating on them. 220 // to make a copy of the transient registrations before operating on them.
221 WillBeHeapVector<RawPtrWillBeMember<MutationObserverRegistration>, 1> transi entRegistrations; 221 WillBeHeapVector<RawPtrWillBeMember<MutationObserverRegistration>, 1> transi entRegistrations;
222 for (auto& registration : m_registrations) { 222 for (auto& registration : m_registrations) {
223 if (registration->hasTransientRegistrations()) 223 if (registration->hasTransientRegistrations())
224 transientRegistrations.append(registration); 224 transientRegistrations.append(registration);
225 } 225 }
226 for (size_t i = 0; i < transientRegistrations.size(); ++i) 226 for (size_t i = 0; i < transientRegistrations.size(); ++i)
227 transientRegistrations[i]->clearTransientRegistrations(); 227 transientRegistrations[i]->clearTransientRegistrations();
228 228
229 if (m_records.isEmpty()) 229 if (m_records.isEmpty())
230 return; 230 return;
231 231
232 MutationRecordVector records; 232 MutationRecordVector records;
233 records.swap(m_records); 233 records.swap(m_records);
234 234
235 InspectorInstrumentation::willDeliverMutationRecords(m_callback->executionCo ntext(), this); 235 InspectorInstrumentation::willDeliverMutationRecords(m_callback->getExecutio nContext(), this);
236 m_callback->call(records, this); 236 m_callback->call(records, this);
237 InspectorInstrumentation::didDeliverMutationRecords(m_callback->executionCon text()); 237 InspectorInstrumentation::didDeliverMutationRecords(m_callback->getExecution Context());
238 } 238 }
239 239
240 void MutationObserver::resumeSuspendedObservers() 240 void MutationObserver::resumeSuspendedObservers()
241 { 241 {
242 ASSERT(isMainThread()); 242 ASSERT(isMainThread());
243 if (suspendedMutationObservers().isEmpty()) 243 if (suspendedMutationObservers().isEmpty())
244 return; 244 return;
245 245
246 MutationObserverVector suspended; 246 MutationObserverVector suspended;
247 copyToVector(suspendedMutationObservers(), suspended); 247 copyToVector(suspendedMutationObservers(), suspended);
(...skipping 24 matching lines...) Expand all
272 { 272 {
273 #if ENABLE(OILPAN) 273 #if ENABLE(OILPAN)
274 visitor->trace(m_callback); 274 visitor->trace(m_callback);
275 visitor->trace(m_records); 275 visitor->trace(m_records);
276 visitor->trace(m_registrations); 276 visitor->trace(m_registrations);
277 visitor->trace(m_callback); 277 visitor->trace(m_callback);
278 #endif 278 #endif
279 } 279 }
280 280
281 } // namespace blink 281 } // namespace blink
OLDNEW
« no previous file with comments | « third_party/WebKit/Source/core/dom/MutationCallback.h ('k') | third_party/WebKit/Source/core/dom/Node.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698