/**
   * A (self-inverse) bijection which converts the ordering on unsigned longs to the ordering on
   * longs, that is, {@code a <= b} as unsigned longs if and only if {@code flip(a) <= flip(b)} as
   * signed longs.
   */
  private static long flip(long a) {
    return a ^ Long.MIN_VALUE;
  }

  /**
   * Compares the two specified {@code long} values, treating them as unsigned values between {@code

                if (read < 0) {
                    throw new IOException("Connection closed by peer");
                }
            }

            headerBuffer.flip();
            int messageSize = headerBuffer.getInt();

            // Now read the message body
            ByteBuffer messageBuffer = ByteBuffer.allocate(messageSize);
            while (messageBuffer.hasRemaining()) {

      int maxCount = (int) (4 * Math.log(2 * keyBits * hashBits) + 1);
      while (same != 0xffffffff || diff != 0xffffffff) {
        int key1 = rand.nextInt();
        // flip input bit for key2
        int key2 = key1 ^ (1 << i);
        // get hashes
        int hash1 = function.hashInt(key1).asInt();
        int hash2 = function.hashInt(key2).asInt();

			if got := hashDeterministicString(m); got == want {
				t.Errorf("hashDeterministicString() = %v, does not want %v", got, want)
			}

			// Flip key/value
			want = hashDeterministicString(m)
			delete(m, "another")

      }
    }

    checkNotNull(from);
    checkNotNull(to);
    long total = 0;
    CharBuffer buf = createBuffer();
    while (from.read(buf) != -1) {
      Java8Compatibility.flip(buf);
      to.append(buf);
      total += buf.remaining();
      Java8Compatibility.clear(buf);
    }
    return total;
  }

            // Test data preparation
            byte[] testData = "Test RDMA data transfer".getBytes();
            sendBuffer.getBuffer().put(testData);
            sendBuffer.getBuffer().flip();
            assertEquals(testData.length, sendBuffer.getBuffer().remaining(), "Buffer should contain test data");

            // Clean up
            bufferManager.releaseSendRegion(sendBuffer);

    assertThat(listener.recordedEventTypes().filter { it == "ConnectFailed" }).hasSize(0)
  }

  @Test
  fun callIpv6WhenBothServersAreReachable() {
    // Flip DNS results to prefer IPv6.
    dnsResults =
      listOf(
        localhostIpv6,
        localhostIpv4,
      )
    serverIpv4.enqueue(
      MockResponse(body = "unexpected call to IPv4"),
    )

      StringBuilder builder = new StringBuilder();
      CharBuffer buffer = CharBuffer.allocate(100);
      while (reader.read(buffer) != -1) {
        Java8Compatibility.flip(buffer);
        builder.append(buffer);
        Java8Compatibility.clear(buffer);
      }
      return builder.toString();
    }
  }

    BloomFilter<Integer> bloomFilter =
        BloomFilter.create(Funnels.integerFunnel(), 15_000_000, 0.01);

    // This check has to be BEFORE the loop because the random insertions can
    // flip GOLDEN_PRESENT_KEY to true even if it wasn't explicitly inserted
    // (false positive).
    assertThat(bloomFilter.mightContain(GOLDEN_PRESENT_KEY)).isFalse();
    for (int i = 0; i < NUM_PUTS; i++) {

        
        // Register buffer if needed
        RdmaMemoryRegion sendRegion = bufferManager.getSendRegion(requestBuffer.remaining());
        sendRegion.getBuffer().put(requestBuffer);
        sendRegion.getBuffer().flip();
        
        try {
            // Send via RDMA
            rdmaConnection.send(sendRegion.getBuffer(), sendRegion);
            rdmaConnection.consumeSendCredit();