Function finishProcessing

worker/model-worker.ts:69–105

(
  responseFile: string,
  requestId: string,
  success: boolean,
  data?: any,
  error?: string,
  callback?: () => void
)

let processing = false;

function finishProcessing(
  responseFile: string,
  requestId: string,
  success: boolean,
  data?: any,
  error?: string,
  callback?: () => void
) {
  try {
    const responseFileLen = view[RESPONSE_FILENAME_LENGTH_INDEX];
    if (responseFileLen > 0 && responseFileLen <= FILENAME_MAX_LENGTH) {
      const responseFilePath = join(tmpDir, responseFile);
      
      const finalResponse = {
        requestId,
        success,
        data: success ? data : undefined,
        error: error,
      };

      const encryptedResponse = encrypt(JSON.stringify(finalResponse), aesKey);
      writeFileSync(responseFilePath, encryptedResponse);
      
      Atomics.or(view, 0, 0b010);
      Atomics.notify(view, 0);
      
      if (callback) {
        callback();
      }
    }
  } catch (err) {
    log('error', `[Worker] Failed to write response file: ${err}`);
  } finally {
    processing = false;
    Atomics.and(view, 0, ~0b001);
  }
}

async function processRequestAsync(): Promise<void> {
  let requestFile = '';