bytesTransferred.addAndGet(bytes);
        totalSendTime.addAndGet(durationNanos);
    }

    /**
     * Record an RDMA receive operation
     *
     * @param bytes number of bytes received
     * @param durationNanos operation duration in nanoseconds
     */
    public void recordRdmaReceive(int bytes, long durationNanos) {
        rdmaReceives.incrementAndGet();
        bytesTransferred.addAndGet(bytes);

                        long start = System.nanoTime();
                        mockBytesEncrypted.addAndGet(1024); // Simulate 1KB message
                        long end = System.nanoTime();

                        totalTime.addAndGet(end - start);
                        operations.incrementAndGet();
                    }
                } catch (InterruptedException e) {

     *
     * @param bytes number of bytes
     */
    public void addBytesSent(long bytes) {
        bytesSent.addAndGet(bytes);
    }

    /**
     * Add bytes received
     *
     * @param bytes number of bytes
     */
    public void addBytesReceived(long bytes) {
        bytesReceived.addAndGet(bytes);
    }

    /**
     * Increment requests sent counter
     */

   */
  @CanIgnoreReturnValue
  public long incrementAndGet(K key) {
    return addAndGet(key, 1);
  }

  /**
   * Decrements by one the value currently associated with {@code key}, and returns the new value.
   */
  @CanIgnoreReturnValue
  public long decrementAndGet(K key) {
    return addAndGet(key, -1);
  }

  /**

        }
      }
    }
  }

  /** addAndGet adds given value to current, and returns current value */
  public void testAddAndGet() {
    AtomicDoubleArray aa = new AtomicDoubleArray(SIZE);
    for (int i : new int[] {0, SIZE - 1}) {
      for (double x : VALUES) {
        for (double y : VALUES) {
          aa.set(i, x);
          double z = aa.addAndGet(i, y);
          assertBitEquals(x + y, z);

    
    public void recordRdmaRead(int bytes) {
        rdmaReads.incrementAndGet();
        bytesTransferred.addAndGet(bytes);
    }
    
    public void recordRdmaWrite(int bytes) {
        rdmaWrites.incrementAndGet();
        bytesTransferred.addAndGet(bytes);
    }
    
    public void recordError() {
        operationErrors.incrementAndGet();
    }
    

                assertNotNull(paramMap);
                assertNotNull(dataMap);
                docSize.incrementAndGet();
                execTime.addAndGet(100);
            }

            @Override
            public long getDocumentSize() {
                return docSize.get();
            }

            @Override
            public long getExecuteTime() {

   *
   * @param i the index
   * @param delta the value to add
   * @return the updated value
   */
  @CanIgnoreReturnValue
  public double addAndGet(int i, double delta) {
    return accumulateAndGet(i, delta, Double::sum);
  }

  /**
   * Atomically updates the element at index {@code i} with the results of applying the given

            // Track time in open state
            if (oldState == State.OPEN && openStateStartTime.get() > 0) {
                totalTimeInOpen.addAndGet(System.currentTimeMillis() - openStateStartTime.get());
                openStateStartTime.set(0);
            }

            if (newState == State.OPEN) {

            k -> new ChannelStatistics());
            
        stats.operations.incrementAndGet();
        stats.latencyTotal.addAndGet(latency);
        
        if (success) {
            stats.bytesReceived.addAndGet(bytes);
        } else {
            stats.errors.incrementAndGet();
        }
    }
    
    public double getAggregatedThroughput() {