}
      throw new AssertionError("must have been one of the known types");
    }

    TypeVariable<?> captureAsTypeVariable(Type[] upperBounds) {
      String name =
          "capture#" + id.incrementAndGet() + "-of ? extends " + Joiner.on('&').join(upperBounds);
      return Types.newArtificialTypeVariable(WildcardCapturer.class, name, upperBounds);
    }

            }
        }
    }

    /**
     * @return tree connection with increased usage count
     */
    public SmbTreeConnection acquire() {
        final long usage = this.usageCount.incrementAndGet();
        if (log.isTraceEnabled()) {
            log.trace("Acquire tree connection " + usage + " " + this);
        }

        if (usage == 1) {
            synchronized (this) {

    AtomicInteger stoppingCount = new AtomicInteger();
    service.addListener(
        new Listener() {
          @Override
          public void stopping(State from) {
            stoppingCount.incrementAndGet();
          }
        },
        directExecutor());

    service.startAsync();
    service.stopAsync();
    assertEquals(1, stoppingCount.get());
    service.stopAsync();

    AtomicInteger stoppingCount = new AtomicInteger();
    service.addListener(
        new Listener() {
          @Override
          public void stopping(State from) {
            stoppingCount.incrementAndGet();
          }
        },
        directExecutor());

    service.startAsync();
    service.stopAsync();
    assertEquals(1, stoppingCount.get());
    service.stopAsync();

            assertThat(response.header("Connection")).isEqualTo("Upgrade")
            assertThat(response.body).isInstanceOf<UnreadableResponseBody>()
            interceptedCount.incrementAndGet()
            response
          },
        ).build()
    webServer.enqueue(
      MockResponse
        .Builder()
        .webSocketUpgrade(serverListener)
        .build(),
    )

     * Acquires a reference to this transport, incrementing the usage count.
     *
     * @return session increased usage count
     */
    public Transport acquire() {
        final long usage = this.usageCount.incrementAndGet();
        if (log.isTraceEnabled()) {
            log.trace("Acquire transport " + usage + " " + this);
        }
        return this;
    }

    /**
     * {@inheritDoc}
     *

            return "doc_" + System.currentTimeMillis();
        }

        @Override
        public boolean calibrateCpuLoad() {
            cpuLoadCallCount.incrementAndGet();
            return true;
        }

        @Override
        public void waitForNoWaitingThreads() {
            // Do nothing in test
        }

            final AtomicInteger openCalled = new AtomicInteger(0);
            CurlRequest req = new OpenOverrideCurlRequest(Curl.Method.GET, specialUrl, u -> {
                openCalled.incrementAndGet();
                return new MockHttpURLConnection(u);
            });

            // ## Act ##
            try (CurlResponse response = req.execute()) {
                // ## Assert ##

    InternalEntry<Object, Object, ?> entry = segment.newEntryForTesting(key, hash, null);
    segment.setValueForTesting(entry, value);

    segment.setTableEntryForTesting(0, entry);
    segment.readCount.incrementAndGet();
    segment.count = 1;

    assertThat(table.get(0)).isEqualTo(entry);

    segment.clear();
    assertThat(table.get(0)).isNull();
    assertEquals(0, segment.readCount.get());

    InternalEntry<Object, Object, ?> entry = segment.newEntryForTesting(key, hash, null);
    segment.setValueForTesting(entry, value);

    segment.setTableEntryForTesting(0, entry);
    segment.readCount.incrementAndGet();
    segment.count = 1;

    assertThat(table.get(0)).isEqualTo(entry);

    segment.clear();
    assertThat(table.get(0)).isNull();
    assertEquals(0, segment.readCount.get());