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

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

Issue 242123005: Allow posting a Task to Microtasks (Closed) Base URL: svn://svn.chromium.org/blink/trunk
Patch Set: changes made Created 6 years, 8 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 /* 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 168 matching lines...) Expand 10 before | Expand all | Expand 10 after
179 179
180 static MutationObserverSet& suspendedMutationObservers() 180 static MutationObserverSet& suspendedMutationObservers()
181 { 181 {
182 DEFINE_STATIC_LOCAL(MutationObserverSet, suspendedObservers, ()); 182 DEFINE_STATIC_LOCAL(MutationObserverSet, suspendedObservers, ());
183 return suspendedObservers; 183 return suspendedObservers;
184 } 184 }
185 185
186 static void activateObserver(PassRefPtr<MutationObserver> observer) 186 static void activateObserver(PassRefPtr<MutationObserver> observer)
187 { 187 {
188 if (activeMutationObservers().isEmpty()) 188 if (activeMutationObservers().isEmpty())
189 Microtask::enqueueMicrotask(&MutationObserver::deliverMutations); 189 Microtask::enqueueMicrotask(WTF::bind(&MutationObserver::deliverMutation s));
190 190
191 activeMutationObservers().add(observer); 191 activeMutationObservers().add(observer);
192 } 192 }
193 193
194 void MutationObserver::enqueueMutationRecord(PassRefPtr<MutationRecord> mutation ) 194 void MutationObserver::enqueueMutationRecord(PassRefPtr<MutationRecord> mutation )
195 { 195 {
196 ASSERT(isMainThread()); 196 ASSERT(isMainThread());
197 m_records.append(mutation); 197 m_records.append(mutation);
198 activateObserver(this); 198 activateObserver(this);
199 InspectorInstrumentation::didEnqueueMutationRecord(m_callback->executionCont ext(), this); 199 InspectorInstrumentation::didEnqueueMutationRecord(m_callback->executionCont ext(), this);
(...skipping 68 matching lines...) Expand 10 before | Expand all | Expand 10 after
268 std::sort(observers.begin(), observers.end(), ObserverLessThan()); 268 std::sort(observers.begin(), observers.end(), ObserverLessThan());
269 for (size_t i = 0; i < observers.size(); ++i) { 269 for (size_t i = 0; i < observers.size(); ++i) {
270 if (observers[i]->canDeliver()) 270 if (observers[i]->canDeliver())
271 observers[i]->deliver(); 271 observers[i]->deliver();
272 else 272 else
273 suspendedMutationObservers().add(observers[i]); 273 suspendedMutationObservers().add(observers[i]);
274 } 274 }
275 } 275 }
276 276
277 } // namespace WebCore 277 } // namespace WebCore
OLDNEW
« no previous file with comments | « Source/core/dom/Microtask.cpp ('k') | Source/core/dom/custom/CustomElementMicrotaskDispatcher.cpp » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698