}

        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should reopen on failure");
    }

    @Test
    public void testManualReset() {
        // Open the circuit
        circuitBreaker.trip();
        assertEquals(State.OPEN, circuitBreaker.getState(), "Circuit should be OPEN");

        // Manually reset
        circuitBreaker.reset();

        // Open the circuit
        circuitBreaker.tripBreaker();
        assertEquals(SimpleCircuitBreaker.State.OPEN, circuitBreaker.getState());

        // Reset
        circuitBreaker.reset();
        assertEquals(SimpleCircuitBreaker.State.CLOSED, circuitBreaker.getState());
        assertTrue(circuitBreaker.allowsRequests());

        SimpleCircuitBreaker.Statistics stats = circuitBreaker.getStatistics();

        /**
         * Called when a request fails
         *
         * @param circuitBreaker the circuit breaker
         * @param exception the failure exception
         */
        void onFailure(SmbCircuitBreaker circuitBreaker, Exception exception);

        /**
         * Called when circuit breaker rejects a request
         *
         * @param circuitBreaker the circuit breaker

            this.consecutiveFailures = consecutiveFailures;
            this.successRate = successRate;
        }

        @Override
        public String toString() {
            return String.format("CircuitBreaker[%s] State=%s, Calls=%d, Success=%.2f%%, Rejected=%d", name, state, totalCalls,
                    successRate * 100, rejectedCalls);
        }
    }

    /**
     * Exception thrown when circuit breaker is open

    private static Logger log = LoggerFactory.getLogger(SmbTransportImpl.class);
    private static final SecurityAuditLogger auditLogger = SecurityAuditLogger.getInstance();
    private final SimpleCircuitBreaker circuitBreaker;

    private boolean smb2 = false;
    private final InetAddress localAddr;
    private final int localPort;
    private final Address address;
    private Socket socket;
    private int port;