Function cleanupWorker

apps/sim/lib/execution/isolated-vm.ts:840–872

(workerId: number)

}

function cleanupWorker(workerId: number) {
  const workerInfo = workers.get(workerId)
  if (!workerInfo) return

  if (workerInfo.idleTimeout) {
    clearTimeout(workerInfo.idleTimeout)
  }

  workerInfo.process.kill()

  for (const [id, pending] of workerInfo.pendingExecutions) {
    clearTimeout(pending.timeout)
    totalActiveExecutions--
    const owner = ownerStates.get(pending.ownerKey)
    if (owner) {
      owner.activeExecutions = Math.max(0, owner.activeExecutions - 1)
      maybeCleanupOwner(owner.ownerKey)
    }
    pending.resolve({
      result: null,
      stdout: '',
      error: {
        message: 'Code execution failed unexpectedly. Please try again.',
        name: 'Error',
        isSystemError: true,
      },
    })
    workerInfo.pendingExecutions.delete(id)
  }
  workerInfo.activeExecutions = 0

  workers.delete(workerId)
}

function resetWorkerIdleTimeout(workerId: number) {
  const workerInfo = workers.get(workerId)