if (logger.isInfoEnabled()) {
                logger.info("GSA XML import completed successfully: fileName={}", fileName);
            }
        } catch (final Exception e) {
            logger.warn("Failed to insert GSA XML data into database: fileName={}, error={}", fileName, e.getMessage(), e);
        } finally {
            deleteTempFile(tempFile);
        }

        assertEquals(0, decodedEnumEx.retval);
        assertEquals(info.level, decodedEnumEx.info.level);
        assertTrue(decodedEnumEx.info.e instanceof netdfs.DfsEnumArray1);
        assertEquals(((netdfs.DfsEnumArray1) info.e).count, ((netdfs.DfsEnumArray1) decodedEnumEx.info.e).count);
        assertEquals(((netdfs.DfsEnumArray1) info.e).s[0].entry_path, ((netdfs.DfsEnumArray1) decodedEnumEx.info.e).s[0].entry_path);

     *
     * @param config
     *            the configuration to use for this request
     * @param fileId
     *            the file ID to read from
     * @param outputBuffer
     *            the buffer to read data into
     * @param outputBufferOffset
     *            the offset in the output buffer to start writing data
     */

        // put cralwing info
        final CrawlingInfoHelper crawlingInfoHelper = ComponentUtil.getCrawlingInfoHelper();

        final long execTime = systemHelper.getCurrentTimeAsLong() - startTime;
        crawlingInfoHelper.putToInfoMap(Constants.DATA_CRAWLING_EXEC_TIME, Long.toString(execTime));
        if (logger.isInfoEnabled()) {
            logger.info("[EXEC TIME] crawling time: {}ms", execTime);
        }

        assertArrayEquals(mic, res);
        verify(gssContext, times(1)).getMIC(eq(data), eq(0), eq(3), any());
    }

    @Test
    @DisplayName("calculateMIC wraps GSSException into CIFSException")
    void calculateMIC_failure_wraps() throws Exception {
        byte[] data = new byte[] { 0 };
        when(gssContext.getMIC(any(), anyInt(), anyInt(), any())).thenThrow(new GSSException(GSSException.FAILURE));

        SmbShareInfo info = new SmbShareInfo(TEST_NET_NAME, TEST_TYPE, TEST_REMARK);

        // Verify all values are set correctly
        assertEquals(TEST_NET_NAME, info.getName());
        assertEquals(SmbConstants.TYPE_SHARE, info.getType());
        assertNotNull(info.toString());
        assertTrue(info.toString().contains(TEST_NET_NAME));
        assertTrue(info.toString().contains(TEST_REMARK));
    }

 * <p>
 * {@link ESSourceReader} reads documents from Elasticsearch using the scroll API.
 * It implements the {@link DocumentReader} interface to provide a way to iterate over documents
 * in a large index without loading all of them into memory at once.
 * </p>
 *
 * <p>
 * The reader supports limiting the number of documents read based on a percentage of the total documents

                }

                // Perform the actual reconnection
                boolean success = performReconnection(info);

                if (success) {
                    handleManager.completeReconnect(info.getPath(), true);
                    log.info("Successfully reconnected handle: {}", info.getPath());
                    return info;

        assertNotNull(guid);
        assertEquals(1, manager.getHandleCount());

        HandleInfo info = manager.getHandleByGuid(guid);
        assertNotNull(info);
        assertEquals("/test/file.txt", info.getPath());
        assertEquals(HandleType.DURABLE_V2, info.getType());
        assertEquals(120000, info.getTimeout());
    }

    @Test
    public void testUpdateHandleFileId() {

        HandleInfo info = guidToHandle.get(guid);
        if (info != null) {
            System.arraycopy(fileId, 0, info.fileId, 0, 16);
            if (info.type == HandleType.PERSISTENT) {
                persistHandle(info);
            }
        }
    }
    
    public HandleInfo getHandleForReconnect(String path) {
        HandleInfo info = handles.get(path);
        if (info != null && !info.isExpired()) {