final AtomicBoolean storeCalled = new AtomicBoolean(false);
        final AtomicReference<DataConfig> capturedConfig = new AtomicReference<>();
        final AtomicReference<IndexUpdateCallback> capturedCallback = new AtomicReference<>();
        final AtomicReference<DataStoreParams> capturedParams = new AtomicReference<>();

        dataStore = new DataStore() {
            @Override

// Since this class only needs CAS on one field, we can avoid this bug by extending AtomicReference
// instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances
// and DONE/INTERRUPTED - they have a common ancestor of Runnable.
abstract class InterruptibleTask<T extends @Nullable Object>
    extends AtomicReference<@Nullable Runnable> implements Runnable {
  static {

        new ThreadLocal<Integer>() {
          @Override
          protected Integer initialValue() {
            return 0;
          }
        };
    AtomicReference<Throwable> throwableFromOtherThread = new AtomicReference<>(null);
    Runnable incrementTask =
        new Runnable() {
          @Override
          public void run() {
            threadLocalCount.set(threadLocalCount.get() + 1);

    assertSame(one, cache.getUnchecked(one));
    assertFalse(segment.recencyQueue.isEmpty());
  }

  public void testRecursiveComputation() throws InterruptedException {
    AtomicReference<LoadingCache<Integer, String>> cacheRef = new AtomicReference<>();
    CacheLoader<Integer, String> recursiveLoader =
        new CacheLoader<Integer, String>() {
          @Override
          public String load(Integer key) {

import java.io.InterruptedIOException
import java.net.HttpURLConnection
import java.time.Duration
import java.util.concurrent.CountDownLatch
import java.util.concurrent.TimeUnit
import java.util.concurrent.atomic.AtomicReference
import kotlin.test.assertFailsWith
import mockwebserver3.MockResponse
import mockwebserver3.MockWebServer
import mockwebserver3.junit5.StartStop
import okhttp3.MediaType.Companion.toMediaTypeOrNull

  @GwtIncompatible // Thread
  private void testSupplierThreadSafe(Function<Supplier<Boolean>, Supplier<Boolean>> memoizer)
      throws Throwable {
    AtomicInteger count = new AtomicInteger(0);
    AtomicReference<Throwable> thrown = new AtomicReference<>(null);
    int numThreads = 3;
    Thread[] threads = new Thread[numThreads];
    long timeout = SECONDS.toNanos(60);

    Supplier<Boolean> supplier =
        new Supplier<Boolean>() {

    public void test_getPermissions_withLdapConfig() {
        // Test with LDAP configuration
        final AtomicBoolean activityHelperCalled = new AtomicBoolean(false);
        final AtomicReference<String[]> rolesFromCallback = new AtomicReference<>();

        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            @Override
            public String getLdapBaseDn() {
                return "dc=example,dc=com";

    public enum State {
        CLOSED, // Normal operation
        OPEN, // Failing, requests blocked
        HALF_OPEN // Testing recovery
    }

    private final String name;
    private final AtomicReference<State> state = new AtomicReference<>(State.CLOSED);
    private final AtomicInteger consecutiveFailures = new AtomicInteger(0);
    private final AtomicInteger halfOpenSuccesses = new AtomicInteger(0);

        assertEquals("ok", FileUtil.readText(fileList.get(0).toFile()));
    }

    public void test_updateSystemProperties() {
        final SystemHelper helper = new SystemHelper();
        final AtomicReference<String> appValue = new AtomicReference<>(StringUtil.EMPTY);
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {
            private static final long serialVersionUID = 1L;

            @Override

            }
        }, WebConfigService.class.getCanonicalName());
    }

    public void test_sendDocuments() {
        documentSizeByQuery = 0L;
        final AtomicReference<String> sentIndex = new AtomicReference<>();
        final List<Map<String, Object>> sentDocList = new ArrayList<>();
        final SearchEngineClient client = new SearchEngineClient() {
            @Override