RateLimiter rateLimiter =
              RateLimiter.create(qps, warmupMillis, MILLISECONDS, coldFactor, stopwatch);
          assertEquals(warmupMillis, measureTotalTimeMillis(rateLimiter, warmupPermits, random));
        }
      }
    }
  }

  public void testNulls() {
    NullPointerTester tester =
        new NullPointerTester()

            int bytesWritten = context.encode(buffer, 0);

            assertEquals(12, bytesWritten);
            assertEquals(3, SMBUtil.readInt2(buffer, 0));
            assertEquals(2, SMBUtil.readInt2(buffer, 2));
            assertEquals(0x01, SMBUtil.readInt2(buffer, 4));
            assertEquals(0x02, SMBUtil.readInt2(buffer, 6));
            assertEquals(0x03, SMBUtil.readInt2(buffer, 8));

        assertEquals(0x00000001, DcerpcError.DCERPC_FAULT_OTHER);
    }

    @Test
    @DisplayName("Should verify DCERPC_FAULT_ACCESS_DENIED constant value")
    void testDcerpcFaultAccessDenied() {
        assertEquals(0x00000005, DcerpcError.DCERPC_FAULT_ACCESS_DENIED);
    }

    @Test
    @DisplayName("Should verify DCERPC_FAULT_CANT_PERFORM constant value")
    void testDcerpcFaultCantPerform() {

        // Act & Assert
        Assertions.assertEquals(attributes, info.getAttributes());
        Assertions.assertEquals(createTime, info.getCreateTime());
        Assertions.assertEquals(lastWrite, info.getLastWriteTime());
        Assertions.assertEquals(lastAccess, info.getLastAccessTime());
        Assertions.assertEquals(size, info.getSize());
    }

    // Supplies a range of normal and edge case values.

  /**
   * Returns the innermost cause of {@code throwable}. The first throwable in a chain provides
   * context from when the error or exception was initially detected. Example usage:
   *
   * <pre>
   * assertEquals("Unable to assign a customer id", Throwables.getRootCause(e).getMessage());
   * </pre>
   *
   * @throws IllegalArgumentException if there is a loop in the causal chain
   */

            int result = notification.writeBytesWireFormat(buffer, 0);
            assertEquals(0, result);

            // Test with different offsets
            result = notification.writeBytesWireFormat(buffer, 10);
            assertEquals(0, result);

            result = notification.writeBytesWireFormat(buffer, 50);
            assertEquals(0, result);
        }

        @Test

  /**
   * Returns the innermost cause of {@code throwable}. The first throwable in a chain provides
   * context from when the error or exception was initially detected. Example usage:
   *
   * <pre>
   * assertEquals("Unable to assign a customer id", Throwables.getRootCause(e).getMessage());
   * </pre>
   *
   * @throws IllegalArgumentException if there is a loop in the causal chain
   */

    RdmaMemoryRegion region = provider.registerMemory(buffer, 
        EnumSet.of(RdmaAccess.LOCAL_READ, RdmaAccess.REMOTE_READ));
    
    assertNotNull(region);
    assertEquals(4096, region.getSize());
    assertTrue(region.hasAccess(RdmaAccess.LOCAL_READ));
    
    region.close();
}

@Test
public void testRdmaBufferManager() throws Exception {

            int bytesRead = in.read(buffer);
            assertEquals(10, bytesRead, "Should read requested bytes");
            assertEquals("0123456789", new String(buffer, 0, bytesRead, "UTF-8"));

            // Read next chunk
            bytesRead = in.read(buffer);
            assertEquals(10, bytesRead, "Should read next chunk");
            assertEquals("ABCDEFGHIJ", new String(buffer, 0, bytesRead, "UTF-8"));
        }

        assertTrue(avgReleaseTimeNs < 10000, "Average release should be under 10000ns (O(1) performance)");
        assertEquals(threadCount * operationsPerThread, allocations.get());
        assertEquals(threadCount * operationsPerThread, releases.get());

        // Verify cache statistics
        String stats = BufferCache.getCacheStatistics();