}

    // Test execute with timeout
    @Test
    public void test_execute_withTimeout() {
        pythonJob.filename("timeout.py");
        pythonJob.timeout = 60; // Set timeout
        pythonJob.processTimeout = true;

        testProcessHelper.exitValue = -1;
        testProcessHelper.processOutput = "Process terminated";

 * \r} or {@code \r\n}, do not include the line separator in each line and do not consider there to
 * be an empty line at the end if the contents are terminated with a line separator.
 *
 * <p>Any {@link ByteSource} containing text encoded with a specific {@linkplain Charset character
 * encoding} may be viewed as a {@code CharSource} using {@link ByteSource#asCharSource(Charset)}.
 *

   * executor will not be {@linkplain ScheduledExecutorService#shutdown shutdown} when this service
   * {@linkplain Service.State#TERMINATED terminates} or {@linkplain Service.State#TERMINATED
   * fails}. Subclasses may override this method to supply a custom {@link ScheduledExecutorService}
   * instance. This method is guaranteed to only be called once.
   *

   * structures.
   *
   * We make such subtle calls in [okhttp3.internal.ws.MessageInflater] because we try to read a
   * compressed stream that is terminated in a web socket frame even though the DEFLATE stream is
   * not terminated.
   *
   * Use this method to create a degenerate Okio Buffer where each byte is in a separate segment of
   * the internal list.
   */
  @JvmStatic

    }

    @Test
    @DisplayName("Test decode with null-terminated Unicode filename")
    void testDecodeWithNullTerminatedUnicodeFilename() throws SMBProtocolDecodingException {
        // Prepare test data with null-terminated filename
        String expectedFilename = "nullterm.txt";

                logger.error("IndexUpdater is terminated.", e);
            } else if (logger.isInfoEnabled()) {
                logger.info("IndexUpdater is terminated.");
            }
            forceStop();
        } catch (final Throwable t) {
            if (ComponentUtil.available()) {
                logger.error("IndexUpdater is terminated.", t);
            } else if (logger.isDebugEnabled()) {

        thumbnailJob.timeout = 120; // Set timeout
        thumbnailJob.processTimeout = true;

        testProcessHelper.exitValue = -1;
        testProcessHelper.processOutput = "Process terminated";

        String result = thumbnailJob.execute();

        assertNotNull(result);
        assertNotNull(thumbnailJob.sessionId);
        assertTrue(result.contains("Session Id: " + thumbnailJob.sessionId));

        }
      }
      assertThat(service.state()).isNotEqualTo(from);
    }

    @Override
    public synchronized void terminated(State from) {
      assertEquals(from, Iterables.getLast(stateHistory, State.NEW));
      stateHistory.add(State.TERMINATED);
      assertEquals(State.TERMINATED, service.state());
      if (from == State.NEW) {
        try {
          service.awaitRunning();
          fail();

        }
      }
      assertThat(service.state()).isNotEqualTo(from);
    }

    @Override
    public synchronized void terminated(State from) {
      assertEquals(from, Iterables.getLast(stateHistory, State.NEW));
      stateHistory.add(State.TERMINATED);
      assertEquals(State.TERMINATED, service.state());
      if (from == State.NEW) {
        try {
          service.awaitRunning();
          fail();

        byte[] dst = new byte[100];
        int bytesWritten = smbComQueryInformation.writeBytesWireFormat(dst, 0);

        // Expected format: buffer format (1 byte) + file name (null-terminated)
        int expectedLength = 1 + TEST_FILE_NAME.length() + 1;
        assertEquals(expectedLength, bytesWritten);
        assertEquals(0x04, dst[0]); // Buffer format