logger.debug("Shutting down thread executor.");
            }
            executor.shutdown();
            executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
        } catch (final InterruptedException e) {
            if (logger.isDebugEnabled()) {
                logger.debug("Executor shutdown interrupted", e);
            }
        } finally {
            executor.shutdownNow();
        }

      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)

            if (response.hasFailures()) {
                throw new SearchEngineClientException(response.buildFailureMessage());
            }
            return true;
        } catch (final InterruptedException e) {
            throw new InterruptedRuntimeException(e);
        } catch (final ExecutionException e) {
            throw new SearchEngineClientException("Failed to update bulk data.", e);
        }
    }

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

        this.lifecycles = lifecycles;
    }

    public void execute(MavenSession session, ReactorContext reactorContext, List<TaskSegment> taskSegments)
            throws ExecutionException, InterruptedException {
        try (BuildContext ctx = new BuildContext(session, reactorContext, taskSegments)) {
            ctx.execute();
        }
    }

    class BuildContext implements AutoCloseable {

                        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();

            },
            directExecutor());
      } catch (Throwable t) {
        ListenableFuture<V> result = setException(t) ? futureValue : fullyFailedFuture(t);
        if (t instanceof InterruptedException) {
          Thread.currentThread().interrupt();
        }
        return result;
      }
    }

    public @Nullable V compute(

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