}

    /**
     * Check if connection is established and ready for use
     *
     * @return true if connection is connected/established, false otherwise
     */
    public boolean isConnected() {
        return state == RdmaConnectionState.CONNECTED || state == RdmaConnectionState.ESTABLISHED;
    }

    /**
     * Read data from RDMA connection
     *

     * Test that getInputStream() attempts to connect if not connected.
     */
    public void test_getInputStream_autoConnect() throws Exception {
        URL url = new URL("gcs://mybucket/object.txt");
        Handler handler = new Handler();
        Handler.GcsURLConnection conn = (Handler.GcsURLConnection) handler.openConnection(url);

        // getInputStream should try to auto-connect (and fail due to missing project ID)
        try {

   * value that are {@linkplain Range#isConnected connected} to this range.
   *
   * <p>The behavior of {@link #get(Comparable) get(k)} after calling this method is identical to
   * the behavior described in {@link #put(Range, Object) put(range, value)}, however the ranges
   * returned from {@link #asMapOfRanges} will be different if there were existing entries which
   * connect to the given range and value.
   *

        try (SmbSessionImpl session = getSession()) {
            if (isConnected()) {
                try (SmbTransportImpl transport = session.getTransport()) {
                    if (transport.isDisconnected() || transport.getRemoteHostName() == null) {
                        /*
                         * Tree/session thinks it is connected but transport disconnected

    val sslSocket = socketFactory.createSocket() as SSLSocket
    assertTrue(adapter.matchesSocket(sslSocket))

    adapter.configureTlsExtensions(sslSocket, null, listOf(HTTP_2, HTTP_1_1))
    // not connected
    assertNull(adapter.getSelectedProtocol(sslSocket))
  }

  @Test
  fun testMatchesSupportedAndroidSocketFactory() {
    assumeTrue(adapter is StandardAndroidSocketAdapter)

    }

    @Test
    @DisplayName("isConnected reflects underlying tree state")
    void isConnected_usesTree() {
        SmbTreeConnection c = newConn();
        // No tree -> false
        assertFalse(c.isConnected());

        SmbTreeImpl tree = mock(SmbTreeImpl.class);
        when(tree.isConnected()).thenReturn(true);
        setTree(c, tree);
        assertTrue(c.isConnected());
    }

    @Test

        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

            state = RdmaConnectionState.CONNECTED;
            log.debug("DiSNI RDMA connection established to {}", remoteAddress);

    }

    /**
     * Test: Verify connected flag is set correctly
     */
    @Test
    public void testConnectedFlag() {
        assertFalse("Initially not connected", fesenClient.connected());

        // After destroy, should be disconnected
        fesenClient.destroy();
        assertFalse("Should be disconnected after destroy", fesenClient.connected());
    }

   *
   * <p>For example,
   *
   * <ul>
   *   <li>{@code [2, 4)} and {@code [5, 7)} are not connected
   *   <li>{@code [2, 4)} and {@code [3, 5)} are connected, because both enclose {@code [3, 4)}
   *   <li>{@code [2, 4)} and {@code [4, 6)} are connected, because both enclose the empty range
   *       {@code [4, 4)}
   * </ul>
   *

/**
 * A set comprising zero or more {@linkplain Range#isEmpty nonempty}, {@linkplain
 * Range#isConnected(Range) disconnected} ranges of type {@code C}.
 *
 * <p>Implementations that choose to support the {@link #add(Range)} operation are required to
 * ignore empty ranges and coalesce connected ranges. For example:
 *
 * {@snippet :
 * RangeSet<Integer> rangeSet = TreeRangeSet.create();