if (!isRdmaConnected()) {
            throw new IOException("RDMA connection not available");
        }

        try {
            statistics.recordWriteRequest(length);
            long startTime = System.nanoTime();

            int bytesWritten = rdmaConnection.write(buffer, remoteAddress, remoteKey, length);

            long duration = System.nanoTime() - startTime;

    public void recordReadError() {
        recordError();
    }

    /**
     * Record start of a write request
     *
     * @param bytes number of bytes being written
     */
    public void recordWriteRequest(int bytes) {
        // Track that a write was requested
        rdmaWrites.incrementAndGet();
    }

    /**
     * Record successful completion of a write request
     *