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;
    boolean inDfs, inDomainDfs;

            tree.send(req, resp);
        }
    }

    /* 0 - not connected
     * 1 - connecting
     * 2 - connected
     * 3 - disconnecting
     */
    int connectionState;
    int uid;
    Vector trees;
    // Transport parameters allows trans to be removed from CONNECTIONS
    private final UniAddress address;

            }

            final SmbTransportInternal et = this.exclusiveTransport;
            if (et != null) {
                synchronized (this) {
                    try {
                        log.debug("Disconnecting exclusive transport");
                        this.exclusiveTransport = null;
                        this.tree = null;
                        this.treeAcquired = false;
                        et.close();

    private static AtomicLong TREE_CONN_COUNTER = new AtomicLong();

    /*
     * 0 - not connected
     * 1 - connecting
     * 2 - connected
     * 3 - disconnecting
     */
    private final AtomicInteger connectionState = new AtomicInteger();

    private final String share;
    private final String service0;
    private final SmbSessionImpl session;

            if (oldTransport != null) {
                try {
                    oldTransport.close();
                } catch (Exception e) {
                    log.debug("Error disconnecting old transport", e);
                }
            }

            // Create new transport
            SmbTransport newTransport = manager.createTransport(channel.getLocalInterface(), channel.getRemoteInterface());

        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 };

            for (int state : disconnectedStates) {

/**
 * This class simplifies communication for protocols that support
 * multiplexing requests. It encapsulates a stream and some protocol
 * knowledge (provided by a concrete subclass) so that connecting,
 * disconnecting, sending, and receiving can be syncronized
 * properly. Apparatus is provided to send and receive requests
 * concurrently.
 */

public abstract class Transport implements Runnable {

    /**

            connectionsRemoved.incrementAndGet();

            try {
                transport.disconnect(true, true);
            } catch (Exception e) {
                log.debug("Error disconnecting unhealthy transport: {}", e.getMessage());
            }
        }

        if (!unhealthy.isEmpty()) {
            log.info("Removed {} unhealthy connections from pool", unhealthy.size());
        }

     * this transport.
     */

    /**
     * Disconnect the transport connection
     *
     * @param hard if true, force immediate disconnection without waiting for pending requests
     * @param inUse whether the transport is currently in use
     * @return true if the disconnection was successful
     * @throws IOException if an I/O error occurs
     */

	}
}

// disconnect will disconnect the mux.
// m.recvMu must be locked when calling this function.
func (m *muxServer) disconnect(msg string, locked bool) {
	if debugPrint {
		fmt.Println("Mux", m.ID, "disconnecting. Reason:", msg)
	}
	if msg != "" {
		m.send(message{Op: OpMuxServerMsg, MuxID: m.ID, Flags: FlagPayloadIsErr | FlagEOF, Payload: []byte(msg)})
	} else {
		m.send(message{Op: OpDisconnectClientMux, MuxID: m.ID})