import org.codelibs.fess.crawler.entity.ResponseData;
import org.codelibs.fess.crawler.exception.ChildUrlsException;
import org.codelibs.fess.crawler.exception.CrawlerSystemException;
import org.codelibs.fess.crawler.exception.CrawlingAccessException;
import org.codelibs.fess.crawler.exception.MaxLengthExceededException;
import org.codelibs.fess.crawler.helper.ContentLengthHelper;

        SMBUtil.writeInt2(64, malformedBuffer, 0);

        SMBProtocolDecodingException exception = assertThrows(SMBProtocolDecodingException.class, () -> {
            response.readBytesWireFormat(malformedBuffer, 0);
        });

        assertTrue(exception.getMessage().contains("Structure size is not 65"));
        assertTrue(exception.getMessage().contains("got: 64"));
    }

    /**

 */
package org.codelibs.fess.crawler.exception;

/**
 * An exception indicating that the execution of a process has timed out.
 * This exception extends {@link org.codelibs.fess.crawler.exception.ExtractException}.
 *
 */
public class ExecutionTimeoutException extends ExtractException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new exception with the specified detail message and cause.

     */
    void reset();

    /**
     * Gets the exception associated with this response.
     *
     * @return an exception linked to an error
     */
    Exception getException();

    /**
     * Sets an exception for this response.
     *
     * @param e the exception to set
     */
    void exception(Exception e);

    /**
     * Gets the next response in the chain.
     *

    }

    // --- Tests for copyFile exception handling branch ---

    @Nested
    class CopyFileExceptions {

        private SmbTreeHandleImpl newTreeHandle(boolean isSmb2) throws Exception {
            SmbTreeHandleImpl th = mock(SmbTreeHandleImpl.class);
            lenient().when(th.isSMB2()).thenReturn(isSmb2);

    void handlesNullDirectory() throws Exception {
        SmbFilenameFilter filter = (dir, name) -> dir == null;

        boolean result = filter.accept(null, "anything");

        assertTrue(result, "Filter should accept when dir is null as defined");
    }

    /**
     * Exception flow: filter throws SmbException and it propagates to caller.
     */
    @Test

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

    @Override
    public ByteBuffer receive(int timeout) throws IOException {
        if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {
            throw new IOException("Connection not established");
        }

    }

    /**
     * Constructs a runtime CIFS exception with the specified detail message and cause.
     *
     * @param message the detail message
     * @param cause the cause of this exception
     */
    public RuntimeCIFSException(final String message, final Throwable cause) {
        super(message, cause);
    }

    /**
     * Constructs a runtime CIFS exception with the specified detail message.
     *

import java.io.File;
import java.io.IOException;
import java.util.Map;

import org.codelibs.core.io.FileUtil;
import org.codelibs.fess.crawler.Constants;
import org.codelibs.fess.crawler.entity.AccessResultDataImpl;
import org.codelibs.fess.crawler.entity.ResponseData;
import org.codelibs.fess.crawler.entity.ResultData;
import org.codelibs.fess.crawler.exception.CrawlerSystemException;

        verify(fd, never()).markClosed();
    }

    @Test
    @DisplayName("available() wraps SmbException to IOException")
    void available_wrapsException() throws Exception {
        // Verify exceptions from th.send are converted to IOException via seToIoe
        SmbPipeInputStream stream = newStreamWithMinimalStubs(true);

        when(handle.ensureOpen()).thenReturn(fd);