} catch (Exception e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("DiSNI RDMA receive failed", e);
        }
    }

    @Override
    public void rdmaRead(RdmaMemoryRegion localRegion, long remoteAddress, int remoteKey, int length) throws IOException {
        if (state != RdmaConnectionState.ESTABLISHED) {
            throw new IOException("Connection not established");
        }

     * @param remoteKey remote access key
     * @param length number of bytes to read
     * @return number of bytes read
     * @throws IOException if operation fails
     */
    public int rdmaRead(ByteBuffer buffer, long remoteAddress, int remoteKey, int length) throws IOException {
        if (!isRdmaConnected()) {
            throw new IOException("RDMA connection not available");
        }

        try {

        } catch (IOException e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("TCP RDMA receive failed", e);
        }
    }

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

     * @param remoteAddress remote memory address
     * @param remoteKey remote memory key
     * @param length number of bytes to read
     * @throws IOException if read fails
     */
    public abstract void rdmaRead(RdmaMemoryRegion localRegion, long remoteAddress, int remoteKey, int length) throws IOException;

    /**
     * Perform RDMA write operation
     *
     * @param localRegion local memory region to write from

    /**
     * Receive data using RDMA  
     */
    public abstract ByteBuffer receive(int timeout) throws IOException;
    
    /**
     * Perform RDMA read operation
     */
    public abstract void rdmaRead(RdmaMemoryRegion localRegion, 
                                 long remoteAddress, 
                                 int remoteKey,
                                 int length) throws IOException;
    
    /**

 */
public class RdmaStatistics {

    /**
     * Creates a new RDMA statistics tracker
     */
    public RdmaStatistics() {
        // Default constructor
    }

    private final AtomicLong rdmaReads = new AtomicLong();
    private final AtomicLong rdmaWrites = new AtomicLong();
    private final AtomicLong rdmaSends = new AtomicLong();
    private final AtomicLong rdmaReceives = new AtomicLong();

/**
 * RDMA capability flags indicating what operations are supported
 * by an RDMA provider implementation.
 */
public enum RdmaCapability {
    /**
     * Remote direct read operations
     */
    RDMA_READ,

    /**
     * Remote direct write operations
     */
    RDMA_WRITE,

    /**
     * Traditional send/receive with RDMA
     */
    RDMA_SEND_RECEIVE,

    /**

        assertTrue(capabilities.contains(RdmaCapability.RDMA_SEND_RECEIVE), "Should support send/receive");
        assertFalse(capabilities.contains(RdmaCapability.RDMA_READ), "Should not support RDMA read");
        assertFalse(capabilities.contains(RdmaCapability.RDMA_WRITE), "Should not support RDMA write");
    }

    @Test
    public void testCreateConnection() throws Exception {