}
    return sum;
  }

  private enum SubMultisetSpec {
    TAIL_CLOSED {
      @Override
      <E> List<Entry<E>> expectedEntries(int targetEntry, List<Entry<E>> entries) {
        return entries.subList(targetEntry, entries.size());
      }

      @Override
      <E> SortedMultiset<E> subMultiset(
          SortedMultiset<E> multiset, List<Entry<E>> entries, int targetEntry) {

    private final ReadWriteLock delegate;

    WeakSafeReadWriteLock() {
      this.delegate = new ReentrantReadWriteLock();
    }

    @Override
    public Lock readLock() {
      return new WeakSafeLock(delegate.readLock(), this);
    }

    @Override
    public Lock writeLock() {
      return new WeakSafeLock(delegate.writeLock(), this);
    }
  }

import java.io.Serializable;
import java.util.List;

import org.codelibs.fess.util.ComponentUtil;

/**
 * Pager class for stemmer override dictionary management.
 *
 * This class provides pagination functionality for displaying stemmer override
 * dictionary entries in the administrative interface. It manages page state,
 * navigation controls, and provides methods for calculating page boundaries

    private MockThumbnailManager thumbnailManager;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        purgeThumbnailJob = new PurgeThumbnailJob();

        // Create a mock ThumbnailManager
        thumbnailManager = new MockThumbnailManager();

        ComponentUtil.register(thumbnailManager, "thumbnailManager");
    }

    @Override
    public void tearDown() throws Exception {

  /**
   * Returns the encoded media type, like "text/plain; charset=utf-8", appropriate for use in a
   * Content-Type header.
   */
  override fun toString(): String = mediaType

  override fun equals(other: Any?): Boolean = other is MediaType && other.mediaType == mediaType

  override fun hashCode(): Int = mediaType.hashCode()

  companion object {
    private const val TOKEN = "([a-zA-Z0-9-!#$%&'*+.^_`{|}~]+)"

    FakeTicker ticker = new FakeTicker();

    int numberOfThreads = 64;
    runConcurrentTest(
        numberOfThreads,
        new Callable<@Nullable Void>() {
          @Override
          public @Nullable Void call() throws Exception {
            // adds two nanoseconds to the ticker
            ticker.advance(1L);
            Thread.sleep(10);
            ticker.advance(1L);

   */
  @Override
  void putAll(Map<? extends K, ? extends V> map);

  // Views

  /**
   * {@inheritDoc}
   *
   * <p>Because a bimap has unique values, this method returns a {@link Set}, instead of the {@link
   * java.util.Collection} specified in the {@link Map} interface.
   */
  @Override
  Set<V> values();

  /**

     * @throws NdrException if decoding fails
     */
    protected abstract void decodeWitnessParameters(NdrBuffer buf) throws NdrException;

    @Override
    public void encode_in(NdrBuffer buf) throws NdrException {
        encodeWitnessParameters(buf);
    }

    @Override
    public void decode_out(NdrBuffer buf) throws NdrException {
        decodeWitnessParameters(buf);

     */
    public boolean isDeleted() {
        return isUpdated() && newInputs.length == 0;
    }

    @Override
    public int hashCode() {
        return Objects.hash(Arrays.hashCode(inputs), Arrays.hashCode(outputs));
    }

    @Override
    public boolean equals(final Object obj) {
        if (this == obj) {
            return true;
        }

        }

        public TestServerMessageBlock2Response(Configuration config, int command) {
            super(config, command);
        }

        @Override
        public ServerMessageBlock2 getNext() {
            return nextBlock;
        }

        @Override
        public void setNext(ServerMessageBlock2 next) {
            this.nextBlock = next;
        }