(owner: OwnerState, queued: QueuedExecution)
| 543 | } |
| 544 | |
| 545 | function pushQueuedExecution(owner: OwnerState, queued: QueuedExecution) { |
| 546 | const node: QueueNode = { |
| 547 | ownerKey: owner.ownerKey, |
| 548 | value: queued, |
| 549 | prev: owner.queueTail, |
| 550 | next: null, |
| 551 | } |
| 552 | if (owner.queueTail) { |
| 553 | owner.queueTail.next = node |
| 554 | } else { |
| 555 | owner.queueHead = node |
| 556 | } |
| 557 | owner.queueTail = node |
| 558 | owner.queueLength++ |
| 559 | owner.burstRemaining = 0 |
| 560 | addOwnerToRing(owner.ownerKey) |
| 561 | queueNodes.set(queued.id, node) |
| 562 | queueSize++ |
| 563 | } |
| 564 | |
| 565 | function selectOwnerForDispatch(): OwnerState | null { |
| 566 | if (queuedOwnerRing.length === 0) return null |
no test coverage detected