Skip to content

Commit b85ed5b

Browse files
committed
test: keep release deadline assertion alive
1 parent 135a85f commit b85ed5b

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

tests/zcode-client.test.mjs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1670,7 +1670,7 @@ test('broker release returns at its hard deadline while its tracked continuation
16701670
let reads = 0; broker.readOwnerStore = async () => { reads += 1; if (reads === 1) await readGate; return { exists: true, sessions: { [sessionId]: ownerId } }; };
16711671
let sendCalls = 0; let createCalls = 0; let stopCalls = 0; broker.protocol = { request: async (method) => { if (method === 'session/send') { sendCalls += 1; return { accepted: true, sessionId, stateRevision: 1 }; } if (method === 'session/create') { createCalls += 1; throw new Error('a fenced create reached ZCode'); } if (method === 'session/stop') { stopCalls += 1; return {}; } throw new Error(`unexpected ${method}`); }, beginTurn() {}, armTurn() {}, abortTurn() {}, cancelTurn() {} };
16721672
const handling = broker.handleLocal(socket, JSON.stringify({ id: 83, method: 'broker/releaseOwner', params: { excludeSessionIds: [] } }));
1673-
await releaseResponseReady;
1673+
await withTestDeadlineKeepalive(() => releaseResponseReady);
16741674
const releaseResponse = writes.find((frame) => frame.id === 83); assert.equal(releaseResponse?.error?.data?.pluginError?.code, 'ZCODE_OWNER_RELEASE_TIMEOUT'); assert.equal(reads, 1); assert.equal(broker.admission.ownerStates.get(ownerId)?.release?.ownerId, ownerId); assert.equal(broker.sessionOwners.get(sessionId)?.ownerId, ownerId);
16751675
await broker.handleLocal(socket, JSON.stringify({ id: 84, method: 'session/send', params: { sessionId, inputId: 'release-fenced-send', queryId: 'release-fenced-send', content: 'must not reach ZCode' } }));
16761676
await broker.handleLocal(socket, JSON.stringify({ id: 85, method: 'session/create', params: brokerCreateParams(directory, 'release-fenced-create') }));

0 commit comments

Comments
 (0)