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

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

        }

        @Test
        @DisplayName("release should decrement usage count")
        void shouldDecrementUsageCount() {
            transport.acquire();
            long beforeRelease = transport.getUsageCount();
            transport.release();
            assertEquals(beforeRelease - 1, transport.getUsageCount());
        }

        @Test

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

        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;

        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 {

        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

    }

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

 */
package jcifs;

/**
 * Opaque reference to a SMB transport
 *
 * @author mbechler
 *
 * <p>This interface is intended for internal use.</p>
 */
public interface SmbTransport extends AutoCloseable {

    /**
     * Gets the CIFS context associated with this transport.
     *
     * @return the context this transport is attached to
     */
    CIFSContext getContext();

    /**