Integer timeout = 5000;
            testRequest.setOverrideTimeout(timeout);
            assertEquals(timeout, testRequest.getOverrideTimeout());
        }

        @Test
        @DisplayName("setOverrideTimeout should handle null value")
        void testSetOverrideTimeoutNull() {
            testRequest.setOverrideTimeout(5000);
            testRequest.setOverrideTimeout(null);

            when(mockReferral.getExpandedNames()).thenReturn(new String[] { "\\SERVER1", "\\SERVER2" });

            String reqPath = "\\\\domain\\root\\path";
            long expire = System.currentTimeMillis() + 30000;
            int consumed = 15;

            DfsReferralDataImpl result = DfsReferralDataImpl.fromReferral(mockReferral, reqPath, expire, consumed);

            assertNotNull(result);

            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {
                logger.info("Python: Exit Code={} - Process Output:\n{}", exitValue, it.getOutput());

            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {
                logger.info("SuggestCreator: Exit Code={} - Process Output:\n{}", exitValue, it.getOutput());

            int result = response.decode(largeBuffer, 1000, 5000);
            assertEquals(5000, result);
            assertEquals(5000, response.getData().length);
        }

        @Test
        @DisplayName("Should handle empty name array")
        void testEmptyNameArray() {
            byte[] emptyName = new byte[0];

    private static final Logger logger = LogManager.getLogger(PdfExtractor.class);

    /** Timeout for PDF extraction in milliseconds (default: 30 seconds). */
    protected long timeout = 30000; // 30sec

    /** Whether the extraction thread should be a daemon thread. */
    protected boolean isDaemonThread = false;

    /**
     * Creates a new PdfExtractor instance.
     */
    public PdfExtractor() {

            it.start();

            final Process currentProcess = jobProcess.getProcess();
            currentProcess.waitFor();
            it.join(5000);

            final int exitValue = currentProcess.exitValue();

            if (logger.isInfoEnabled()) {
                logger.info("ThumbnailGenerator: Exit Code={} - Process Output:\n{}", exitValue, it.getOutput());

    private static final int WITNESS_INTERFACE_VERSION = 1;

    // RPC connection parameters
    private static final int WITNESS_RPC_PORT = 135;
    private static final int WITNESS_RPC_TIMEOUT_MS = 5000;

    // RPC operation numbers
    private static final int WITNESS_REGISTER = 0;
    private static final int WITNESS_UNREGISTER = 1;
    private static final int WITNESS_ASYNC_NOTIFY = 2;

        assertEquals((byte) 0x00, getFieldValue(netShareEnum, "maxSetupCount"));
        assertEquals(0, getFieldValue(netShareEnum, "setupCount"));
        assertEquals(5000, getFieldValue(netShareEnum, "timeout"));

        // Verify command and subcommand from parent class
        assertEquals(SmbComTransaction.SMB_COM_TRANSACTION, getFieldValue(netShareEnum, "command"));

        keyManager.configureKeyRotation(60000);

        // Test disabling rotation
        keyManager.configureKeyRotation(0);

        // Test reconfiguring
        keyManager.configureKeyRotation(30000);
    }

    @Test
    public void testConcurrentKeyOperations() throws InterruptedException {
        int threadCount = 10;
        int operationsPerThread = 50;