this.setInstanceFollowRedirects(this.connection.getInstanceFollowRedirects());
    }

    @Override
    public void connect() throws IOException {
        if (this.connected) {
            return;
        }
        this.connection.connect();
        this.connected = true;
    }

    private void handshake() {
        if (this.handshakeComplete) {
            return;
        }

                    "DHnC", // Durable handle reconnect
                    "AlSi", // Allocation size
                    "MxAc", // Max access
                    "TWrp", // Timewarp
                    "QFid", // Query on disk ID
                    "RqLs", // Request lease
                    "DH2Q", // Durable handle request V2
                    "DH2C", // Durable handle reconnect V2
                    "ExtA", // Extended attributes

    }

    /**
     * Test that connect() calls connect() on the underlying connection.
     * @throws IOException
     */
    @Test
    void testConnect() throws Exception {
        // Act
        ntlmConnection.connect();

        // Assert
        verify(mockConnection).connect();
        // Connection should be established after connect
    }

    /**

            if (info != null && !info.isExpired()) {
                info.setReconnecting(true);
                info.updateAccessTime();
                log.debug("Found handle for reconnect: {}", path);
                return info;
            }
            return null;
        } finally {
            lock.readLock().unlock();
        }
    }

    /**

	return client.endpoint.String()
}

// IsOnline - returns whether client failed to connect or not.
func (client *storageRESTClient) IsOnline() bool {
	return client.restClient.IsOnline() || client.IsOnlineWS()
}

// IsOnlineWS - returns whether websocket client failed to connect or not.
func (client *storageRESTClient) IsOnlineWS() bool {
	return client.gridConn.State() == grid.StateConnected
}

     *
     * @return the registration timeout
     */
    long getWitnessRegistrationTimeout();

    /**
     * Gets the witness reconnect delay in milliseconds.
     *
     * @return the reconnect delay
     */
    long getWitnessReconnectDelay();

    /**
     * Gets whether witness service discovery is enabled.
     *
     * @return true if discovery is enabled

            // Check if transport creation failed
            if (newTransport == null) {
                throw new IOException("Failed to create new transport");
            }

            // Reconnect
            channel.setState(ChannelState.CONNECTING);
            // Connection would be ensured through proper transport interface

            // Re-establish channel binding

            try {
                transport.disconnect(true);
                transport.connect(getConfig().getConnTimeout()); // Reconnect
                log.info("Successfully reconnected after witness notification");
            } catch (Exception e) {
                log.error("Failed to reconnect after witness notification", e);
            }
        });
    }

    /**

	// Only needed for tracking
	globalServiceFreezeCnt int32
	globalServiceFreezeMu  sync.Mutex // Updates.

	// Map of local drives to this node, this is set during server startup,
	// disk reconnect and mutated by HealFormat. Hold globalLocalDrivesMu to access.
	globalLocalDrivesMap map[string]StorageAPI
	globalLocalDrivesMu  sync.RWMutex

                new jcifs.internal.smb2.persistent.DurableHandleV2Request(timeoutMs, persistent, createGuid);
        addCreateContext(context);
    }

    /**
     * Add a durable handle reconnect context to this request
     * @param fileId the 16-byte file ID from the previous open
     */
    public void addDurableHandleReconnectContext(byte[] fileId) {