try {
                if (!cleanupExecutor.awaitTermination(5, TimeUnit.SECONDS)) {
                    cleanupExecutor.shutdownNow();
                }
            } catch (InterruptedException e) {
                cleanupExecutor.shutdownNow();
                Thread.currentThread().interrupt();
            }
        }

        // Clean up expired weak references

                    return;
                }
                try {
                    transport.wait();
                } catch (final InterruptedException ie) {
                    throw new SmbException(ie.getMessage(), ie);
                }
            }
            connectionState = 1; // trying ...

            try {

            logger.info("[EXEC TIME] crawling time: {}ms", execTime);
        }

        indexUpdater.setFinishCrawling(true);
        try {
            indexUpdater.join();
        } catch (final InterruptedException e) {
            logger.warn("Interrupted index update.", e);
        }

        crawlingInfoHelper.putToInfoMap(Constants.WEB_FS_INDEX_EXEC_TIME, Long.toString(indexUpdater.getExecuteTime()));

  }

  /**
   * Tests that a ServiceManager can be fully shut down if one of its failure listeners is slow or
   * even permanently blocked.
   */
  public void testListenerDeadlock() throws InterruptedException {
    CountDownLatch failEnter = new CountDownLatch(1);
    CountDownLatch failLeave = new CountDownLatch(1);
    CountDownLatch afterStarted = new CountDownLatch(1);
    Service failRunService =

            assertEquals("Test exception", e.getMessage());
        }
    }

    // Test concurrent modification of jvmOptions
    public void test_jvmOptions_concurrent() throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(2);

        Thread t1 = new Thread(() -> {
            for (int i = 0; i < 100; i++) {
                execJob.jvmOptions("-Xmx" + i + "m");
            }

    if (sendOnClosed) {
      listener.onClosed(this, code, reason!!)
    }

    readerToClose?.closeQuietly()
  }

  /** For testing: force this web socket to release its threads. */
  @Throws(InterruptedException::class)
  fun tearDown() {
    taskQueue.shutdown()
    taskQueue.idleLatch().await(10, TimeUnit.SECONDS)
  }

  @Synchronized fun sentPingCount(): Int = sentPingCount

          try {
            // Wait for the server to send the duplex response before acting on the 301 response
            // and resetting the stream.
            duplexResponseSent.await()
          } catch (e: InterruptedException) {
            throw AssertionError()
          }
          super.responseHeadersEnd(call, response)
        }
      }
    client =
      client
        .newBuilder()

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

                return null;
            }
            while (LOOKUP_TABLE.containsKey(name)) {
                try {
                    LOOKUP_TABLE.wait();
                } catch (final InterruptedException e) {}
            }
        }
        obj = getCachedAddress(name);
        if (obj == null) {
            synchronized (LOOKUP_TABLE) {
                LOOKUP_TABLE.put(name, name);
            }

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