}
    
    public void recordRdmaWrite(int bytes) {
        rdmaWrites.incrementAndGet();
        bytesTransferred.addAndGet(bytes);
    }
    
    public void recordError() {
        operationErrors.incrementAndGet();
    }
    
    public double getErrorRate() {
        long total = rdmaReads.get() + rdmaWrites.get() + rdmaSends.get() + rdmaReceives.get();
        if (total == 0) return 0.0;

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

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

     * 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();
    private final AtomicLong bytesTransferred = new AtomicLong();