@Override
  public final void awaitRunning(long timeout, TimeUnit unit) throws TimeoutException {
    delegate.awaitRunning(timeout, unit);
  }

  /**
   * @since 15.0
   */
  @Override
  public final void awaitTerminated() {
    delegate.awaitTerminated();
  }

  /**
   * @since 15.0
   */
  @Override
  public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {

        // Release should not throw exception
        assertDoesNotThrow(() -> bufferManager.releaseBuffer(buffer));
    }

    @Test
    public void testStatistics() throws Exception {
        long initialAllocated = bufferManager.getTotalAllocated();

        // Allocate regions larger than pool buffer size to force new allocations

package org.codelibs.fess.exception;

/**
 * This exception is thrown when the requested result offset exceeds the limit.
 */
public class ResultOffsetExceededException extends FessSystemException {
    private static final long serialVersionUID = 1L;

    /**
     * Constructor.
     * @param message The exception message.
     */
    public ResultOffsetExceededException(final String message) {
        super(message);
    }

/**
 * Exception that wraps {@link IndexOutOfBoundsException}.
 *
 * @author wyukawa
 */
public class ClIndexOutOfBoundsException extends IndexOutOfBoundsException {

    private static final long serialVersionUID = -824874776607593608L;

    /**
     * Creates a {@link ClIndexOutOfBoundsException}.
     */
    public ClIndexOutOfBoundsException() {
        super();
    }

    /**

            processMethod.setAccessible(true);

            try {
                Integer result = (Integer) processMethod.invoke(null, options);
                // Any result is acceptable as long as no unexpected exception
                assertNotNull(result);
            } catch (Exception e) {
                // Expected behavior when components are not fully initialized

    Request request = chain.request();

    long t1 = System.nanoTime();
    logger.info(String.format("Sending request %s on %s%n%s",
        request.url(), chain.connection(), request.headers()));

    Response response = chain.proceed(request);

    long t2 = System.nanoTime();
    logger.info(String.format("Received response for %s in %.1fms%n%s",

      object : Source {
        private var cacheRequestClosed = false

        @Throws(IOException::class)
        override fun read(
          sink: Buffer,
          byteCount: Long,
        ): Long {
          val bytesRead: Long
          try {
            bytesRead = source.read(sink, byteCount)
          } catch (e: IOException) {
            if (!cacheRequestClosed) {
              cacheRequestClosed = true

      throw new AssertionError();
    }
  }

  /** Implementation of {@link Futures#getChecked(Future, Class, long, TimeUnit)}. */
  @CanIgnoreReturnValue
  @ParametricNullness
  static <V extends @Nullable Object, X extends Exception> V getChecked(
      Future<V> future, Class<X> exceptionClass, long timeout, TimeUnit unit) throws X {
    // TODO(cpovirk): benchmark a version of this method that accepts a GetCheckedTypeValidator

        this.map = map;
      }

      Object readResolve() {
        return map.keySet();
      }

      @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;
    }
  }

  @Override
  ImmutableCollection<V> createValues() {
    return new Values<>(this);
  }

  private static final class Values<K, V> extends ImmutableList<V> {

        assertEquals(message, exception.getMessage());
    }

    public void test_veryLongMessage() {
        // Test with very long message
        StringBuilder sb = new StringBuilder();
        for (int i = 0; i < 1000; i++) {
            sb.append("Long message part ").append(i).append(" ");
        }
        String longMessage = sb.toString();