Lines Matching refs:signal
119 // the created timer object. Separately, we add the signal to a
120 // FinalizerRegistry that will clear the timeout when the signal is gc'd.
123 const signal = weakRef.deref();
124 if (signal !== undefined) {
125 gcPersistentSignals.delete(signal);
127 signal,
186 const signal = createAbortSignal();
187 signal[kTimeout] = true;
189 signal,
190 setWeakAbortSignalTimeout(new WeakRef(signal), delay));
191 return signal;
207 const signal = signals[i];
208 if (signal.aborted) {
209 abortSignal(resultSignal, signal.reason);
212 signal[kDependantSignals] ??= new SafeSet();
213 if (!signal[kComposite]) {
214 resultSignal[kSourceSignals].add(new WeakRef(signal));
215 signal[kDependantSignals].add(resultSignalWeakRef);
216 } else if (!signal[kSourceSignals]) {
219 for (const sourceSignal of signal[kSourceSignals]) {
246 // If this is a timeout signal, or a non-empty composite signal, and we're adding a non-weak abort
354 const signal = new EventTarget();
355 ObjectSetPrototypeOf(signal, AbortSignal.prototype);
356 signal[kAborted] = aborted;
357 signal[kReason] = reason;
358 signal[kComposite] = composite;
359 return transferable ? lazyMakeTransferable(signal) : signal;
362 function abortSignal(signal, reason) {
363 if (signal[kAborted]) return;
364 signal[kAborted] = true;
365 signal[kReason] = reason;
369 signal.dispatchEvent(event);
370 signal[kDependantSignals]?.forEach((s) => {
378 const kSignal = Symbol('signal');
393 get signal() {
408 signal: this.signal,
421 * @param {AbortSignal} signal
424 function transferableAbortSignal(signal) {
425 if (signal?.[kAborted] === undefined)
426 throw new ERR_INVALID_ARG_TYPE('signal', 'AbortSignal', signal);
427 return lazyMakeTransferable(signal);
438 * @param {AbortSignal} signal
442 async function aborted(signal, resource) {
443 if (signal === undefined) {
444 throw new ERR_INVALID_ARG_TYPE('signal', 'AbortSignal', signal);
446 validateAbortSignal(signal, 'signal');
448 if (signal.aborted)
452 signal.addEventListener('abort', abortPromise.resolve, opts);
457 signal: kEnumerableProperty,