*/
    public int rdmaRead(ByteBuffer buffer, long remoteAddress, int remoteKey, int length) throws IOException {
        if (!isRdmaConnected()) {
            throw new IOException("RDMA connection not available");
        }

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

                final long lastValue = lastTime.get();
                if (lastValue == 0) {
                    // First access to this host - no delay needed
                    // Set current time to allow proper delay for next access
                    lastTime.set(SystemUtil.currentTimeMillis());
                    return;
                }

                long currentTime = SystemUtil.currentTimeMillis();

        "properties" : {
          "boost" : {
            "type" : "float"
          },
          "createdBy" : {
            "type" : "keyword"
          },
          "createdTime" : {
            "type" : "long"
          },
          "permissions" : {
            "type" : "keyword"
          },
          "reading" : {
            "type" : "keyword"
          },
          "suggestWord" : {

            long ops = operations.get();
            if (ops == 0) return 0;
            return (double) latencyTotal.get() / ops;
        }
        
        public long getThroughput() {
            return bytesSent.get() + bytesReceived.get();
        }
    }
    
    public void recordOperation(String channelId, long bytes, long latency, boolean success) {

        assertEquals(WitnessRegistration.WITNESS_REGISTER_IP_NOTIFICATION, registration.getFlags());
    }

    @Test
    void testSequenceNumbers() {
        long seq1 = registration.getNextSequenceNumber();
        long seq2 = registration.getNextSequenceNumber();
        long seq3 = registration.getNextSequenceNumber();

        assertEquals(1, seq1);
        assertEquals(2, seq2);
        assertEquals(3, seq3);

    public void setCreatedBy(String value) {
        registerModifiedProperty("createdBy");
        this.createdBy = value;
    }

    public Long getCreatedTime() {
        checkSpecifiedProperty("createdTime");
        return createdTime;
    }

    public void setCreatedTime(Long value) {
        registerModifiedProperty("createdTime");
        this.createdTime = value;
    }

    public Integer getDepth() {

     * @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

        resourceManager.markClosed(id1);

        Map<String, Object> stats = resourceManager.getStatistics();

        assertNotNull(stats);
        assertTrue((long) stats.get("totalAllocated") >= 2);
        assertTrue((long) stats.get("totalReleased") >= 1);
        assertNotNull(stats.get("activeResources"));
        assertNotNull(stats.get("closedResources"));
    }

    @Test

            return 0;
        }

        @Override
        public long createTime() {
            return 0;
        }

        @Override
        public long lastModified() {
            return 0;
        }

        @Override
        public long lastAccess() {
            return 0;
        }

        @Override
        public long length() {
            return 0;
        }

        @Override

        "properties" : {
          "authRealm" : {
            "type" : "keyword"
          },
          "createdBy" : {
            "type" : "keyword"
          },
          "createdTime" : {
            "type" : "long"
          },
          "hostname" : {
            "type" : "keyword"
          },
          "parameters" : {
            "type" : "keyword"
          },
          "password" : {
            "type" : "keyword"