context = new PreauthIntegrityNegotiateContext(mockConfig, new int[3], new byte[32]);
            assertEquals(4 + 6 + 32, context.size()); // header + 3*2 + 32

            context = new PreauthIntegrityNegotiateContext(mockConfig, null, new byte[16]);
            assertEquals(4 + 16, context.size());

            context = new PreauthIntegrityNegotiateContext(mockConfig, new int[5], null);

        final SuggestItem item = new SuggestItem();
        item.setText(text);
        item.setReadings(readings.toArray(new String[readings.size()][]));
        item.setFields(fields.toArray(new String[fields.size()]));
        item.setDocFreq(docFreq);
        item.setQueryFreq(queryFreq);
        item.setUserBoost(userBoost);
        item.setTags(tags.toArray(new String[tags.size()]));

    HashingOutputStream out = new HashingOutputStream(sha512(), buffer);

    out.write(buf);

    assertEquals(expectedHash, out.hash());
  }

  public void testChecksForNull() throws Exception {
    NullPointerTester tester = new NullPointerTester();
    tester.testAllPublicInstanceMethods(
        new HashingOutputStream(sha512(), new ByteArrayOutputStream()));

        when(mockSid1.unwrap(sid_t.class)).thenReturn(mockSidT);
        when(mockSid2.unwrap(sid_t.class)).thenReturn(mockSidT);
        testSids = new jcifs.SID[] { mockSid1, mockSid2 };

        // Act
        lookupSids = new MsrpcLookupSids(mockPolicyHandle, testSids);

        // Assert
        assertNotNull(lookupSids);
        assertEquals(0, lookupSids.getPtype());

        final GroovyEngine engine = new GroovyEngine();
        final int threadCount = 8;
        final int iterationsPerThread = 50;
        final ExecutorService executor = Executors.newFixedThreadPool(threadCount);
        final CountDownLatch startLatch = new CountDownLatch(1);
        final AtomicInteger errors = new AtomicInteger(0);

        final List<Future<?>> futures = new ArrayList<>();

    @BeforeEach
    void setUp() {
        mockConfig = mock(Configuration.class);
        response = new Smb2TreeDisconnectResponse(mockConfig);
    }

    @Test
    @DisplayName("Should create response with configuration")
    void testConstructorWithConfiguration() {
        // Given & When
        Smb2TreeDisconnectResponse resp = new Smb2TreeDisconnectResponse(mockConfig);

        // Then
        assertNotNull(resp);

        // Poll concurrently
        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch doneLatch = new CountDownLatch(numThreads);
        final AtomicInteger totalPolled = new AtomicInteger(0);
        final List<String> allUrls = new ArrayList<>();

        for (int i = 0; i < numThreads; i++) {
            new Thread(() -> {
                try {
                    startLatch.await();

        List<String> missingFiles = new ArrayList<>();

        Gson gson = new Gson();
        List<AdocFileEntry> entries;
        try (FileReader reader = new FileReader(jsonFile)) {
            entries = gson.fromJson(reader, new TypeToken<List<AdocFileEntry>>() {}.getType());
        }

        Set<String> foundAdocFiles = new HashSet<>();

    Object unused1 = new Object() {};
    Object unused2 = new Object() {};
    Object unused3 = new Object() {};
    Object unused4 = new Object() {};
    Object unused5 = new Object() {};
    Object unused6 = new Object() {};
    Object unused7 = new Object() {};
    Object unused8 = new Object() {};
    Object unused9 = new Object() {};
    Object o10 = new Object() {};

        try {
            startLatch = new CountDownLatch(size);
            endLatch = new CountDownLatch(size);
            Map<String, String> output = new ConcurrentHashMap<String, String>();

            try (SimplexTransferListener listener = new SimplexTransferListener(new ConsoleMavenTransferListener(
                    new JLineMessageBuilderFactory(),
                    new PrintWriter(System.out) {