IllegalArgumentException exception = assertThrows(IllegalArgumentException.class, () -> referralData.stripPathConsumed(10));
            assertEquals("Stripping more than consumed", exception.getMessage());
        }

        private void setupReferralDataWithPathConsumed(int consumed) {
            when(mockReferral.getTtl()).thenReturn(300);
            when(mockReferral.getRFlags()).thenReturn(0);

        try {
            execJob.execute();
            fail("Should throw RuntimeException");
        } catch (RuntimeException e) {
            assertEquals("Test exception", e.getMessage());
        }
    }

    // Test concurrent modification of jvmOptions
    public void test_jvmOptions_concurrent() throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(2);

    ImmutableMap<Object, ImmutableList<Object>> tmpMap;
    try {
      tmpMap = builder.buildOrThrow();
    } catch (IllegalArgumentException e) {
      throw (InvalidObjectException) new InvalidObjectException(e.getMessage()).initCause(e);
    }

    FieldSettersHolder.MAP_FIELD_SETTER.set(this, tmpMap);
    FieldSettersHolder.SIZE_FIELD_SETTER.set(this, tmpSize);
  }

                sb.append(new String(buf, 0, n, "ISO8859_1"));
            }
            style = sb.toString();
        } catch (final IOException ioe) {
            throw new ServletException(ioe.getMessage());
        }

        enableBasic = Config.getBoolean("jcifs.smb1.http.enableBasic", false);
        insecureBasic = Config.getBoolean("jcifs.smb1.http.insecureBasic", false);

                index++;
            }
            return Integer.parseInt(response.substring(index, index + 3));
        } catch (final Exception ex) {
            throw new IOException(ex.getMessage());
        }
    }

    private void doHandshake() throws IOException, GeneralSecurityException {
        connect();
        try {
            int response = parseResponseCode();

            assertTrue(cause instanceof SMBProtocolDecodingException, "Actual cause should be SMBProtocolDecodingException");
            assertEquals("Structure size is not 16", cause.getMessage(), "Should have correct error message");
        }

        @Test
        @DisplayName("Should write empty bytes for wire format")
        void testWriteBytesWireFormat() throws Exception {
            // Given

                    assertThrows(SMBProtocolDecodingException.class, () -> response.readBytesWireFormat(buffer, 0));
            assertEquals("Expected structureSize = 60", exception.getMessage());
        }

        @ParameterizedTest
        @ValueSource(ints = { 0, 10, 20, 30 })
        @DisplayName("Should correctly read from different buffer offsets")

            } catch (final UnknownHostException ex) {
                this.uhe = ex;
            } catch (final Exception ex) {
                this.uhe = new UnknownHostException(ex.getMessage());
            } finally {
                synchronized (this.sem) {
                    this.sem.count--;
                    this.sem.notify();
                }
            }
        }

        try {
            indexUpdater.run();
            fail("Should throw FessSystemException");
        } catch (FessSystemException e) {
            assertEquals("DataService is null.", e.getMessage());
        }
    }

    // Test run method basic flow
    public void test_run_basicFlow() throws Exception {
        final List<String> sessionIdList = Arrays.asList("session1");

        final CmdLineParser parser = new CmdLineParser(options);
        try {
            parser.parseArgument(args);
        } catch (final CmdLineException e) {
            System.err.println(e.getMessage());
            System.err.println("java " + Crawler.class.getCanonicalName() + " [options...] arguments...");
            parser.printUsage(System.err);
            return;
        }