Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for AtomicReference (0.79 sec)

  1. src/test/java/org/codelibs/fess/ds/DataStoreTest.java

            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
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 13K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/ldap/LdapUserTest.java

        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";
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/SimpleCircuitBreaker.java

        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);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 11.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/reflect/Types.java

        return (type instanceof Class) ? ((Class<?>) type).getName() : type.toString();
      }
    
      static @Nullable Type getComponentType(Type type) {
        checkNotNull(type);
        AtomicReference<@Nullable Type> result = new AtomicReference<>();
        new TypeVisitor() {
          @Override
          void visitTypeVariable(TypeVariable<?> t) {
            result.set(subtypeOfComponentType(t.getBounds()));
          }
    
          @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 14:03:14 UTC 2025
    - 23.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/SmbCircuitBreaker.java

             */
            OPEN,
    
            /**
             * Testing if service has recovered
             */
            HALF_OPEN
        }
    
        private final String name;
        private final AtomicReference<State> state = new AtomicReference<>(State.CLOSED);
        private final AtomicInteger failureCount = new AtomicInteger(0);
        private final AtomicInteger successCount = new AtomicInteger(0);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/reflect/Types.java

        return (type instanceof Class) ? ((Class<?>) type).getName() : type.toString();
      }
    
      static @Nullable Type getComponentType(Type type) {
        checkNotNull(type);
        AtomicReference<@Nullable Type> result = new AtomicReference<>();
        new TypeVisitor() {
          @Override
          void visitTypeVariable(TypeVariable<?> t) {
            result.set(subtypeOfComponentType(t.getBounds()));
          }
    
          @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Sep 03 14:03:14 UTC 2025
    - 23.6K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/indexer/IndexUpdaterTest.java

            final List<String> sessionIdList = Arrays.asList("session1");
            indexUpdater.setSessionIdList(sessionIdList);
    
            final AtomicReference<Throwable> caughtException = new AtomicReference<>();
            indexUpdater.setUncaughtExceptionHandler((t, e) -> caughtException.set(e));
    
            // Make dataService throw ContainerNotAvailableException
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 33K bytes
    - Viewed (0)
Back to top