MCPcopy Create free account
hub / github.com/RtlZeroMemory/Rezi / failAll

Function failAll

packages/node/src/backend/nodeBackend.ts:237–253  ·  view source on GitHub ↗
(err: Error)

Source from the content-addressed store, hash-verified

235 const debugChannel = createNodeBackendDebugChannelState();
236
237 function failAll(err: Error): void {
238 while (eventWaiters.length > 0) eventWaiters.shift()?.reject(err);
239 while (capsWaiters.length > 0) capsWaiters.shift()?.reject(err);
240 while (commitWaiters.length > 0) commitWaiters.shift()?.reject(err);
241 eventQueue.length = 0;
242 rejectFrameWaiters(frameTracking, frameAudit, err);
243 rejectDebugWaiters(debugChannel, err);
244
245 if (startDef !== null && !startSettled) {
246 startSettled = true;
247 startDef.reject(err);
248 }
249 if (stopDef !== null && !stopSettled) {
250 stopSettled = true;
251 stopDef.reject(err);
252 }
253 }
254
255 function rejectPending(err: Error): void {
256 while (eventWaiters.length > 0) eventWaiters.shift()?.reject(err);

Callers 3

handleWorkerMessageFunction · 0.85
handleWorkerExitFunction · 0.85
startFunction · 0.85

Calls 2

rejectFrameWaitersFunction · 0.85
rejectDebugWaitersFunction · 0.85

Tested by

no test coverage detected