}

    /**
     * Handle channel failure
     *
     * @param failedChannel failed channel
     * @param error error that caused failure
     */
    public void handleFailure(ChannelInfo failedChannel, Exception error) {
        log.warn("Channel {} failed: {}", failedChannel.getChannelId(), error.getMessage());

        // Mark channel as failed
        failedChannel.setState(ChannelState.FAILED);

        CrawlerSystemException exception1 = new CrawlerSystemException(exceptionCause);
        assertSame(exceptionCause, exception1.getCause());

        // With Error cause
        Error errorCause = new Error("Error cause");
        CrawlerSystemException exception2 = new CrawlerSystemException(errorCause);
        assertSame(errorCause, exception2.getCause());

        // With RuntimeException cause

     *
     * @throws IOException if an I/O error occurs (not thrown in this implementation)
     */
    @Override
    public void close() throws IOException {
        // inputStream.close();
    }

    /**
     * Returns the number of bytes that can be read from this input stream without blocking.
     *
     * @return the number of bytes available
     * @throws IOException if an I/O error occurs
     */
    @Override

     *
     * @param message The detailed error message explaining the cause of the exception
     */
    public SsoProcessException(final String message) {
        super(message);
    }

    /**
     * Constructs a new SSO process exception with the specified detailed message and cause.
     *
     * @param message The detailed error message explaining the cause of the exception

                    log.error("Failed to create child URL", e);
                    continue;
                }
            }

            try (SmbResource r = adapt(fe)) {
                if (this.filter.accept(r)) {
                    return r;
                }
            } catch (final MalformedURLException e) {
                log.error("Failed to create child URL", e);
                continue;

     * @param cause the cause of the exception
     */
    public GsaConfigException(final String message, final Throwable cause) {
        super(message, cause);
    }

    /**
     * Constructs a new GSA configuration exception with the specified detail message.
     *
     * @param message the detail message describing the configuration error
     */

            } catch (InterruptedException ignore) {}
            deferred.reject(new Exception());
        });
        th.start();

        final CountDownLatch latch = new CountDownLatch(1);
        deferred.promise().error(error -> latch.countDown());
        assertTrue(latch.await(10, TimeUnit.SECONDS));
    }

    @Test
    public void test_doneAfterReject() throws Exception {

            state = RdmaConnectionState.CONNECTED;
            log.debug("DiSNI RDMA connection established to {}", remoteAddress);

        } catch (Exception e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("DiSNI RDMA connection failed", e);
        }
    }

    @Override
    public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {

        requestsReceived.incrementAndGet();
    }

    /**
     * Increment error counter
     */
    public void incrementErrors() {
        errors.incrementAndGet();
    }

    /**
     * Get error rate (errors / total requests)
     *
     * @return error rate between 0.0 and 1.0
     */
    public double getErrorRate() {
        long total = requestsSent.get();

     * @param resp The response.
     * @param challenge The domain controller challenge.
     * @throws IOException If an IO error occurs.
     * @return the authenticated NtlmPasswordAuthentication object
     * @throws IOException If an IO error occurs.
     * @throws ServletException If an error occurs.
     */
    public static NtlmPasswordAuthentication authenticate(final HttpServletRequest req, final HttpServletResponse resp,