}

    /**
     * {@inheritDoc}
     *
     * @see jcifs.util.transport.Response#error()
     */
    @Override
    public final void error() {
        this.error = true;
        synchronized (this) {
            notifyAll();
        }
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.util.transport.Response#clearReceived()
     */
    @Override

    void testTreeConnectSmb2() throws CIFSException, IOException {
        when(transport.isSMB2()).thenReturn(true);
        when(transport.getContext()).thenReturn(context);
        when(session.getTargetHost()).thenReturn("localhost");

        // Mock negotiate response for SMB2
        Smb2NegotiateResponse nego = mock(Smb2NegotiateResponse.class);
        when(transport.getNegotiateResponse()).thenReturn(nego);

package jcifs.smb1.util.transport;

/**
 * Marker interface for transport layer request objects.
 * Represents a request that can be sent through the SMB1 transport layer.
 */
public interface Request {

    }

    /**
     * Constructs a new signing digest using transport and authentication credentials.
     *
     * @param transport the SMB transport for this signing context
     * @param auth the NTLM password authentication credentials
     * @throws SmbException if MD5 algorithm is not available or key generation fails
     */
    public SigningDigest(final SmbTransport transport, final NtlmPasswordAuthentication auth) throws SmbException {

        this.macSigningKey = macSigningKey;
        this.signSequence = initialSequence;
    }

    /**
     * Constructs a signing digest from transport and authentication information
     *
     * @param transport
     *            The SMB transport containing server encryption key
     * @param auth
     *            The NTLM password authenticator containing user credentials
     * @throws SmbException

        synchronized (session.transport()) {
            String unc;

            while (connectionState != 0) {
                if (connectionState == 2 || connectionState == 3) { // connected or disconnecting
                    return;
                }
                try {
                    session.transport.wait();
                } catch (final InterruptedException ie) {

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs.util.transport;

import jcifs.CIFSException;

/**
 * Exception class for transport layer errors.
 * This exception is thrown when transport-related communication errors occur.
 */
public class TransportException extends CIFSException {

    /**
     *
     */

        SmbTransportImpl transport = mock(SmbTransportImpl.class);

        when(tree.isConnected()).thenReturn(true);
        when(tree.getSession()).thenReturn(session);
        when(tree.acquire(false)).thenReturn(tree);
        when(session.getTransport()).thenReturn(transport);
        when(transport.isDisconnected()).thenReturn(false);
        when(transport.getRemoteHostName()).thenReturn("host");

import jcifs.smb1.util.LogStream;
import jcifs.smb1.util.transport.Request;
import jcifs.smb1.util.transport.Response;
import jcifs.smb1.util.transport.Transport;
import jcifs.smb1.util.transport.TransportException;

/**
 * Legacy SMB transport implementation for SMB1 protocol communication.
 * Handles the low-level transport layer for SMB1 protocol messages.
 */
public class SmbTransport extends Transport implements SmbConstants {

	minioClient, err := minio.New(s.endpoint, &minio.Options{
		Creds:     cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken),
		Secure:    s.secure,
		Transport: s.TestSuiteCommon.client.Transport,
	})
	if err != nil {
		c.Fatalf("Error initializing client: %v", err)
	}

	// Validate that the client from sts creds can access the bucket.
	c.mustListObjects(ctx, minioClient, bucket)