Function selectOwnerForDispatch

apps/sim/lib/execution/isolated-vm.ts:565–608

()

}

function selectOwnerForDispatch(): OwnerState | null {
  if (queuedOwnerRing.length === 0) return null

  let visited = 0
  while (queuedOwnerRing.length > 0 && visited < queuedOwnerRing.length) {
    if (queuedOwnerCursor >= queuedOwnerRing.length) {
      queuedOwnerCursor = 0
    }
    const ownerKey = queuedOwnerRing[queuedOwnerCursor]
    if (!ownerKey) return null

    const owner = ownerStates.get(ownerKey)
    if (!owner) {
      removeOwnerFromRing(ownerKey)
      continue
    }

    if (owner.queueLength === 0) {
      owner.burstRemaining = 0
      removeOwnerFromRing(ownerKey)
      continue
    }

    if (owner.activeExecutions >= MAX_ACTIVE_PER_OWNER) {
      owner.burstRemaining = 0
      queuedOwnerCursor = (queuedOwnerCursor + 1) % queuedOwnerRing.length
      visited++
      continue
    }

    if (owner.burstRemaining <= 0) {
      owner.burstRemaining = owner.weight
    }

    owner.burstRemaining--
    if (owner.burstRemaining <= 0) {
      queuedOwnerCursor = (queuedOwnerCursor + 1) % queuedOwnerRing.length
    }

    return owner
  }

  return null
}

function scheduleDrainRetry() {
  if (queueDrainRetryTimeout || queueSize === 0) return