}

  public void testBasics() {
    AtomicInteger totalCalls = new AtomicInteger();
    Runnable intCounter =
        () -> {
          totalCalls.incrementAndGet();
          // Make sure that no other tasks are scheduled to run while this is running.
          assertFalse(fakePool.hasNext());
        };

    assertFalse(fakePool.hasNext());
    e.execute(intCounter);

    for (int i = 0; i < 1000; i++) {
      AtomicInteger counter = new AtomicInteger();
      TrustedListenableFutureTask<Integer> task =
          TrustedListenableFutureTask.create(counter::incrementAndGet);
      CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
      Runnable wrapper =
          () -> {
            awaitUnchecked(barrier);
            task.run();
            awaitUnchecked(barrier);

    for (int i = 0; i < 1000; i++) {
      AtomicInteger counter = new AtomicInteger();
      TrustedListenableFutureTask<Integer> task =
          TrustedListenableFutureTask.create(counter::incrementAndGet);
      CyclicBarrier barrier = new CyclicBarrier(numThreads + 1);
      Runnable wrapper =
          () -> {
            awaitUnchecked(barrier);
            task.run();
            awaitUnchecked(barrier);

            evictionCount.incrementAndGet();
            totalSum.addAndGet(notification.getValue().get());
          }
        };

    CacheLoader<Integer, AtomicInteger> loader =
        new CacheLoader<Integer, AtomicInteger>() {
          @Override
          public AtomicInteger load(Integer key) {
            applyCount.incrementAndGet();
            return new AtomicInteger();
          }

        void recordConnection() {
            connectionsCreated.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();
        }

        void recordSuccess() {
            successCount.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();
        }

        void recordFailure() {
            failureCount.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();

        val calls = mutableMapOf<String, AtomicInteger>()

        override fun publish(record: LogRecord) {
          calls
            .getOrPut(record.loggerName) { AtomicInteger(0) }
            .incrementAndGet()
        }

        override fun flush() {
        }

        override fun close() {
        }
      }.apply {
        level = Level.FINEST
      }

    Logger

        totalValidations.incrementAndGet();

        if (buffer == null) {
            failedValidations.incrementAndGet();
            throw new SmbException("Response buffer is null");
        }

        if (buffer.length < expectedSize) {
            failedValidations.incrementAndGet();
            bufferOverflowsPrevented.incrementAndGet();

  }

  private static void insertIntoReplica(Map<Integer, AtomicInteger> replica, int newValue) {
    if (replica.containsKey(newValue)) {
      replica.get(newValue).incrementAndGet();
    } else {
      replica.put(newValue, new AtomicInteger(1));
    }
  }

  private static void removeMinFromReplica(
      SortedMap<Integer, AtomicInteger> replica, int minValue) {

     * Record an RDMA operation error
     */
    public void recordError() {
        operationErrors.incrementAndGet();
    }

    /**
     * Record a new RDMA connection creation
     */
    public void recordConnectionCreated() {
        connectionsCreated.incrementAndGet();
        connectionsActive.incrementAndGet();
    }

    /**
     * Record RDMA connection closure
     */

  }

  private static void insertIntoReplica(Map<Integer, AtomicInteger> replica, int newValue) {
    if (replica.containsKey(newValue)) {
      replica.get(newValue).incrementAndGet();
    } else {
      replica.put(newValue, new AtomicInteger(1));
    }
  }

  private static void removeMinFromReplica(
      SortedMap<Integer, AtomicInteger> replica, int minValue) {