}

    @Test
    public void testReleaseSendRegion() throws Exception {
        RdmaMemoryRegion region = bufferManager.getSendRegion(1024);
        assertNotNull(region);

        // Release should not throw exception
        assertDoesNotThrow(() -> bufferManager.releaseSendRegion(region));
    }

    @Test
    public void testGetReceiveRegion() throws Exception {

    }

    /**
     * @throws Exception
     */
    @Test
    public void testCopyBeanToBean_whitespace() throws Exception {
        final SrcBean src = new SrcBean();
        src.ccc = " ";
        final DestBean dest = new DestBean();
        BeanUtil.copyBeanToBean(src, dest);
        assertThat(dest.ccc, is(" "));
    }

    /**
     * @throws Exception
     */
    @Test

                bindWithNullBinding.encode_in(mockBuffer);
            }, "Should throw NullPointerException when binding is null");
        }

        @Test
        @DisplayName("encode_in should use default constructor values")
        void testEncodeInDefaultConstructor() throws Exception {
            // Given
            DcerpcBind defaultBind = new DcerpcBind();

     * @throws NdrException if encoding fails
     */
    public abstract void encode_in(NdrBuffer buf) throws NdrException;

    /**
     * Decode the output parameters from this DCERPC message.
     * @param buf the buffer to decode from
     * @throws NdrException if decoding fails
     */
    public abstract void decode_out(NdrBuffer buf) throws NdrException;

        authenticator = null;
    }

    @AfterEach
    public void tearDown() throws Exception {
        if (authenticator != null) {
            authenticator.close();
        }
    }

    @Test
    @DisplayName("Test password stored as char array")
    void testPasswordStoredAsCharArray() throws Exception {
        authenticator = new NtlmPasswordAuthenticator("DOMAIN", "username", "password123");

        // TCP fallback doesn't support real RDMA read
        throw new UnsupportedOperationException("RDMA read not supported by TCP fallback");
    }

    @Override
    public void rdmaWrite(RdmaMemoryRegion localRegion, long remoteAddress, int remoteKey, int length) throws IOException {
        // TCP fallback doesn't support real RDMA write

   *
   * @throws TimeoutException if this thread does not offer a response within a reasonable amount of
   *     time
   * @throws AssertionFailedError if the given method name does not match the name of the method
   *     this thread has called most recently
   */
  private Response getResponse(String methodName) throws Exception {
    Response response = responseQueue.poll(TIMEOUT_MILLIS, MILLISECONDS);

        new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {
              throw new IllegalStateException("More than one source open");
            }
            return new FilterInputStream(source.openStream()) {
              @Override
              public void close() throws IOException {
                super.close();
                counter[0]--;

    return new Callable<T>() {
      @Override
      public T call() throws Exception {
        throw exception;
      }
    };
  }

  private static Runnable runnableThrowing(RuntimeException e) {
    return new Runnable() {
      @Override
      public void run() {
        throw e;
      }
    };
  }

  @SuppressWarnings("serial")

     * @throws IllegalAccessRuntimeException {@link IllegalAccessException} if an error occurs
     * @see Field#getInt(Object)
     */
    public static int getInt(final Field field, final Object target) throws IllegalAccessRuntimeException {
        assertArgumentNotNull("field", field);

        try {
            return field.getInt(target);
        } catch (final IllegalAccessException ex) {