Formatter logFormatter =
        new Formatter() {
          @Override
          public String format(LogRecord record) {
            return formatMessage(record);
          }
        };
    for (LogRecord record : logHandler.getStoredLogRecords()) {
      assertThat(logFormatter.format(record)).doesNotContain("NoOpService");
    }
  }

  public void testStartupFailureOutput() {

        assertEquals(SmbComTransaction.TRANS_WAIT_NAMED_PIPE, transWaitNamedPipe.getSubCommand());
    }

    @Test
    @DisplayName("Multiple wire format operations should be consistent")
    void testMultipleWireFormatOperations() {
        // Arrange
        transWaitNamedPipe = new TransWaitNamedPipe(mockConfig, testPipeName);
        byte[] dst1 = new byte[10];

     * @throws SmbException if the textual format is invalid
     */
    public SID(final String textual) throws SmbException {
        final StringTokenizer st = new StringTokenizer(textual, "-");
        if (st.countTokens() < 3 || !st.nextToken().equals("S")) {
            // need S-N-M
            throw new SmbException("Bad textual SID format: " + textual);
        }

    /**
     * Record a write operation error
     */
    public void recordWriteError() {
        recordError();
    }

    @Override
    public String toString() {
        return String.format(
                "RdmaStatistics[reads=%d, writes=%d, sends=%d, receives=%d, "
                        + "bytes=%d, errors=%d, errorRate=%.3f, activeConnections=%d, activeMemRegions=%d]",

     * is used internally be jCIFS when parsing SMB URLs.
     *
     * @param tc the CIFS context to use
     * @param userInfo the user information string in the format "domain;user:pass"
     */
    public NtlmPasswordAuthentication(final CIFSContext tc, final String userInfo) {
        super(userInfo, tc.getConfig().getDefaultDomain(),

  public void testAddAll_nullSupported() {
    List<E> containsNull = singletonList(null);
    assertTrue("addAll(containsNull) should return true", collection.addAll(containsNull));
    /*
     * We need (E) to force interpretation of null as the single element of a
     * varargs array, not the array itself
     */
    expectAdded((E) null);
  }

  @CollectionFeature.Require(value = SUPPORTS_ADD, absent = ALLOWS_NULL_VALUES)

    testAddAndRemove(new ConcurrentSkipListMap<>());
  }

  public void testAddAndRemove_mapMakerMap() throws Exception {
    MapMaker mapMaker = new MapMaker();
    // force MapMaker to use its own MapMakerInternalMap
    mapMaker.useCustomMap = true;
    testAddAndRemove(mapMaker.makeMap());
  }

  private void testAddAndRemove(ConcurrentMap<String, AtomicInteger> map)

        context2.close();
    }

    private String bytesToHex(byte[] bytes) {
        StringBuilder result = new StringBuilder();
        for (byte b : bytes) {
            result.append(String.format("%02x", b));
        }
        return result.toString();
    }

    private boolean isAllZeros(byte[] array) {
        for (byte b : array) {
            if (b != 0) {
                return false;

        for (int i = startIndex + bytesWritten; i < dst.length; i++) {
            assertEquals((byte) (i & 0xFF), dst[i]);
        }
    }

    @Test
    @DisplayName("Test setup wire format structure")
    void testSetupWireFormatStructure() {
        notifyChange = new NtTransNotifyChange(mockConfig, 0xABCD, 0x12345678, true);
        byte[] dst = new byte[100];

        return handle;
    }

    @Nested
    @DisplayName("Constructor Tests")
    class ConstructorTests {

        @Test
        @DisplayName("Should throw DcerpcException for invalid URL format")
        void testConstructor_InvalidUrl() {
            String invalidUrl = "invalid:server";
            assertThrows(DcerpcException.class, () -> new DcerpcPipeHandle(invalidUrl, mockContext, false),