totalReceiveTime.set(0);
    }

    /**
     * Record start of a read request
     *
     * @param bytes number of bytes being requested
     */
    public void recordReadRequest(int bytes) {
        // Track that a read was requested
        rdmaReads.incrementAndGet();
    }

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

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

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

            int bytesRead = rdmaConnection.read(buffer, remoteAddress, remoteKey, length);

            long duration = System.nanoTime() - startTime;