Function getTestOpDefinitions

test/tools/cmap_spec_runner.ts:194–270

(threadContext: ThreadContext)

};

const getTestOpDefinitions = (threadContext: ThreadContext) => ({
  checkOut: async function (op) {
    const timeoutContext = TimeoutContext.create({
      serverSelectionTimeoutMS: 0,
      waitQueueTimeoutMS: threadContext.pool.options.waitQueueTimeoutMS
    });
    const connection: Connection = await ConnectionPool.prototype.checkOut.call(
      threadContext.pool,
      { timeoutContext }
    );
    if (op.label != null) {
      threadContext.connections.set(op.label, connection);
    } else {
      threadContext.orphans.add(connection);
    }
  },
  checkIn: function (op) {
    const connection = threadContext.connections.get(op.connection);
    threadContext.connections.delete(op.connection);

    if (!connection) {
      throw new Error(`Attempted to release non-existient connection ${op.connection}`);
    }

    return threadContext.pool.checkIn(connection);
  },
  clear: function ({ interruptInUseConnections }: { interruptInUseConnections: boolean }) {
    return threadContext.pool.clear({ interruptInUseConnections });
  },
  close: function () {
    return ConnectionPool.prototype.close.call(threadContext.pool);
  },
  ready: function () {
    return threadContext.pool.ready();
  },
  wait: function (options) {
    const ms = options.ms;
    return sleep(ms);
  },
  start: function (options) {
    const target = options.target;
    const thread = threadContext.getThread(target);
    thread.start();
  },
  waitForThread: async function (options): Promise<void> {
    const name = options.name;
    const target = options.target;

    const threadObj = threadContext.threads.get(target);

    if (!threadObj) {
      throw new Error(`Attempted to run op ${name} on non-existent thread ${target}`);
    }

    await threadObj.finish();
  },
  waitForEvent: function (options): Promise<void> {
    const event = options.event;