Arguments.of(makeSeq(10), 2, 5, 3), // middle slice, non-zero dst index
                Arguments.of(makeSeq(4), 4, 0, 0), // zero-length slice at end
                Arguments.of(makeSeq(16), 7, 3, 0), // small slice from middle
                Arguments.of(makeSeq(16), 0, 0, 5) // zero-length with non-zero dst index
        );
    }

    // Creates a deterministic byte sequence [0,1,2,...,n-1]

                });
            }

            for (Thread t : threads) {
                t.start();
            }
            for (Thread t : threads) {
                t.join();
            }

            // Verify all arrays were signed
            for (byte[] arr : dataArrays) {
                byte[] signature = Arrays.copyOfRange(arr, SIGNATURE_OFFSET, SIGNATURE_OFFSET + SIGNATURE_LENGTH);

            Thread thread2 = new Thread(() -> transportPool.getSmbTransport(context, address, DEFAULT_PORT, true));

            thread1.start();
            thread2.start();
            thread1.join();
            thread2.join();

            // Then
            verify(transportPool, times(2)).getSmbTransport(any(), any(Address.class), anyInt(), anyBoolean());
        }

        @Test

        IOException ex = assertThrows(IOException.class, () -> new NegTokenInit(token));
        assertTrue(ex.getMessage().contains("OID"), "Error should mention OID");
    }

    @Test
    @DisplayName("Parse accepts non-zero outer tag numbers (current implementation behavior)")
    void testParseAcceptsNonZeroOuterTag() throws Exception {
        // Note: The current implementation does not validate the outer APPLICATION tag number

    @Test
    @DisplayName("accept: returns false for non-directories")
    void accept_returnsFalseForNonDirectory() throws Exception {
        // Arrange
        SmbFileFilter filter = f -> f.isDirectory();
        when(smbFile.isDirectory()).thenReturn(false);

        // Act
        boolean result = filter.accept(smbFile);

        // Assert
        assertFalse(result, "Non-directory should be rejected");

            assertFalse(message.isFlagSet(DcerpcConstants.RPC_C_PF_BROADCAST));
            assertTrue(message.isFlagSet(DcerpcConstants.RPC_C_PF_NO_FRAGMENT));

            // Test unsetting a non-existing flag
            message.flags = DcerpcConstants.RPC_C_PF_BROADCAST;
            message.unsetFlag(DcerpcConstants.RPC_C_PF_IDEMPOTENT);
            assertTrue(message.isFlagSet(DcerpcConstants.RPC_C_PF_BROADCAST));

     */
    protected String charsetName = Constants.UTF_8;

    /**
     * Creates a new TextTransformer instance.
     */
    public TextTransformer() {
        super();
    }

    /*
     * (non-Javadoc)
     *
     * @see
     * org.codelibs.fess.crawler.transformer.impl.AbstractTransformer#transform(org.fess.crawler.entity.ResponseData)
     */
    @Override

    /**
     * Test get method with non-existing type
     */
    @Test
    @DisplayName("Get should return null for non-existing type")
    void testGetNonExistingType() {
        List<AvPair> pairs = new LinkedList<>();
        pairs.add(new AvFlags(0x12345678));

        AvPair result = AvPairs.get(pairs, AvPair.MsvAvTargetName);
        assertNull(result, "Should return null for non-existing type");
    }

    /**

# This file is used with all of the non-matrix tests in Jenkins.

# This .properties file defines the versions of Java with which to
# build and test Elasticsearch for this branch. Valid Java versions
# are 'java' or 'openjdk' followed by the major release number.

ES_BUILD_JAVA=openjdk16

    @Override
    protected void setUp() throws Exception {
        super.setUp();
        extractor = new TestExtractor();
    }

    /**
     * Test that validateInputStream accepts non-null input streams.
     */
    public void test_validateInputStream_acceptsNonNullStream() {
        final InputStream in = new ByteArrayInputStream(new byte[0]);

        // Should not throw exception