![]() Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/dceprojects.corals.io/node_modules/puppeteer/lib/esm/puppeteer/node/ |
/** * Copyright 2018 Google Inc. All rights reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import { helper, debugError, } from '../common/helper.js'; export class PipeTransport { constructor(pipeWrite, pipeRead) { this._pipeWrite = pipeWrite; this._pendingMessage = ''; this._eventListeners = [ helper.addEventListener(pipeRead, 'data', (buffer) => this._dispatch(buffer)), helper.addEventListener(pipeRead, 'close', () => { if (this.onclose) this.onclose.call(null); }), helper.addEventListener(pipeRead, 'error', debugError), helper.addEventListener(pipeWrite, 'error', debugError), ]; this.onmessage = null; this.onclose = null; } send(message) { this._pipeWrite.write(message); this._pipeWrite.write('\0'); } _dispatch(buffer) { let end = buffer.indexOf('\0'); if (end === -1) { this._pendingMessage += buffer.toString(); return; } const message = this._pendingMessage + buffer.toString(undefined, 0, end); if (this.onmessage) this.onmessage.call(null, message); let start = end + 1; end = buffer.indexOf('\0', start); while (end !== -1) { if (this.onmessage) this.onmessage.call(null, buffer.toString(undefined, start, end)); start = end + 1; end = buffer.indexOf('\0', start); } this._pendingMessage = buffer.toString(undefined, start); } close() { this._pipeWrite = null; helper.removeEventListeners(this._eventListeners); } }