func (c *Client) Close() {
	atomic.StoreInt32(&c.connected, closed)
}

// NewClient - returns new REST client.
func NewClient(uu *url.URL, tr http.RoundTripper, auth func() string) *Client {
	connected := int32(online)
	urlStr := uu.String()
	u, err := url.Parse(urlStr)
	if err != nil {
		// Mark offline, with no reconnection attempts.
		connected = int32(offline)
		err = &url.Error{URL: urlStr, Err: err}
	}

   * contained in this set. This is equivalent to {@code range(CLOSED, CLOSED)}.
   *
   * @throws NoSuchElementException if this set is empty
   */
  public abstract Range<C> range();

  /**
   * Returns the minimal range with the given boundary types for which all values in this set are
   * {@linkplain Range#contains(Comparable) contained} within the range.
   *

 */

package jcifs.smb1.smb1;

import jcifs.smb1.util.LogStream;

class SmbTree {

    private static int tree_conn_counter;

    /* 0 - not connected
     * 1 - connecting
     * 2 - connected
     * 3 - disconnecting
     */
    int connectionState;
    int tid;

    String share;
    String service = "?????";
    String service0;
    SmbSession session;

        smbClient.setInitParameterMap(params);
        smbClient.init();

        boolean connected = false;
        for (int i = 0; i < 30; i++) {
            try {
                smbClient.doGet(baseUrl);
            } catch (final ChildUrlsException e) {
                connected = true;
                break;
            } catch (final Exception e) {

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String projectId = System.getenv("GCS_PROJECT_ID");
            final String endpoint = System.getenv("GCS_ENDPOINT");

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String endpoint = System.getenv().get("S3_ENDPOINT");
            final String accessKey = System.getenv().get("S3_ACCESS_KEY");

   * contained in this set. This is equivalent to {@code range(CLOSED, CLOSED)}.
   *
   * @throws NoSuchElementException if this set is empty
   */
  public abstract Range<C> range();

  /**
   * Returns the minimal range with the given boundary types for which all values in this set are
   * {@linkplain Range#contains(Comparable) contained} within the range.
   *

         *
         * @throws IOException If the connection cannot be established
         */
        @Override
        public synchronized void connect() throws IOException {
            if (connected) {
                return;
            }
            final String endpoint = System.getenv().get("STORAGE_ENDPOINT");
            final String accessKey = System.getenv().get("STORAGE_ACCESS_KEY");

            if (n <= 0) {
                break;
            }
            i += n;
        }

        return i;
    }

    /* state values
     * 0 - not connected
     * 1 - connecting
     * 2 - run connected
     * 3 - connected
     * 4 - error
     */
    int state = 0;

    String name = "Transport" + id++;
    Thread thread;
    TransportException te;

    /**

 * service type, and DFS information for the connected share.
 *
 * @author mbechler
 */
public interface TreeConnectResponse extends CommonServerMessageBlockResponse {

    /**
     * Returns the tree identifier (TID) assigned to this tree connection.
     *
     * @return tree id
     */
    int getTid();

    /**