CircuitBreaker.REQUEST,
                    bytesToPreallocate,
                    "aggregations"
                );
            } else {
                breakerService = AggConstructionContentionBenchmark.this.breakerService;
                preallocated = null;
            }
            breaker = breakerService.getBreaker(CircuitBreaker.REQUEST);

        }

        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