* Set channel state
     *
     * @param state new state
     */
    public void setState(ChannelState state) {
        this.state = state;
    }

    /**
     * Get the time when channel was established
     *
     * @return establishment time in milliseconds
     */
    public long getEstablishedTime() {
        return establishedTime;
    }

    /**
     * Get the last activity time
     *

		}
		for _, server := range t.Servers {
			server.Close()
		}
		for _, listener := range t.Listeners {
			listener.Close()
		}
	})
}

// WaitAllConnect will wait for all connections to be established.
func (t *TestGrid) WaitAllConnect(ctx context.Context) {
	for _, manager := range t.Managers {
		for _, remote := range manager.Targets() {
			if manager.HostName() == remote {
				continue
			}

         * System properties are initialized before the build starts and are available throughout the entire Maven
         * execution. They are used for core Maven functionality that needs to be established at startup.
         */
        SYSTEM_PROPERTIES,
        /**
         * Maven user properties. These are properties that users configure through various means such as

        // Assert
        assertNotNull(ctx, "createContext returns an SSPContext");
        assertFalse(ctx.isEstablished(), "stub context initially not established");

        // Verify interactions with dependency are meaningful and ordered
        InOrder order = inOrder(mockContext);
        order.verify(mockContext, times(1)).getConfig();

            throw ioe;
        }

        switch (type) {
        case SessionServicePacket.POSITIVE_SESSION_RESPONSE:
            if (LogStream.level > 2) {
                log.println("session established ok with " + address);
            }
            return;
        case SessionServicePacket.NEGATIVE_SESSION_RESPONSE:
            final int errorCode = in.read() & 0xFF;
            close();

            try {
                /* The hostname to use in the path is only known for
                 * sure if the NetBIOS session has been successfully
                 * established.
                 */

                session.transport.connect();

                unc = "\\\\" + session.transport.tconHostName + '\\' + share;

import java.util.Vector;

import jcifs.smb1.Config;
import jcifs.smb1.UniAddress;
import jcifs.smb1.netbios.NbtAddress;
import jcifs.smb1.util.LogStream;

/**
 * The SmbSession class represents an SMB session established with a server.
 * It provides methods for authentication and session management.
 */
public final class SmbSession {

    protected int maxFragmentedSize;
    protected int maxReadWriteSize;
    
    public enum RdmaConnectionState {
        DISCONNECTED,
        CONNECTING,
        CONNECTED,
        ESTABLISHED,
        ERROR,
        CLOSING,
        CLOSED
    }
    
    public RdmaConnection(InetSocketAddress remote, InetSocketAddress local) {
        this.remoteAddress = remote;

            if (request == null || chainedResponse != null && chainedResponse.isReceived()) {
                return chainedResponse;
            }

            // fall trough if the tree connection is already established
            // and send it as a separate request instead
            String svc = null;
            final int t = this.tid;
            request.setTid(t);

            if (!transport.isSMB2()) {

                log.info("RDMA connection established to {}", delegate.getRemoteAddress());
            } catch (IOException e) {
                log.warn("Failed to establish RDMA connection: {}", e.getMessage());
                throw e;
            }
        }
    }

    /**
     * Checks if RDMA connection is available.