123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153
// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.// Copyright Joyent, Inc. and other Node contributors.//// Permission is hereby granted, free of charge, to any person obtaining a// copy of this software and associated documentation files (the// "Software"), to deal in the Software without restriction, including// without limitation the rights to use, copy, modify, merge, publish,// distribute, sublicense, and/or sell copies of the Software, and to permit// persons to whom the Software is furnished to do so, subject to the// following conditions://// The above copyright notice and this permission notice shall be included// in all copies or substantial portions of the Software.//// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE// USE OR OTHER DEALINGS IN THE SOFTWARE.
// This module ports:// - https://github.com/nodejs/node/blob/master/src/async_wrap-inl.h// - https://github.com/nodejs/node/blob/master/src/async_wrap.cc// - https://github.com/nodejs/node/blob/master/src/async_wrap.h
export function registerDestroyHook(  // deno-lint-ignore no-explicit-any  _target: any,  _asyncId: number,  _prop: { destroyed: boolean },) {  // TODO(kt3k): implement actual procedures}
export enum constants {  kInit,  kBefore,  kAfter,  kDestroy,  kPromiseResolve,  kTotals,  kCheck,  kExecutionAsyncId,  kTriggerAsyncId,  kAsyncIdCounter,  kDefaultTriggerAsyncId,  kUsesExecutionAsyncResource,  kStackLength,}
const asyncHookFields = new Uint32Array(Object.keys(constants).length);
export { asyncHookFields as async_hook_fields };
// Increment the internal id counter and return the value.export function newAsyncId() {  return ++asyncIdFields[constants.kAsyncIdCounter];}
export enum UidFields {  kExecutionAsyncId,  kTriggerAsyncId,  kAsyncIdCounter,  kDefaultTriggerAsyncId,  kUidFieldsCount,}
const asyncIdFields = new Float64Array(Object.keys(UidFields).length);
// `kAsyncIdCounter` should start at `1` because that'll be the id the execution// context during bootstrap.asyncIdFields[UidFields.kAsyncIdCounter] = 1;
// `kDefaultTriggerAsyncId` should be `-1`, this indicates that there is no// specified default value and it should fallback to the executionAsyncId.// 0 is not used as the magic value, because that indicates a missing// context which is different from a default context.asyncIdFields[UidFields.kDefaultTriggerAsyncId] = -1;
export { asyncIdFields };
export enum providerType {  NONE,  DIRHANDLE,  DNSCHANNEL,  ELDHISTOGRAM,  FILEHANDLE,  FILEHANDLECLOSEREQ,  FIXEDSIZEBLOBCOPY,  FSEVENTWRAP,  FSREQCALLBACK,  FSREQPROMISE,  GETADDRINFOREQWRAP,  GETNAMEINFOREQWRAP,  HEAPSNAPSHOT,  HTTP2SESSION,  HTTP2STREAM,  HTTP2PING,  HTTP2SETTINGS,  HTTPINCOMINGMESSAGE,  HTTPCLIENTREQUEST,  JSSTREAM,  JSUDPWRAP,  MESSAGEPORT,  PIPECONNECTWRAP,  PIPESERVERWRAP,  PIPEWRAP,  PROCESSWRAP,  PROMISE,  QUERYWRAP,  SHUTDOWNWRAP,  SIGNALWRAP,  STATWATCHER,  STREAMPIPE,  TCPCONNECTWRAP,  TCPSERVERWRAP,  TCPWRAP,  TTYWRAP,  UDPSENDWRAP,  UDPWRAP,  SIGINTWATCHDOG,  WORKER,  WORKERHEAPSNAPSHOT,  WRITEWRAP,  ZLIB,}
const kInvalidAsyncId = -1;
export class AsyncWrap {  provider: providerType = providerType.NONE;  asyncId = kInvalidAsyncId;
  constructor(provider: providerType) {    this.provider = provider;    this.getAsyncId();  }
  getAsyncId(): number {    this.asyncId = this.asyncId === kInvalidAsyncId      ? newAsyncId()      : this.asyncId;
    return this.asyncId;  }
  getProviderType() {    return this.provider;  }}