Brunobkr/llama.cpp_AlgMor24_github

1"use strict";2var __defProp = Object.defineProperty;3var __getOwnPropDesc = Object.getOwnPropertyDescriptor;4var __getOwnPropNames = Object.getOwnPropertyNames;5var __hasOwnProp = Object.prototype.hasOwnProperty;6var __export = (target, all) => {7  for (var name in all)8    __defProp(target, name, { get: all[name], enumerable: true });9};10var __copyProps = (to, from, except, desc) => {11  if (from && typeof from === "object" || typeof from === "function") {12    for (let key of __getOwnPropNames(from))13      if (!__hasOwnProp.call(to, key) && key !== except)14        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });15  }16  return to;17};18var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);19var pipeTransport_exports = {};20__export(pipeTransport_exports, {21  PipeTransport: () => PipeTransport22});23module.exports = __toCommonJS(pipeTransport_exports);24var import_utils = require("../utils");25var import_debugLogger = require("./utils/debugLogger");26class PipeTransport {27  constructor(pipeWrite, pipeRead) {28    this._pendingBuffers = [];29    this._waitForNextTask = (0, import_utils.makeWaitForNextTask)();30    this._closed = false;31    this._pipeRead = pipeRead;32    this._pipeWrite = pipeWrite;33    pipeRead.on("data", (buffer) => this._dispatch(buffer));34    pipeRead.on("close", () => {35      this._closed = true;36      if (this._onclose)37        this._onclose.call(null);38    });39    pipeRead.on("error", (e) => import_debugLogger.debugLogger.log("error", e));40    pipeWrite.on("error", (e) => import_debugLogger.debugLogger.log("error", e));41    this.onmessage = void 0;42  }43  get onclose() {44    return this._onclose;45  }46  set onclose(onclose) {47    this._onclose = onclose;48    if (onclose && !this._pipeRead.readable)49      onclose();50  }51  send(message) {52    if (this._closed)53      throw new Error("Pipe has been closed");54    this._pipeWrite.write(JSON.stringify(message));55    this._pipeWrite.write("\0");56  }57  close() {58    throw new Error("unimplemented");59  }60  _dispatch(buffer) {61    let end = buffer.indexOf("\0");62    if (end === -1) {63      this._pendingBuffers.push(buffer);64      return;65    }66    this._pendingBuffers.push(buffer.slice(0, end));67    const message = Buffer.concat(this._pendingBuffers).toString();68    this._waitForNextTask(() => {69      if (this.onmessage)70        this.onmessage.call(null, JSON.parse(message));71    });72    let start = end + 1;73    end = buffer.indexOf("\0", start);74    while (end !== -1) {75      const message2 = buffer.toString(void 0, start, end);76      this._waitForNextTask(() => {77        if (this.onmessage)78          this.onmessage.call(null, JSON.parse(message2));79      });80      start = end + 1;81      end = buffer.indexOf("\0", start);82    }83    this._pendingBuffers = [buffer.slice(start)];84  }85}86// Annotate the CommonJS export names for ESM import in node:870 && (module.exports = {88  PipeTransport89});90