super.setUp(testInfo);
        purgeDocJob = new PurgeDocJob();

        // Reset flags and variables
        deleteByQueryCalled = false;
        deleteIndex = null;
        deleteQuery = null;
        expiresFieldName = "expires";
        documentUpdateIndex = "fess.update";

        // Create mock SearchEngineClient
        searchEngineClient = new SearchEngineClient() {
            @Override

        when(config.getNotifyBufferSize()).thenReturn(8192);
        Smb2ChangeNotifyRequest req = new Smb2ChangeNotifyRequest(config, fileId);
        byte[] buffer = new byte[512];
        req.writeBytesWireFormat(buffer, 0);

        byte[] readFileId = new byte[16];
        System.arraycopy(buffer, 8, readFileId, 0, 16);
        assertArrayEquals(fileId, readFileId);
    }

    @Test

                    Arguments.of(new int[0], 4), // size() returns 4 for empty array
                    Arguments.of(new int[] { 1 }, 4 + 2), // size() returns 4 + 2*1
                    Arguments.of(new int[] { 1, 2 }, 4 + 4), // size() returns 4 + 2*2
                    Arguments.of(new int[] { 1, 2, 3, 4, 5 }, 4 + 10) // size() returns 4 + 2*5
            );
        }

    // PatternFilterable -> reason why skipped.
    private final Map<PatternFilterable, String> skippedTestByFilePatternTransformations = new HashMap<>();
    // PatternFilterable -> list of full test names and reasons. Needed for 1 pattern may include many tests and reasons
    private final Map<PatternFilterable, List<Pair<String, String>>> skippedTestByTestNameTransformations = new HashMap<>();

    @Inject

        MsrpcSamrConnect2 msrpcSamrConnect2 = new MsrpcSamrConnect2(testServer, testAccess, mockPolicyHandle);

        // Then
        assertEquals(0x39, msrpcSamrConnect2.getOpnum(), "Should have opnum 0x39 from parent class");
    }

    @Test
    @DisplayName("Should work with null server name")
    void shouldHandleNullServerName() {
        // When

            modelValueSource2 = new ProblemDetectingValueSource(modelValueSource2, "", "project.", problems);
        }

        // NOTE: Order counts here!
        List<ValueSource> valueSources = new ArrayList<>(9);

        if (projectDir != null) {
            ValueSource basedirValueSource = new PrefixedValueSourceWrapper(
                    new AbstractValueSource(false) {
                        @Override

            int bytesRead2 = stream2.read(buffer2);
            assertEquals(testContent, new String(buffer2, 0, bytesRead2, "UTF-8"));
        }
    }

    @Test
    public void testMemoryBasedCacheWithEmptyData() throws IOException {
        byte[] data = new byte[0];
        ContentCache cache = new ContentCache(data);

        try (InputStream stream = cache.getInputStream()) {

        final Pattern parsePattern = Pattern.compile("(.*?)\\s*+=>\\s*+(.*?)\\s*+$");
        final List<StemmerOverrideItem> itemList = new ArrayList<>();
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {
            long id = 0;
            String line = null;
            while ((line = reader.readLine()) != null) {

  }

  public void testFailStart() throws Exception {
    Service a = new NoOpService();
    Service b = new FailStartService();
    Service c = new NoOpService();
    Service d = new FailStartService();
    Service e = new NoOpService();
    ServiceManager manager = new ServiceManager(asList(a, b, c, d, e));
    RecordingListener listener = new RecordingListener();
    manager.addListener(listener, directExecutor());

        String values;

        protocols = new String[] { "http:" };
        values = "http://www.foo.com/";
        assertTrue(UriTypeValidator.check(protocols, values));

        protocols = new String[] { "http:" };
        values = "http://www.foo.com/\nhttp://www.bar.com/";
        assertTrue(UriTypeValidator.check(protocols, values));

        protocols = new String[] { "http:" };