}
                            if (response.errorCode != 0) {
                                checkStatus(req, resp);
                            }
                        } catch (final InterruptedException ie) {
                            throw new TransportException(ie);
                        } finally {
                            response_map.remove(req);
                        }
                    }

      client
        .newBuilder()
        .addNetworkInterceptor(
          Interceptor { chain: Interceptor.Chain ->
            try {
              latch.await()
            } catch (e: InterruptedException) {
              throw AssertionError(e)
            }
            chain.proceed(chain.request())
          },
        ).build()
    val call = client.newCall(Request(server.url("/a")))

    val authenticator =
      okhttp3.Authenticator { route: Route?, response: Response? ->
        responses.offer(response!!.body.string())
        try {
          latch.await()
        } catch (e: InterruptedException) {
          throw AssertionError()
        }
        response.request
      }
    val blockingAuthClient =
      client
        .newBuilder()
        .authenticator(authenticator)

            executor.submit(
                waiter.waitFor(
                    new Callable<TestCloseable>() {
                      @Override
                      public TestCloseable call() throws InterruptedException {
                        awaitUninterruptibly(futureCancelled);
                        return closeable1;
                      }
                    })),
            closingExecutor);

                        return this.treeHandle.acquire();
                    }
                    return this.treeHandle;

                } catch (InterruptedException ie) {
                    Thread.currentThread().interrupt();
                    throw new SmbException("Connection retry interrupted", ie);
                } catch (CIFSException retryException) {

                        return chainedResponse;
                    }
                    try {
                        this.transport.wait();
                    } catch (InterruptedException ie) {
                        throw new SmbException(ie.getMessage(), ie);
                    }
                }

                try {
                    trans.ensureConnected();

                        }
                        while (!w.ready) {
                            try {
                                w.wait();
                            } catch (final InterruptedException ie) {
                                throw new SmbException(dest.url.toString(), ie);
                            }
                        }
                        if (w.e != null) {