private byte[] signingKey;
        private boolean established;
        private String nbName;
        private ASN1ObjectIdentifier[] supportedMechs;
        private int flags;
        private boolean integrity;
        private boolean disposed;

        DummySSPContext(byte[] signingKey, boolean established, String nbName, ASN1ObjectIdentifier[] supportedMechs, int flags,

            log.debug("DiSNI RDMA connection established to {}", remoteAddress);

        } catch (Exception e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("DiSNI RDMA connection failed", e);
        }
    }

    @Override
    public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
        if (state != RdmaConnectionState.ESTABLISHED && state != RdmaConnectionState.CONNECTED) {

        } else {
            throw new SmbException("Invalid token");
        }

        if (spToken instanceof final NegTokenTarg targ && this.mechContext.isEstablished()) {
            // already established, but server hasn't completed yet
            if (targ.getResult() == NegTokenTarg.ACCEPT_INCOMPLETE && targ.getMechanismToken() == null
                    && targ.getMechanismListMIC() != null) {

    @DisplayName("toString shows basic info when not established")
    void toString_notEstablished() throws Exception {
        when(gssContext.isEstablished()).thenReturn(false);
        String s = ctx.toString();
        assertTrue(s.startsWith("KERB5["));
        assertTrue(s.contains("src=null"));
    }

    @Test
    @DisplayName("toString shows names and mech when established")
    void toString_established_ok() throws Exception {

     * 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
     *

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 {

        // 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();

   *
   * This method is safe to be called concurrently, but provides limited guarantees. If a transport
   * layer connection has been established (such as a HTTP/2 stream) that is terminated. Otherwise,
   * if a socket connection is being established, that is terminated.
   */
  override fun cancel() {
    if (canceled) return // Already canceled.

    canceled = true
    exchange?.cancel()

        performChannelBinding(channel);
        
        // Add to active channels
        channels.put(channelId, channel);
        channel.setState(ChannelState.ESTABLISHED);
        
        log.info("Established channel {} using {}:{} -> {}:{}", 
            channelId, localIf.getAddress(), remoteIf.getAddress());
    }
    
    private void performChannelBinding(ChannelInfo channel) throws IOException {

            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()) {