*/
package org.codelibs.fess.storage;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.time.ZonedDateTime;
import java.util.ArrayList;
import java.util.Base64;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.logging.log4j.LogManager;

        }

        // Start all threads at once
        startLatch.countDown();

        // Wait for completion
        assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time");
        executor.shutdown();

        // Verify hash is not null
        byte[] hash = transport.getPreauthIntegrityHash();
        assertNotNull(hash);

        // Verify hash is a copy, not the original

        smbTree.close();

        verify(smbTree).close();
    }

    /**
     * Test for unwrap preserving type safety.
     * Verifies that unwrap maintains type safety at compile time.
     */
    @Test
    void testUnwrap_typeSafety() {
        CustomSmbTree customTree = mock(CustomSmbTree.class);
        when(smbTree.unwrap(CustomSmbTree.class)).thenReturn(customTree);

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.bsentity.dbmeta;

import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;

import org.codelibs.fess.opensearch.config.exentity.ScheduledJob;
import org.dbflute.Entity;
import org.dbflute.dbmeta.AbstractDBMeta;

        assertEquals(SmbConstants.ATTR_READONLY | SmbConstants.ATTR_DIRECTORY, info.getAttributes());
    }

    @Test
    @DisplayName("Test time-related methods always return 0")
    void testTimeRelatedMethods() {
        // Default instance
        assertEquals(0L, shareInfo.createTime());
        assertEquals(0L, shareInfo.lastModified());

            public List<FileNotifyInformation> watch() throws CIFSException {
                synchronized (lock) {
                    watchCount++;
                    try {
                        // Simulate some processing time
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        Thread.currentThread().interrupt();
                    }

import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
import org.mockito.junit.jupiter.MockitoExtension;

/**
 * JUnit 5 tests for {@link TestLocking}.
 * Tests command line argument parsing and basic field initialization.
 * Does not require a real SMB server - focuses on application logic.
 */
@ExtendWith(MockitoExtension.class)
class TestLockingTest {

    private PrintStream originalOut;

    /** Property key for SMB denied SID entries. */
    public static final String SMB_DENIED_SID_ENTRIES = "smbDeniedSidEntries";

    /** Property key for SMB file creation time. */
    public static final String SMB_CREATE_TIME = "smbCreateTime";

    /** Property key for SMB owner attributes. */
    public static final String SMB_OWNER_ATTRIBUTES = "smbOwnerAttributes";

            urlQueue.setUrl("http://www.example.com/page" + i);
            urlQueueList.add(urlQueue);
        }

        urlQueueService.offerAll(sessionId, urlQueueList);

        // Poll items - should work fine even with max size constraint
        int count = 0;
        while (true) {
            final OpenSearchUrlQueue polled = urlQueueService.poll(sessionId);
            if (polled == null) {
                break;

                DirectoryCacheScope.IMMEDIATE_CHILDREN);

        DirectoryCacheEntry entry = directoryLeaseManager.getCacheEntry(directoryPath);
        assertNotNull(entry);

        // Set very short expiration time
        entry.setMaxAge(50); // 50ms

        // Update cache
        List<SmbFile> files = Arrays.asList(mockFile1);
        directoryLeaseManager.updateDirectoryCache(directoryPath, files);