ext/node/polyfills/cluster.ts - main - githubmirror/deno

ext/node/polyfills/cluster.ts
94 строки2 KB
Kenta Moriuchi
chore: make prefer-primordials lint an internal plugin (#35978)
23 июл 2026, 11:53
23 июл 2026, 11:535b55d08
// Copyright 2018-2026 the Deno authors. MIT license.
// Copyright Joyent and Node contributors. All rights reserved. MIT license.

// Mirrors lib/cluster.js. Node decides at module-load whether to require
// `internal/cluster/primary` or `internal/cluster/child` from
// process.env.NODE_UNIQUE_ID. In Deno, the IIFE initializes the primary side
// at module load, and `01_require.js`'s `initialize` flips to the child side
// via the `__initCluster` callback (after triggering this script when
// NODE_UNIQUE_ID is set).

// TODO(petamoriken): enable prefer-primordials for node polyfills
// deno-lint-ignore-file no-explicit-any deno-internal/prefer-primordials

(function () {
const { core, internals } = __bootstrap;
const { EventEmitter } = core.loadExtScript("ext:deno_node/_events.mjs");
const { init: initPrimary } = core.loadExtScript(
  "ext:deno_node/internal/cluster/primary.ts",
);
const { init: initChild } = core.loadExtScript(
  "ext:deno_node/internal/cluster/child.ts",
);

const cluster: any = new EventEmitter();
initPrimary(cluster);

internals.__initCluster = (
  uniqueId: string,
  schedPolicyEnv: string | undefined,
) => {
  if (typeof uniqueId !== "string" || uniqueId.length === 0) {
    return;
  }

  initChild(cluster);

  if (typeof schedPolicyEnv === "string" && schedPolicyEnv.length > 0) {
    if (schedPolicyEnv === "rr") {
      cluster.schedulingPolicy = cluster.SCHED_RR;
    } else if (schedPolicyEnv === "none") {
      cluster.schedulingPolicy = cluster.SCHED_NONE;
    } else {
      const n = Number(schedPolicyEnv);
      if (!Number.isNaN(n)) {
        cluster.schedulingPolicy = n;
      }
    }
  }

  cluster._setupWorker();
};

// Use getters so consumers see the current value of `cluster.*` even after
// `__initCluster` has flipped the EventEmitter to the child side.
return {
  default: cluster,
  Worker: cluster.Worker,
  SCHED_NONE: cluster.SCHED_NONE,
  SCHED_RR: cluster.SCHED_RR,
  get isPrimary() {
    return cluster.isPrimary;
  },
  get isMaster() {
    return cluster.isMaster;
  },
  get isWorker() {
    return cluster.isWorker;
  },
  get workers() {
    return cluster.workers;
  },
  get settings() {
    return cluster.settings;
  },
  get schedulingPolicy() {
    return cluster.schedulingPolicy;
  },
  get fork() {
    return cluster.fork;
  },
  get disconnect() {
    return cluster.disconnect;
  },
  get setupPrimary() {
    return cluster.setupPrimary;
  },
  get setupMaster() {
    return cluster.setupMaster;
  },
  get worker() {
    return cluster.worker;
  },
};
})();