* concurrently.
 */

public abstract class Transport implements Runnable {

    /**
     * Default constructor for Transport.
     */
    public Transport() {
        // Default constructor
    }

    static int id = 0;
    static LogStream log = LogStream.getInstance();

    /**
     * Reads exactly len bytes from the input stream into the buffer.
     *

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

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

        // Transport and context delegation
        assertSame(cifsContext, session.getContext());
        clearInvocations(transport);
        assertSame(transport, session.getTransport());
        verify(transport, times(1)).acquire();
    }

    @Test
    @DisplayName("close/release manage usage and transport lifecycle")
    void testReleaseLifecycle() {

        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

        assertNull(session.transport, "transport not created yet");
        SmbTransport tr = session.transport();
        assertNotNull(tr, "transport should now exist");
        // subsequent calls return the same instance
        assertSame(tr, session.transport());
    }

    @Test
    void sendResetsResponseAndForwards() throws Exception {

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

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

    @Test
    @DisplayName("Should remove transport from pool")
    void testRemoveTransport() {
        // Given: A pooled connection
        SmbTransportImpl transport = pool.getSmbTransport(ctx, address, 445, false);
        assertTrue(pool.contains(transport), "Transport should be in pool initially");

        // When: Remove the transport
        pool.removeTransport(transport);