}

  public void testOnlyOneOpen() throws Exception {
    ByteSource source = newByteSource(0, 50);
    int[] counter = new int[1];
    ByteSource checker =
        new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {
              throw new IllegalStateException("More than one source open");
            }

        }

        // Then - Check that counter portion has entropy
        // For SMB3-compliant nonces, the first 8 bytes are a counter (little-endian)
        // so we check that the counter bytes change as expected
        Set<String> uniqueCounters = new HashSet<>();
        for (int i = 0; i < sampleSize; i++) {
            // Extract first 8 bytes as counter
            byte[] counter = new byte[8];

        /** Indicates that content was successfully parsed. */
        PARSED,
        /** Indicates that a URL was prepared for crawling. */
        PREPARED,
        /** Indicates that a URL redirect was encountered. */
        REDIRECTED,
        /** Indicates that a URL was processed completely. */
        PROCESSED
    }

 * identical functionality but do not throw {@link IOException}.
 *
 * <p><b>Warning:</b> The caller is responsible for not attempting to read past the end of the
 * array. If any method encounters the end of the array prematurely, it throws {@link
 * IllegalStateException} to signify <i>programmer error</i>. This behavior is a technical violation
 * of the supertype's contract, which specifies a checked exception.
 *

      void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) {
        builder.add(counter.getAndIncrement());
      }
    },
    ADD_ARRAY {
      @Override
      void doIt(ImmutableLongArray.Builder builder, AtomicLong counter) {
        long[] array = new long[random.nextInt(10)];
        for (int i = 0; i < array.length; i++) {
          array[i] = counter.getAndIncrement();
        }
        builder.addAll(array);

  }

  public void testOnlyOneOpen() throws Exception {
    ByteSource source = newByteSource(0, 50);
    int[] counter = new int[1];
    ByteSource checker =
        new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {
              throw new IllegalStateException("More than one source open");
            }

import org.lastaflute.web.Execute;
import org.lastaflute.web.response.HtmlResponse;

/**
 * Action class for handling HTTP 500 Internal Server Error pages.
 * This action displays error pages when the server encounters
 * an unexpected condition that prevents it from fulfilling the request.
 */
public class ErrorSystemerrorAction extends FessSearchAction {

    /**
     * Default constructor for ErrorSystemerrorAction.
     */

    /** Current page number. */
    private int currentPageNumber;

    /** ID of the failure URL record. */
    public String id;

    /** Name of the thread that encountered the failure. */
    public String threadName;

    /** Number of errors encountered for this URL. */
    public String errorCount;

    /** Last time this URL was accessed. */
    public String lastAccessTime;

    /**

 */
package org.codelibs.fess.exception;

/**
 * Exception thrown when command execution fails.
 * This exception indicates that an external command or process execution encountered an error.
 */
public class CommandExecutionException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructor with error message.

    }

    @Test
    @DisplayName("Test run method")
    void testRunMethod() throws Exception {
        AtomicInteger counter = new AtomicInteger(0);

        circuitBreaker.run(() -> counter.incrementAndGet());
        assertEquals(1, counter.get());

        SimpleCircuitBreaker.Statistics stats = circuitBreaker.getStatistics();
        assertEquals(1, stats.totalCalls);