public void test_interface_methods() {
        // Test with anonymous implementation
        IndexUpdateCallback callback = new IndexUpdateCallback() {
            private final AtomicLong docSize = new AtomicLong(0);
            private final AtomicLong execTime = new AtomicLong(0);

            @Override
            public void store(DataStoreParams paramMap, Map<String, Object> dataMap) {
                assertNotNull(paramMap);

   */
  public void testBuilder_bruteForce() {
    for (int i = 0; i < reduceIterationsIfGwt(100); i++) {
      ImmutableLongArray.Builder builder = ImmutableLongArray.builder(random.nextInt(20));
      AtomicLong counter = new AtomicLong(0);
      while (counter.get() < 1000) {
        BuilderOp op = BuilderOp.randomOp();
        op.doIt(builder, counter);
      }
      ImmutableLongArray iia = builder.build();

  // We would use AtomicLongFieldUpdater, but it has issues on some Android devices.
  private transient AtomicLong value;

  /**
   * Creates a new {@code AtomicDouble} with the given initial value.
   *
   * @param initialValue the initial value
   */
  public AtomicDouble(double initialValue) {
    value = new AtomicLong(doubleToRawLongBits(initialValue));
  }

        final FessConfig fessConfig = ComponentUtil.getFessConfig();
        final int maxRequests = fessConfig.getRateLimitRequestsPerWindowAsInteger();

        AtomicLong counter = requestCounters.getIfPresent(ip);
        if (counter == null) {
            counter = new AtomicLong(0);
            requestCounters.put(ip, counter);
        }

        final long count = counter.incrementAndGet();

    // Test implementation of IndexUpdateCallback for testing purposes
    private static class TestIndexUpdateCallback implements IndexUpdateCallback {
        private final AtomicLong documentCount = new AtomicLong(0);
        private final AtomicLong executeTime = new AtomicLong(0);
        private final AtomicBoolean committed = new AtomicBoolean(false);
        private final long startTime = System.currentTimeMillis();

        @Override

     */
    public IndexUpdateCallbackImpl() {
        // Default constructor
    }

    /** Atomic counter for the number of documents processed */
    protected AtomicLong documentSize = new AtomicLong(0);

    /** Total execution time for all operations */
    protected volatile long executeTime = 0;

    /** List of documents waiting to be indexed */

                    excludeFields, query);
        }

        final long startTime = System.currentTimeMillis();

        try {
            final AtomicLong processedCount = new AtomicLong(0);
            final long count = searchEngineClient.scrollSearch(fessConfig.getIndexDocumentSearchIndex(), requestBuilder -> {
                requestBuilder.setQuery(query).setSize(scrollSize);

    /** Sort list. */
    protected List<SortBuilder<?>> sortList = new ArrayList<>();

    /** Scroll ID. */
    protected String scrollId = null;

    /** Document count. */
    protected final AtomicLong docCount = new AtomicLong(0);
    /** Total document number. */
    protected final long totalDocNum;

    /**
     * Constructor for ESSourceReader.
     * @param client The OpenSearch client.

```java
class PrintingEventListener extends EventListener {
  public static final Factory FACTORY = new Factory() {
    final AtomicLong nextCallId = new AtomicLong(1L);

    @Override public EventListener create(Call call) {
      long callId = nextCallId.getAndIncrement();
      System.out.printf("%04d %s%n", callId, call.request().url());

     */
    protected final AtomicInteger activeThreadCount = new AtomicInteger(0);

    /**
     * Atomic counter for tracking the number of accesses made.
     */
    protected AtomicLong accessCount = new AtomicLong(0);

    /**
     * Current status of the crawler.
     */
    protected volatile CrawlerStatus status = CrawlerStatus.INITIALIZING;

    /**