}

    @Override
    public SmbRandomAccessFile openRandomAccess(final String mode) throws SmbException {
        return new SmbRandomAccessFile(this, mode);
    }

    @Override
    public SmbRandomAccessFile openRandomAccess(final String mode, final int sharing) throws SmbException {
        return new SmbRandomAccessFile(this, mode, sharing, false);
    }

@ExtendWith(MockitoExtension.class)
class DirFileEntryEnumIteratorBaseTest {

    // Simple FileEntry implementation used for tests
    private static FileEntry entry(String name) {
        return new FileEntry() {
            @Override
            public String getName() {
                return name;
            }

            @Override
            public int getType() {
                return 0;
            }

    @Test
    @DisplayName("Multiple server names should be handled correctly")
    void testDifferentServerNames() {
        // Test with different server names
        String[] serverNames = { "server1", "domain.local", "192.168.1.100", "FILESERVER" };

        for (String serverName : serverNames) {
            MsrpcDfsRootEnum enumInstance = new MsrpcDfsRootEnum(serverName);
            assertEquals(serverName, enumInstance.dfs_name);

    private SmbFileHandleImpl handle;
    private SmbPipeOutputStream output;
    private SmbPipeInputStream input;

    private final String uncPath;

    private SmbTreeHandleImpl treeHandle;

    private final int sharing = SmbConstants.DEFAULT_SHARING;

    /**
     * @param pipe
     */
    public SmbPipeHandleImpl(final SmbNamedPipe pipe) {
        this.pipe = pipe;

        private final String sessionId;
        private final List<ChannelInfo> channels = new CopyOnWriteArrayList<>();
        private final AtomicInteger roundRobinIndex = new AtomicInteger(0);
        private volatile ChannelInfo primaryChannel;

        public ChannelGroup(String sessionId) {
            this.sessionId = sessionId;
        }

        public String getSessionId() {
            return sessionId;

     * @param dst destination buffer
     * @param dstIndex starting index in destination buffer
     * @return number of bytes written
     */
    protected abstract int writeSetupWireFormat(byte[] dst, int dstIndex);

    /**
     * Writes parameters in wire format
     * @param dst destination buffer
     * @param dstIndex starting index in destination buffer
     * @return number of bytes written
     */

            }
        } else {
            aces = null;
        }

        return bufferIndex - start;
    }

    @Override
    public String toString() {
        StringBuilder ret = new StringBuilder("SecurityDescriptor:\n");
        if (aces != null) {
            for (final ACE element : aces) {
                ret.append(element.toString()).append("\n");

    private static final String IMAGE_NAME = "dperson/samba:latest";

    private SmbClient smbClient;
    private GenericContainer<?> sambaServer;
    private String baseUrl;
    private String publicUrl;
    private String emptyUrl;
    private String deepUrl;
    private String specialUrl;

    @Override
    protected void setUp() throws Exception {

        java.util.Map<CrawlerStatus, String> statusMap = new java.util.HashMap<>();

        // Add entries
        statusMap.put(CrawlerStatus.INITIALIZING, "Starting up");
        statusMap.put(CrawlerStatus.RUNNING, "In progress");
        statusMap.put(CrawlerStatus.DONE, "Completed");

        // Verify entries
        assertEquals(3, statusMap.size());
        assertEquals("Starting up", statusMap.get(CrawlerStatus.INITIALIZING));

        final List<String> sessionIdList = new ArrayList<>();
        dataCrawlingThreadList.clear();
        final List<String> dataCrawlingThreadStatusList = new ArrayList<>();
        for (final DataConfig dataConfig : configList) {
            final DataStoreParams initParamMap = new DataStoreParams();
            final String sid = ComponentUtil.getCrawlingConfigHelper().store(sessionId, dataConfig);