{"version":3,"file":"retry.d.ts","sourceRoot":"","sources":["../../../../src/harness/runtime/drive/retry.ts"],"names":[],"mappings":"AAAA,wBAAgB,UAAU,CAAC,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,MAAM,CAGvE;AAED,wBAAgB,cAAc,CAAC,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,EAAE,GAAG,SAAa,GAAG,MAAM,CAG7F;AAED,wBAAgB,SAAS,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,WAAW,GAAG,OAAO,CAAC,IAAI,CAAC,CAwB/E","sourcesContent":["export function retryDelay(baseDelayMs: number, attempt: number): number {\n\tconst delay = baseDelayMs * 2 ** Math.max(0, attempt - 1);\n\treturn Number.isSafeInteger(delay) ? delay : Number.MAX_SAFE_INTEGER;\n}\n\nexport function retryNotBefore(baseDelayMs: number, attempt: number, now = Date.now()): number {\n\tconst sum = now + retryDelay(baseDelayMs, attempt);\n\treturn Number.isSafeInteger(sum) ? sum : Number.MAX_SAFE_INTEGER;\n}\n\nexport function waitUntil(notBefore: number, signal: AbortSignal): Promise<void> {\n\treturn new Promise<void>((resolve, reject) => {\n\t\tlet timer: ReturnType<typeof setTimeout> | undefined;\n\t\tconst cleanup = () => {\n\t\t\tif (timer !== undefined) clearTimeout(timer);\n\t\t\tsignal.removeEventListener(\"abort\", onAbort);\n\t\t};\n\t\tconst onAbort = () => {\n\t\t\tcleanup();\n\t\t\treject(signal.reason);\n\t\t};\n\t\tconst check = () => {\n\t\t\tconst remaining = notBefore - Date.now();\n\t\t\tif (remaining <= 0) {\n\t\t\t\tcleanup();\n\t\t\t\tresolve();\n\t\t\t\treturn;\n\t\t\t}\n\t\t\ttimer = setTimeout(check, Math.min(remaining, 2_147_483_647));\n\t\t};\n\t\tsignal.addEventListener(\"abort\", onAbort, { once: true });\n\t\tif (signal.aborted) onAbort();\n\t\telse check();\n\t});\n}\n"]}