Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 2 additions & 5 deletions unitTests/resources/dropTableCrossWorkerWrite.test.js
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ require('../testUtils');
const assert = require('node:assert');
const path = require('node:path');
const { setupTestDBPath } = require('../testUtils');
const { table, database } = require('#src/resources/databases');
const { table } = require('#src/resources/databases');
const { startWorker, onMessageByType, setMainIsWorker } = require('#js/server/threads/manageThreads');

const WORKER_FIXTURE = path.join(__dirname, 'dropTableCrossWorkerWrite-worker.js');
Expand Down Expand Up @@ -115,11 +115,8 @@ describe('dropTable racing a cross-worker source-fill commit', function () {
assert.deepStrictEqual(catalogRows(Main, name), [], 'catalog rows must be removed');
});

// Relies on @harperfast/rocksdb-js deferring physical column-family drops behind admitted commits (rocksdb-js#850).
it('leaves the storage environment writable and the catalog clean', async function () {
assert.ok(
'columnFamily.pendingReclaims' in (database({ database: 'test', table: null }).getStats?.() ?? {}),
'the drop path no longer drains in-flight writes and needs a @harperfast/rocksdb-js that defers physical column-family drops behind admitted commits (rocksdb-js#850); bump the pin'
);
let raced = 0;
for (let i = 0; i < ITERATIONS; i++) {
const name = `CrossDrop${i}`;
Expand Down
Loading