public void testCircuitResetsAfterTimeout() throws Exception {
        // Open the circuit
        circuitBreaker.trip();
        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");

        // Wait for reset timeout
        Thread.sleep(1100);

        // Execute successful operation - should transition to HALF_OPEN then potentially CLOSED
        String result = circuitBreaker.executeWithCircuitBreaker(() -> "success");

 *   for successful and unsuccessful computations, respectively.
 * </p>
 *
 * <p>
 *   The Deferred class uses a CountDownLatch to allow you to wait for the computation to complete.
 *   The resolve and reject methods decrement the CountDownLatch, allowing the getResponse method
 *   to return the result of the computation.
 * </p>
 *

        awaitTermination(0);
    }

    /**
     * Waits for the crawling process to terminate for a specified duration.
     * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely.
     */
    public void awaitTermination(final long millis) {
        if (parentThread != null) {
            try {
                if (logger.isDebugEnabled()) {

    public void testExpiration() {
        // Set a very short max age
        entry.setMaxAge(100); // 100ms

        assertFalse(entry.isExpired());
        assertFalse(entry.needsRefresh());

        // Wait for expiration
        try {
            Thread.sleep(150);
        } catch (InterruptedException e) {
            // Ignore
        }

        assertTrue(entry.isExpired());

 * for connection when the pipe server was busy.
 */
public class TransWaitNamedPipeResponse extends SmbComTransactionResponse {

    /**
     * Constructs a response for a wait named pipe request.
     *
     * @param config the configuration to use
     */
    public TransWaitNamedPipeResponse(final Configuration config) {
        super(config);
    }

    @Override

            crawler.getCrawlerContext().setMaxAccessCount(maxCount);
            crawler.getCrawlerContext().setNumOfThread(numOfThread);
            final String sessionId = crawler.execute();

            // Wait for crawler to start running with polling
            long startTime = System.currentTimeMillis();
            while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) {

                executor.shutdownNow();
            }
        }

        long elapsed = (System.nanoTime() - time) / 1000000;
        long wait = waittime * (numTasks - 1);
        assertTrue(elapsed + " >= " + wait, elapsed + 1L >= wait);
    }

    /**
     * Test that different hosts can be accessed concurrently without delay
     */
    public void test_multipleHosts_concurrent() {

 *
 * @author mbechler
 *
 * <p>This interface is intended for internal use.</p>
 */
public enum RequestParam {

    /**
     * No special request parameters.
     */
    NONE,

    /**
     * Wait indefinitely for a response
     */
    NO_TIMEOUT,

    /**
     * Do not retry request on failure
     */
    NO_RETRY,

    /**
     * Save the raw payload for further inspection
     */

        assertFalse(channelInfo.isHealthy());
    }

    @Test
    void testActivityTracking() {
        long initialTime = channelInfo.getLastActivityTime();

        // Wait a bit and update activity
        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

        channelInfo.updateActivity();

        }
        return values;
    }

    /**
     * Sets the wait time in milliseconds when the crawler is not running.
     *
     * @param crawlerWaitMillis the wait time in milliseconds
     */
    public void setCrawlerWaitMillis(final long crawlerWaitMillis) {
        this.crawlerWaitMillis = crawlerWaitMillis;
    }