String endpoint = "135"; // Example non-pipe endpoint that is not recognized
        DcerpcException thrown = assertThrows(DcerpcException.class, () -> {
            dcerpcBinding.setOption("endpoint", endpoint);
        }, "Should throw DcerpcException for invalid endpoint format.");

        assertTrue(thrown.getMessage().contains("Bad endpoint"), "Exception message should indicate a bad endpoint.");
    }

    @Test

       * No code ever sees this bogus value for `endpoint`: This class overrides both methods that
       * use the `endpoint` field, compareTo() and endpoint(). Additionally, the main implementation
       * of Cut.compareTo checks for belowAll before reading accessing `endpoint` on another Cut
       * instance.
       */
      super("");
    }

    @Override
    Comparable<?> endpoint() {

                }
            }
            throw new DcerpcException("Bad endpoint: " + endpoint);
        }
        if (options == null) {
            options = new HashMap();
        }
        options.put(key, val);
    }

    Object getOption(final String key) {
        if (key.equals("endpoint")) {
            return endpoint;
        }
        if (options != null) {
            return options.get(key);

        // In real implementation, this would create the endpoint:
        // this.endpoint = group.createEndpoint();
        this.endpoint = new Object();
    }

    @Override
    public void connect() throws IOException {
        try {
            // In real implementation, this would establish the RDMA connection:
            // endpoint.connect(remoteAddress, 1000);  // 1 second timeout

        super(buffer, access);
        this.endpoint = endpoint;

        // In real implementation, this would register the memory:
        // try {
        //     int accessFlags = convertAccessFlags(access);
        //     memoryRegister = endpoint.registerMemory(buffer, accessFlags).execute().free();
        // } catch (Exception e) {
        //     throw new RuntimeException("Failed to register memory region", e);

    firstEntry = ENDPOINT;
    lastEntry = ENDPOINT;
    links = new long[expectedSize];
    Arrays.fill(links, UNSET);
  }

  @Override
  int firstIndex() {
    return (firstEntry == ENDPOINT) ? -1 : firstEntry;
  }

  @Override
  int nextIndex(int index) {
    int result = getSuccessor(index);
    return (result == ENDPOINT) ? -1 : result;
  }

  @Override

            }
            throw new DcerpcException("Bad endpoint: " + this.endpoint);
        }
        if (this.options == null) {
            this.options = new HashMap<>();
        }
        this.options.put(key, val);
    }

    Object getOption(final String key) {
        if (key.equals("endpoint")) {
            return this.endpoint;
        }
        if (this.options != null) {

    // DiSNI components - these would be actual DiSNI objects in a real implementation
    private Object endpointGroup; // RdmaActiveEndpointGroup<DisniRdmaEndpoint>
    private Object endpoint; // RdmaActiveEndpoint
    private boolean initialized = false;

    @Override
    public boolean isAvailable() {
        try {
            // Check if DiSNI is available on the classpath

    /**
     * Sends a request to the remote endpoint.
     *
     * @param request the request to send
     * @throws IOException if an I/O error occurs
     */
    protected abstract void doSend(Request request) throws IOException;

    /**
     * Receives a response from the remote endpoint.
     *
     * @param response the response object to populate

    nextInBucketKToV = createFilledWithAbsent(expectedSize);
    nextInBucketVToK = createFilledWithAbsent(expectedSize);

    firstInInsertionOrder = ENDPOINT;
    lastInInsertionOrder = ENDPOINT;

    prevInInsertionOrder = createFilledWithAbsent(expectedSize);
    nextInInsertionOrder = createFilledWithAbsent(expectedSize);
  }