// Make session look connected via setSessionSetup
        Smb2SessionSetupResponse resp = mock(Smb2SessionSetupResponse.class);
        when(resp.getSessionId()).thenReturn(42L);
        session.setSessionSetup(resp);

        when(transport.isDisconnected()).thenReturn(false);
        when(transport.isFailed()).thenReturn(false);
        assertTrue(session.isConnected());
        assertFalse(session.isFailed());

	"errors"
	"net/http"
	"net/url"
	"time"

	xhttp "github.com/minio/minio/internal/http"
	"github.com/minio/minio/internal/rest"
)

// ReconnectRESTClient is a wrapper type for rest.Client which provides reconnect on first failure.
type ReconnectRESTClient struct {
	u    *url.URL
	rest *rest.Client
}

// newClient constructs a ReconnectRESTClient object with addr and endpoint initialized.

    }

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

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

            NEXT_HIGHER);
    if (ceilingIndex < ranges.size()
        && ranges.get(ceilingIndex).isConnected(otherRange)
        && !ranges.get(ceilingIndex).intersection(otherRange).isEmpty()) {
      return true;
    }
    return ceilingIndex > 0
        && ranges.get(ceilingIndex - 1).isConnected(otherRange)
        && !ranges.get(ceilingIndex - 1).intersection(otherRange).isEmpty();
  }

  @Override

            NEXT_HIGHER);
    if (ceilingIndex < ranges.size()
        && ranges.get(ceilingIndex).isConnected(otherRange)
        && !ranges.get(ceilingIndex).intersection(otherRange).isEmpty()) {
      return true;
    }
    return ceilingIndex > 0
        && ranges.get(ceilingIndex - 1).isConnected(otherRange)
        && !ranges.get(ceilingIndex - 1).intersection(otherRange).isEmpty();
  }

  @Override

 */
public class HandleReconnectorTest {

    @Mock
    private PersistentHandleManager mockManager;

    private HandleReconnector reconnector;
    private HandleInfo testHandle;

    @BeforeEach
    public void setUp() {
        MockitoAnnotations.openMocks(this);
        reconnector = new HandleReconnector(mockManager, 2, 50); // 2 retries, 50ms delay

        HandleGuid guid = new HandleGuid();

    // The response structure is empty (0 bytes) for reconnect
    // No data is returned in a successful reconnect response

    /**
     * Create a new durable handle reconnect response
     */
    public DurableHandleReconnectResponse() {
        // No data fields for reconnect response
    }

    @Override
    public byte[] getName() {
        return CONTEXT_NAME_BYTES;
    }

        tree.acquire();
        tree.release();
    }

    // Test case for isConnected method
    @Test
    void testIsConnected() throws CIFSException, IOException {
        SmbTreeImpl tree = new SmbTreeImpl(session, "SHARE", "A:");
        assertFalse(tree.isConnected());
    }

    // Test case for getTreeType method
    @Test
    void testGetTreeType() {

    assertEvents(
      "plan 1 TCP connected",
      "plan 0 cancel",
      "plan 1 TLS connecting...",
      "plan 1 TLS connected",
      "plan 2 TCP connecting...",
    )

    taskFaker.advanceUntil(270.ms)
    assertEvents(
      "plan 0 TCP connect canceled",
    )

    taskFaker.advanceUntil(280.ms)
    assertEvents(
      "plan 2 TCP connected",
      "plan 2 TLS connecting...",

    class StateManagementTests {

        @Test
        @DisplayName("should correctly identify disconnected states")
        void shouldIdentifyDisconnectedStates() {
            // States: 0=not connected, 1=connecting, 2=run connected, 3=connected,
            // 4=error, 5=disconnecting, 6=disconnected/invalid
            int[] disconnectedStates = { 0, 4, 5, 6 };
            int[] connectedStates = { 1, 2, 3 };