123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665 |
- /** @license React v0.20.2
- * scheduler-unstable_mock.development.js
- *
- * Copyright (c) Facebook, Inc. and its affiliates.
- *
- * This source code is licensed under the MIT license found in the
- * LICENSE file in the root directory of this source tree.
- */
- 'use strict';
- if (process.env.NODE_ENV !== "production") {
- (function() {
- 'use strict';
- var enableSchedulerDebugging = false;
- var enableProfiling = false;
- var currentTime = 0;
- var scheduledCallback = null;
- var scheduledTimeout = null;
- var timeoutTime = -1;
- var yieldedValues = null;
- var expectedNumberOfYields = -1;
- var didStop = false;
- var isFlushing = false;
- var needsPaint = false;
- var shouldYieldForPaint = false;
- function requestHostCallback(callback) {
- scheduledCallback = callback;
- }
- function requestHostTimeout(callback, ms) {
- scheduledTimeout = callback;
- timeoutTime = currentTime + ms;
- }
- function cancelHostTimeout() {
- scheduledTimeout = null;
- timeoutTime = -1;
- }
- function shouldYieldToHost() {
- if (expectedNumberOfYields !== -1 && yieldedValues !== null && yieldedValues.length >= expectedNumberOfYields || shouldYieldForPaint && needsPaint) {
- // We yielded at least as many values as expected. Stop flushing.
- didStop = true;
- return true;
- }
- return false;
- }
- function getCurrentTime() {
- return currentTime;
- }
- function forceFrameRate() {// No-op
- }
- function unstable_flushNumberOfYields(count) {
- if (isFlushing) {
- throw new Error('Already flushing work.');
- }
- if (scheduledCallback !== null) {
- var cb = scheduledCallback;
- expectedNumberOfYields = count;
- isFlushing = true;
- try {
- var hasMoreWork = true;
- do {
- hasMoreWork = cb(true, currentTime);
- } while (hasMoreWork && !didStop);
- if (!hasMoreWork) {
- scheduledCallback = null;
- }
- } finally {
- expectedNumberOfYields = -1;
- didStop = false;
- isFlushing = false;
- }
- }
- }
- function unstable_flushUntilNextPaint() {
- if (isFlushing) {
- throw new Error('Already flushing work.');
- }
- if (scheduledCallback !== null) {
- var cb = scheduledCallback;
- shouldYieldForPaint = true;
- needsPaint = false;
- isFlushing = true;
- try {
- var hasMoreWork = true;
- do {
- hasMoreWork = cb(true, currentTime);
- } while (hasMoreWork && !didStop);
- if (!hasMoreWork) {
- scheduledCallback = null;
- }
- } finally {
- shouldYieldForPaint = false;
- didStop = false;
- isFlushing = false;
- }
- }
- }
- function unstable_flushExpired() {
- if (isFlushing) {
- throw new Error('Already flushing work.');
- }
- if (scheduledCallback !== null) {
- isFlushing = true;
- try {
- var hasMoreWork = scheduledCallback(false, currentTime);
- if (!hasMoreWork) {
- scheduledCallback = null;
- }
- } finally {
- isFlushing = false;
- }
- }
- }
- function unstable_flushAllWithoutAsserting() {
- // Returns false if no work was flushed.
- if (isFlushing) {
- throw new Error('Already flushing work.');
- }
- if (scheduledCallback !== null) {
- var cb = scheduledCallback;
- isFlushing = true;
- try {
- var hasMoreWork = true;
- do {
- hasMoreWork = cb(true, currentTime);
- } while (hasMoreWork);
- if (!hasMoreWork) {
- scheduledCallback = null;
- }
- return true;
- } finally {
- isFlushing = false;
- }
- } else {
- return false;
- }
- }
- function unstable_clearYields() {
- if (yieldedValues === null) {
- return [];
- }
- var values = yieldedValues;
- yieldedValues = null;
- return values;
- }
- function unstable_flushAll() {
- if (yieldedValues !== null) {
- throw new Error('Log is not empty. Assert on the log of yielded values before ' + 'flushing additional work.');
- }
- unstable_flushAllWithoutAsserting();
- if (yieldedValues !== null) {
- throw new Error('While flushing work, something yielded a value. Use an ' + 'assertion helper to assert on the log of yielded values, e.g. ' + 'expect(Scheduler).toFlushAndYield([...])');
- }
- }
- function unstable_yieldValue(value) {
- // eslint-disable-next-line react-internal/no-production-logging
- if (console.log.name === 'disabledLog') {
- // If console.log has been patched, we assume we're in render
- // replaying and we ignore any values yielding in the second pass.
- return;
- }
- if (yieldedValues === null) {
- yieldedValues = [value];
- } else {
- yieldedValues.push(value);
- }
- }
- function unstable_advanceTime(ms) {
- // eslint-disable-next-line react-internal/no-production-logging
- if (console.log.name === 'disabledLog') {
- // If console.log has been patched, we assume we're in render
- // replaying and we ignore any time advancing in the second pass.
- return;
- }
- currentTime += ms;
- if (scheduledTimeout !== null && timeoutTime <= currentTime) {
- scheduledTimeout(currentTime);
- timeoutTime = -1;
- scheduledTimeout = null;
- }
- }
- function requestPaint() {
- needsPaint = true;
- }
- function push(heap, node) {
- var index = heap.length;
- heap.push(node);
- siftUp(heap, node, index);
- }
- function peek(heap) {
- var first = heap[0];
- return first === undefined ? null : first;
- }
- function pop(heap) {
- var first = heap[0];
- if (first !== undefined) {
- var last = heap.pop();
- if (last !== first) {
- heap[0] = last;
- siftDown(heap, last, 0);
- }
- return first;
- } else {
- return null;
- }
- }
- function siftUp(heap, node, i) {
- var index = i;
- while (true) {
- var parentIndex = index - 1 >>> 1;
- var parent = heap[parentIndex];
- if (parent !== undefined && compare(parent, node) > 0) {
- // The parent is larger. Swap positions.
- heap[parentIndex] = node;
- heap[index] = parent;
- index = parentIndex;
- } else {
- // The parent is smaller. Exit.
- return;
- }
- }
- }
- function siftDown(heap, node, i) {
- var index = i;
- var length = heap.length;
- while (index < length) {
- var leftIndex = (index + 1) * 2 - 1;
- var left = heap[leftIndex];
- var rightIndex = leftIndex + 1;
- var right = heap[rightIndex]; // If the left or right node is smaller, swap with the smaller of those.
- if (left !== undefined && compare(left, node) < 0) {
- if (right !== undefined && compare(right, left) < 0) {
- heap[index] = right;
- heap[rightIndex] = node;
- index = rightIndex;
- } else {
- heap[index] = left;
- heap[leftIndex] = node;
- index = leftIndex;
- }
- } else if (right !== undefined && compare(right, node) < 0) {
- heap[index] = right;
- heap[rightIndex] = node;
- index = rightIndex;
- } else {
- // Neither child is smaller. Exit.
- return;
- }
- }
- }
- function compare(a, b) {
- // Compare sort index first, then task id.
- var diff = a.sortIndex - b.sortIndex;
- return diff !== 0 ? diff : a.id - b.id;
- }
- // TODO: Use symbols?
- var ImmediatePriority = 1;
- var UserBlockingPriority = 2;
- var NormalPriority = 3;
- var LowPriority = 4;
- var IdlePriority = 5;
- function markTaskErrored(task, ms) {
- }
- /* eslint-disable no-var */
- // Math.pow(2, 30) - 1
- // 0b111111111111111111111111111111
- var maxSigned31BitInt = 1073741823; // Times out immediately
- var IMMEDIATE_PRIORITY_TIMEOUT = -1; // Eventually times out
- var USER_BLOCKING_PRIORITY_TIMEOUT = 250;
- var NORMAL_PRIORITY_TIMEOUT = 5000;
- var LOW_PRIORITY_TIMEOUT = 10000; // Never times out
- var IDLE_PRIORITY_TIMEOUT = maxSigned31BitInt; // Tasks are stored on a min heap
- var taskQueue = [];
- var timerQueue = []; // Incrementing id counter. Used to maintain insertion order.
- var taskIdCounter = 1; // Pausing the scheduler is useful for debugging.
- var currentTask = null;
- var currentPriorityLevel = NormalPriority; // This is set while performing work, to prevent re-entrancy.
- var isPerformingWork = false;
- var isHostCallbackScheduled = false;
- var isHostTimeoutScheduled = false;
- function advanceTimers(currentTime) {
- // Check for tasks that are no longer delayed and add them to the queue.
- var timer = peek(timerQueue);
- while (timer !== null) {
- if (timer.callback === null) {
- // Timer was cancelled.
- pop(timerQueue);
- } else if (timer.startTime <= currentTime) {
- // Timer fired. Transfer to the task queue.
- pop(timerQueue);
- timer.sortIndex = timer.expirationTime;
- push(taskQueue, timer);
- } else {
- // Remaining timers are pending.
- return;
- }
- timer = peek(timerQueue);
- }
- }
- function handleTimeout(currentTime) {
- isHostTimeoutScheduled = false;
- advanceTimers(currentTime);
- if (!isHostCallbackScheduled) {
- if (peek(taskQueue) !== null) {
- isHostCallbackScheduled = true;
- requestHostCallback(flushWork);
- } else {
- var firstTimer = peek(timerQueue);
- if (firstTimer !== null) {
- requestHostTimeout(handleTimeout, firstTimer.startTime - currentTime);
- }
- }
- }
- }
- function flushWork(hasTimeRemaining, initialTime) {
- isHostCallbackScheduled = false;
- if (isHostTimeoutScheduled) {
- // We scheduled a timeout but it's no longer needed. Cancel it.
- isHostTimeoutScheduled = false;
- cancelHostTimeout();
- }
- isPerformingWork = true;
- var previousPriorityLevel = currentPriorityLevel;
- try {
- if (enableProfiling) {
- try {
- return workLoop(hasTimeRemaining, initialTime);
- } catch (error) {
- if (currentTask !== null) {
- var currentTime = getCurrentTime();
- markTaskErrored(currentTask, currentTime);
- currentTask.isQueued = false;
- }
- throw error;
- }
- } else {
- // No catch in prod code path.
- return workLoop(hasTimeRemaining, initialTime);
- }
- } finally {
- currentTask = null;
- currentPriorityLevel = previousPriorityLevel;
- isPerformingWork = false;
- }
- }
- function workLoop(hasTimeRemaining, initialTime) {
- var currentTime = initialTime;
- advanceTimers(currentTime);
- currentTask = peek(taskQueue);
- while (currentTask !== null && !(enableSchedulerDebugging )) {
- if (currentTask.expirationTime > currentTime && (!hasTimeRemaining || shouldYieldToHost())) {
- // This currentTask hasn't expired, and we've reached the deadline.
- break;
- }
- var callback = currentTask.callback;
- if (typeof callback === 'function') {
- currentTask.callback = null;
- currentPriorityLevel = currentTask.priorityLevel;
- var didUserCallbackTimeout = currentTask.expirationTime <= currentTime;
- var continuationCallback = callback(didUserCallbackTimeout);
- currentTime = getCurrentTime();
- if (typeof continuationCallback === 'function') {
- currentTask.callback = continuationCallback;
- } else {
- if (currentTask === peek(taskQueue)) {
- pop(taskQueue);
- }
- }
- advanceTimers(currentTime);
- } else {
- pop(taskQueue);
- }
- currentTask = peek(taskQueue);
- } // Return whether there's additional work
- if (currentTask !== null) {
- return true;
- } else {
- var firstTimer = peek(timerQueue);
- if (firstTimer !== null) {
- requestHostTimeout(handleTimeout, firstTimer.startTime - currentTime);
- }
- return false;
- }
- }
- function unstable_runWithPriority(priorityLevel, eventHandler) {
- switch (priorityLevel) {
- case ImmediatePriority:
- case UserBlockingPriority:
- case NormalPriority:
- case LowPriority:
- case IdlePriority:
- break;
- default:
- priorityLevel = NormalPriority;
- }
- var previousPriorityLevel = currentPriorityLevel;
- currentPriorityLevel = priorityLevel;
- try {
- return eventHandler();
- } finally {
- currentPriorityLevel = previousPriorityLevel;
- }
- }
- function unstable_next(eventHandler) {
- var priorityLevel;
- switch (currentPriorityLevel) {
- case ImmediatePriority:
- case UserBlockingPriority:
- case NormalPriority:
- // Shift down to normal priority
- priorityLevel = NormalPriority;
- break;
- default:
- // Anything lower than normal priority should remain at the current level.
- priorityLevel = currentPriorityLevel;
- break;
- }
- var previousPriorityLevel = currentPriorityLevel;
- currentPriorityLevel = priorityLevel;
- try {
- return eventHandler();
- } finally {
- currentPriorityLevel = previousPriorityLevel;
- }
- }
- function unstable_wrapCallback(callback) {
- var parentPriorityLevel = currentPriorityLevel;
- return function () {
- // This is a fork of runWithPriority, inlined for performance.
- var previousPriorityLevel = currentPriorityLevel;
- currentPriorityLevel = parentPriorityLevel;
- try {
- return callback.apply(this, arguments);
- } finally {
- currentPriorityLevel = previousPriorityLevel;
- }
- };
- }
- function unstable_scheduleCallback(priorityLevel, callback, options) {
- var currentTime = getCurrentTime();
- var startTime;
- if (typeof options === 'object' && options !== null) {
- var delay = options.delay;
- if (typeof delay === 'number' && delay > 0) {
- startTime = currentTime + delay;
- } else {
- startTime = currentTime;
- }
- } else {
- startTime = currentTime;
- }
- var timeout;
- switch (priorityLevel) {
- case ImmediatePriority:
- timeout = IMMEDIATE_PRIORITY_TIMEOUT;
- break;
- case UserBlockingPriority:
- timeout = USER_BLOCKING_PRIORITY_TIMEOUT;
- break;
- case IdlePriority:
- timeout = IDLE_PRIORITY_TIMEOUT;
- break;
- case LowPriority:
- timeout = LOW_PRIORITY_TIMEOUT;
- break;
- case NormalPriority:
- default:
- timeout = NORMAL_PRIORITY_TIMEOUT;
- break;
- }
- var expirationTime = startTime + timeout;
- var newTask = {
- id: taskIdCounter++,
- callback: callback,
- priorityLevel: priorityLevel,
- startTime: startTime,
- expirationTime: expirationTime,
- sortIndex: -1
- };
- if (startTime > currentTime) {
- // This is a delayed task.
- newTask.sortIndex = startTime;
- push(timerQueue, newTask);
- if (peek(taskQueue) === null && newTask === peek(timerQueue)) {
- // All tasks are delayed, and this is the task with the earliest delay.
- if (isHostTimeoutScheduled) {
- // Cancel an existing timeout.
- cancelHostTimeout();
- } else {
- isHostTimeoutScheduled = true;
- } // Schedule a timeout.
- requestHostTimeout(handleTimeout, startTime - currentTime);
- }
- } else {
- newTask.sortIndex = expirationTime;
- push(taskQueue, newTask);
- // wait until the next time we yield.
- if (!isHostCallbackScheduled && !isPerformingWork) {
- isHostCallbackScheduled = true;
- requestHostCallback(flushWork);
- }
- }
- return newTask;
- }
- function unstable_pauseExecution() {
- }
- function unstable_continueExecution() {
- if (!isHostCallbackScheduled && !isPerformingWork) {
- isHostCallbackScheduled = true;
- requestHostCallback(flushWork);
- }
- }
- function unstable_getFirstCallbackNode() {
- return peek(taskQueue);
- }
- function unstable_cancelCallback(task) {
- // remove from the queue because you can't remove arbitrary nodes from an
- // array based heap, only the first one.)
- task.callback = null;
- }
- function unstable_getCurrentPriorityLevel() {
- return currentPriorityLevel;
- }
- var unstable_requestPaint = requestPaint;
- var unstable_Profiling = null;
- exports.unstable_IdlePriority = IdlePriority;
- exports.unstable_ImmediatePriority = ImmediatePriority;
- exports.unstable_LowPriority = LowPriority;
- exports.unstable_NormalPriority = NormalPriority;
- exports.unstable_Profiling = unstable_Profiling;
- exports.unstable_UserBlockingPriority = UserBlockingPriority;
- exports.unstable_advanceTime = unstable_advanceTime;
- exports.unstable_cancelCallback = unstable_cancelCallback;
- exports.unstable_clearYields = unstable_clearYields;
- exports.unstable_continueExecution = unstable_continueExecution;
- exports.unstable_flushAll = unstable_flushAll;
- exports.unstable_flushAllWithoutAsserting = unstable_flushAllWithoutAsserting;
- exports.unstable_flushExpired = unstable_flushExpired;
- exports.unstable_flushNumberOfYields = unstable_flushNumberOfYields;
- exports.unstable_flushUntilNextPaint = unstable_flushUntilNextPaint;
- exports.unstable_forceFrameRate = forceFrameRate;
- exports.unstable_getCurrentPriorityLevel = unstable_getCurrentPriorityLevel;
- exports.unstable_getFirstCallbackNode = unstable_getFirstCallbackNode;
- exports.unstable_next = unstable_next;
- exports.unstable_now = getCurrentTime;
- exports.unstable_pauseExecution = unstable_pauseExecution;
- exports.unstable_requestPaint = unstable_requestPaint;
- exports.unstable_runWithPriority = unstable_runWithPriority;
- exports.unstable_scheduleCallback = unstable_scheduleCallback;
- exports.unstable_shouldYield = shouldYieldToHost;
- exports.unstable_wrapCallback = unstable_wrapCallback;
- exports.unstable_yieldValue = unstable_yieldValue;
- })();
- }
|