* concurrently.
 */

/**
 * Abstract base class for network transport implementations in JCIFS.
 * This class handles the low-level transport protocol for SMB communication.
 */
public abstract class Transport implements Runnable, AutoCloseable {

    /**
     * Default constructor for Transport
     */
    protected Transport() {
        // Default constructor
    }

    private static int id = 0;

import org.apache.maven.api.annotations.Nonnull;

/**
 * Transport for specified remote repository (using provided remote repository base URI as root). Must be treated as a
 * resource, best in try-with-resource block.
 *
 * @since 4.0.0
 */
@Experimental
@Consumer
public interface Transport extends Closeable {
    /**

        setField(transport, "smb2", false);
        Smb2NegotiateResponse smb2 = new Smb2NegotiateResponse(cfg);
        setField(transport, "negotiated", smb2);
        assertTrue(transport.isSMB2());

        // 3) SMB1 negotiation
        SmbComNegotiateResponse smb1 = new SmbComNegotiateResponse(ctx);
        setField(transport, "negotiated", smb1);
        assertFalse(transport.isSMB2());
    }

    @Test

    void signingModes() throws Exception {
        when(transport.isSigningOptional()).thenReturn(true);
        when(transport.isSigningEnforced()).thenReturn(false);

        assertTrue(transport.isSigningOptional());
        assertFalse(transport.isSigningEnforced());
        verify(transport).isSigningOptional();
        verify(transport).isSigningEnforced();
    }

            return transport.getNegotiateResponse().getSendBufferSize();
        }
    }

    @Override
    public int getReceiveBufferSize() throws SmbException {
        try (SmbSessionImpl session = this.treeConnection.getSession(); SmbTransportImpl transport = session.getTransport()) {
            return transport.getNegotiateResponse().getReceiveBufferSize();

        List<SmbTransportImpl> unhealthy = new ArrayList<>();

        for (SmbTransportImpl transport : connections) {
            try {
                // Perform comprehensive health check
                if (isConnectionUnhealthy(transport)) {
                    unhealthy.add(transport);
                    String key = getConnectionKey(transport);
                    recordConnectionFailure(key);

        try (SmbSessionImpl sess = getSession(); SmbTransportImpl transport = sess.getTransport()) {
            synchronized (transport) {

                // this needs to be done before the reference to the remote hostname later
                transport.ensureConnected();

                if (waitForState(transport) == 2) {
                    // already connected
                    return null;

        void testRemoveTransport() {
            // Given
            doNothing().when(transportPool).removeTransport(transport);

            // When
            transportPool.removeTransport(transport);

            // Then
            verify(transportPool).removeTransport(transport);
        }

        @Test
        @DisplayName("Should handle null transport removal")

    }

    /**
     * Get the transport for this channel
     *
     * @return SMB transport
     */
    public SmbTransport getTransport() {
        return transport;
    }

    /**
     * Set the transport for this channel
     *
     * @param transport SMB transport
     */
    public void setTransport(SmbTransport transport) {
        this.transport = transport;
    }

    /**

     * @return a transport connection to the target
     */
    SmbTransport getSmbTransport(CIFSContext tc, Address address, int port, InetAddress localAddr, int localPort, String hostName,
            boolean exclusive, boolean forceSigning);

    /**
     * Removes a transport from the pool.
     *
     * @param trans the transport to remove
     */