if (current == State.OPEN) {
            long timeSinceLastFailure = System.currentTimeMillis() - lastFailureTime.get();
            if (timeSinceLastFailure > timeoutMillis) {
                if (state.compareAndSet(State.OPEN, State.HALF_OPEN)) {
                    stateChangeTime.set(System.currentTimeMillis());
                    halfOpenSuccesses.set(0);

        // First initialization
        if (client.isInit.compareAndSet(false, true)) {
            client.init();
        }
        assertTrue("Client should be initialized", client.isInit.get());

        // Second initialization attempt should be no-op
        boolean secondInit = client.isInit.compareAndSet(false, true);
        assertFalse("Second initialization should not occur", secondInit);

            log.trace("Acquire session " + usage + " " + this);
        }

        if (usage == 1) {
            synchronized (this) {
                if (this.transportAcquired.compareAndSet(false, true)) {
                    log.debug("Reacquire transport");
                    this.transport.acquire();
                }
            }
        }

        return this;
    }

        long windowStart = currentWindowStart.get();

        // Check if we need to reset the window (1 minute window)
        if (now - windowStart > 60000) {
            currentWindowStart.compareAndSet(windowStart, now);
            globalAttemptsInCurrentWindow.set(0);
        }

        int attempts = globalAttemptsInCurrentWindow.incrementAndGet();
        return attempts <= maxGlobalAttemptsPerMinute;
    }

        while (responseTimeMs < currentMin) {
            if (minResponseTime.compareAndSet(currentMin, responseTimeMs)) {
                break;
            }
            currentMin = minResponseTime.get();
        }

        long currentMax = maxResponseTime.get();
        while (responseTimeMs > currentMax) {
            if (maxResponseTime.compareAndSet(currentMax, responseTimeMs)) {
                break;
            }

            }
        }

        if (usage == 1) {
            synchronized (this) {
                if (this.sessionAcquired.compareAndSet(false, true)) {
                    log.debug("Reacquire session");
                    this.session.acquire();
                }
            }
        }
        return this;
    }

    /**

                if (logger.isDebugEnabled()) {
                    logger.debug("Process {} is not alive.", p);
                }
                return;
            }

            if (executed.compareAndSet(false, true)) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Interrupting a stream thread.");
                }
                ist.interrupt();

     * @return the response data
     * @throws CrawlingAccessException if the request fails
     */
    protected ResponseData processRequest(final String uri, final boolean includeContent) {
        if (isInit.compareAndSet(false, true)) {
            init();
        }

        // start
        AccessTimeoutTarget accessTimeoutTarget = null;
        TimeoutTask accessTimeoutTask = null;
        if (accessTimeout != null) {