TransPeekNamedPipeResponse testResponse = new TransPeekNamedPipeResponse(testConfig);

        // Assert
        assertNotNull(testResponse);
    }

    @Test
    @DisplayName("Test state changes after reading parameters")
    void testStateAfterReadingParameters() {
        // Arrange
        byte[] buffer = new byte[10];
        SMBUtil.writeInt2(1500, buffer, 0);
        SMBUtil.writeInt2(0xFFFF, buffer, 2);

 * It uses Log4j2 for logging.
 *
 * <p>
 * The class contains methods for logging different types of events, such as:
 * </p>
 * <ul>
 *   <li>Starting and finishing threads</li>
 *   <li>Starting and cleaning up crawling</li>
 *   <li>Handling unsupported URLs</li>
 *   <li>Checking last modified dates</li>
 *   <li>Getting content</li>
 *   <li>Handling redirects</li>
 *   <li>Processing responses</li>

            }
            maxLineBuffer = maxOutputLineBuffer;
        }

        /**
         * Runs the input stream thread, reading lines and buffering them.
         */
        @Override
        public void run() {
            for (;;) {
                try {
                    final String line = br.readLine();

import org.mockito.Mock;
import org.mockito.MockitoAnnotations;

import jcifs.CIFSContext;
import jcifs.Configuration;
import jcifs.smb.SmbFile;

/**
 * Integration tests for directory leasing functionality
 */
public class DirectoryLeasingIntegrationTest {

    @Mock
    private CIFSContext context;

    @Mock
    private Configuration config;

    @Mock
    private SmbFile mockFile1;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jcifs.internal.util.SMBUtil;
import jcifs.smb.SmbFile;

/**
 * Handles directory change notifications for SMB3 directory leasing
 */
public class DirectoryChangeNotifier {

    private static final Logger log = LoggerFactory.getLogger(DirectoryChangeNotifier.class);

    // Backoff and timing constants (in ms)

     * a regex pattern matches the query.
     */
    protected String queryPlaceHolder = "__QUERY__";

    /**
     * Initializes the RelatedContentHelper by loading related content configurations
     * from the data store. This method is called automatically after dependency
     * injection is complete.
     *
     * PostConstruct annotation ensures this method is called after the bean

    /** The OpenSearch client. */
    protected final Client client;
    /** The suggest settings. */
    protected final SuggestSettings suggestSettings;
    /** The reading converter. */
    protected final ReadingConverter readingConverter;
    /** The contents reading converter. */
    protected final ReadingConverter contentsReadingConverter;
    /** The normalizer. */
    protected final Normalizer normalizer;
    /** The analyzer. */

     */
    protected static class ProcessDestroyer extends TimerTask {

        /** The process to monitor and destroy. */
        private final Process p;

        /** The input stream thread reading process output. */
        private final InputStreamThread ist;

        /** Flag indicating if the destroyer has been executed. */
        private final AtomicBoolean executed = new AtomicBoolean(false);

        assertEquals("mybucket", getField(conn, "bucketName"));
        // URL class does NOT normalize multiple slashes - they are preserved after removing leading slash
        String objectName = (String) getField(conn, "objectName");
        assertEquals("/path//to//object.txt", objectName);
    }

    /**

    }

    // Helper method to read string from buffer
    private String readStringFromBuffer(byte[] buffer, int offset, int length) {
        // Simple ASCII string reading for test purposes
        StringBuilder sb = new StringBuilder();
        for (int i = offset; i < offset + length && buffer[i] != 0; i++) {
            if (buffer[i] != 0) {
                sb.append((char) buffer[i]);