MCPcopy Create free account
hub / github.com/microsoft/SandDance / enqueue

Function enqueue

docs/app/js/sanddance-app.js:108566–108573  ·  view source on GitHub ↗

* Enqueue an operator into the priority queue for evaluation. The operator * will be enqueued if it has no registered pulse for the current cycle, or if * the force argument is true. Upon enqueue, this method also sets the * operator's qrank to the current rank value. * @param {Operator} op - Th

(op, force)

Source from the content-addressed store, hash-verified

108564 * enqueued during the current pulse propagation. This is useful when the
108565 * dataflow graph is dynamically modified and the operator rank changes.
108566 */ function enqueue(op, force) {
108567 const q = op.stamp < this._clock;
108568 if (q) op.stamp = this._clock;
108569 if (q || force) {
108570 op.qrank = op.rank;
108571 this._heap.push(op);
108572 }
108573}
108574/**
108575 * Provide a correct pulse for evaluating an operator. If the operator has an
108576 * explicit source operator, we will try to pull the pulse(s) from it.

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected