generator1.setCommandTimeout(1000L);
        generator2.setCommandTimeout(2000L);

        assertTrue("Multiple generators should work independently", true);
    }

    // Test command string construction edge cases
    public void test_command_string_edge_cases() throws Exception {
        // Test with commands containing special characters

import org.dbflute.utflute.core.PlainTestCase;

/**
 * Test class for CrawlerPooledObjectFactory.
 * Tests the pooled object factory functionality including object creation,
 * wrapping, destruction, and listener mechanisms.
 */
public class CrawlerPooledObjectFactoryTest extends PlainTestCase {

    private CrawlerPooledObjectFactory<TestComponent> factory;
    private StandardCrawlerContainer container;

        assertEquals(0x400000, Smb2CreateRequest.FILE_NOP_RECALL);
        assertEquals(0x800000, Smb2CreateRequest.FILE_OPEN_FOR_FREE_SPACE_QUERY);
    }

    @Test
    @DisplayName("Test default values after construction")
    void testDefaultValues() {
        request = new Smb2CreateRequest(mockConfig, "test.txt");

        byte[] buffer = new byte[1024];
        request.writeBytesWireFormat(buffer, 0);

     * <p>The online hash flooding detecting in RegularSetBuilderImpl.add can detect e.g. many
     * exactly matching hash codes, which would cause construction to take O(n^2), but can't detect
     * e.g. hash codes adversarially designed to go into ascending table locations, which keeps
     * construction O(n) (as desired) but then can have O(n) queries later.
     *
     * <p>If this returns false, then no query can take more than O(log n).
     *

    void testNullPath() {
        // When creating with null path
        Smb2TreeConnectRequest reqWithNull = new Smb2TreeConnectRequest(mockConfig, null);

        // Then - should not throw during construction
        assertNotNull(reqWithNull);

        // But should throw when trying to use the null path
        assertThrows(NullPointerException.class, () -> {
            reqWithNull.size();
        });
    }

     * Creates a new document helper instance.
     */
    public DocumentHelper() {
        // Default constructor
    }

    /**
     * Initializes the document helper after construction.
     * Sets up the TikaExtractor with configuration parameters for text processing.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {

    @DisplayName("Should accept null dialect during construction")
    void testNullDialect() {
        // When/Then
        assertDoesNotThrow(() -> {
            Smb2EncryptionContext context = new Smb2EncryptionContext(1, null, testEncryptionKey, testDecryptionKey);
            assertNull(context.getDialect(), "Dialect should be null");
        }, "Should accept null dialect during construction");
    }

    @Test

    }

    @Test
    @DisplayName("getInput/getOutput return cached streams when open; throw when closed")
    void getInputOutput_caching_and_closed() throws Exception {
        // Arrange: minimal stubs so stream construction works
        SmbPipeHandleImpl handle = newHandleWithBasicStubs(0, "\\\\pipe\\\\foo");
        when(pipe.ensureTreeConnected()).thenReturn(tree);
        when(tree.acquire()).thenReturn(tree);

    protected Cache<String, CrawlingConfig> crawlingConfigCache;

    /**
     * Initializes the CrawlingConfigHelper by setting up the crawling configuration cache.
     * This method is called automatically after the bean construction is complete.
     * The cache is configured with a maximum size of 100 entries and expires after 10 minutes.
     */
    @PostConstruct
    public void init() {
        if (logger.isDebugEnabled()) {

Follow either of the two links above to access the appropriate CLA and instructions for how to sign and return it. Once we receive it, we'll be able to accept your pull requests.

***NOTE***: Only original source code from you and other people that have signed the CLA can be accepted into the main repository.