📁
SKYSHELL MANAGER
PHP v8.3.6
Create
Create
Path:
root
/
var
/
www
/
cstage
/
wp-includes
/
js
/
tinymce
/
themes
/
Name
Size
Perm
Actions
📁
inlite
-
0755
🗑️
🏷️
🔒
📁
modern
-
0755
🗑️
🏷️
🔒
📄
ms-files.php
6.83 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
📄
wp-activate.php
6.83 KB
0444
🗑️
🏷️
⬇️
✏️
🔒
Edit: WorkerAbstract.js
"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.default = void 0; function _stream() { const data = require("stream"); _stream = function () { return data; }; return data; } var _types = require("../types"); /** * Copyright (c) Meta Platforms, Inc. and affiliates. * * This source code is licensed under the MIT license found in the * LICENSE file in the root directory of this source tree. */ class WorkerAbstract extends _stream().EventEmitter { /** * DO NOT WRITE TO THIS DIRECTLY. * Use this.state getter/setters so events are emitted correctly. */ #state = _types.WorkerStates.STARTING; _fakeStream = null; _exitPromise; _resolveExitPromise; _workerReadyPromise; _resolveWorkerReady; get state() { return this.#state; } set state(value) { if (this.#state !== value) { const oldState = this.#state; this.#state = value; this.emit(_types.WorkerEvents.STATE_CHANGE, value, oldState); } } constructor(options) { super(); if (typeof options.on === 'object') { for (const [event, handlers] of Object.entries(options.on)) { // Can't do Array.isArray on a ReadonlyArray<T>. // https://github.com/microsoft/TypeScript/issues/17002 if (typeof handlers === 'function') { super.on(event, handlers); } else { for (const handler of handlers) { super.on(event, handler); } } } } this._exitPromise = new Promise(resolve => { this._resolveExitPromise = resolve; }); this._exitPromise.then(() => { this.state = _types.WorkerStates.SHUT_DOWN; }); } /** * Wait for the worker child process to be ready to handle requests. * * @returns Promise which resolves when ready. */ waitForWorkerReady() { if (!this._workerReadyPromise) { this._workerReadyPromise = new Promise((resolve, reject) => { let settled = false; let to; switch (this.state) { case _types.WorkerStates.OUT_OF_MEMORY: case _types.WorkerStates.SHUTTING_DOWN: case _types.WorkerStates.SHUT_DOWN: settled = true; reject(new Error(`Worker state means it will never be ready: ${this.state}`)); break; case _types.WorkerStates.STARTING: case _types.WorkerStates.RESTARTING: this._resolveWorkerReady = () => { settled = true; resolve(); if (to) { clearTimeout(to); } }; break; case _types.WorkerStates.OK: settled = true; resolve(); break; } if (!settled) { to = setTimeout(() => { if (!settled) { reject(new Error('Timeout starting worker')); } }, 500); } }); } return this._workerReadyPromise; } /** * Used to shut down the current working instance once the children have been * killed off. */ _shutdown() { this.state === _types.WorkerStates.SHUT_DOWN; // End the permanent stream so the merged stream end too if (this._fakeStream) { this._fakeStream.end(); this._fakeStream = null; } this._resolveExitPromise(); } _getFakeStream() { if (!this._fakeStream) { this._fakeStream = new (_stream().PassThrough)(); } return this._fakeStream; } } exports.default = WorkerAbstract;
Save