Search Options

Results per page
Sort
Preferred Languages
Advance

Results 241 - 250 of 1,055 for Ensure (0.03 sec)

  1. guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java

    import java.util.ArrayList;
    import java.util.List;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.jspecify.annotations.NullMarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Tester to ensure forwarding wrapper works by delegating calls to the corresponding method with
     * the same parameters forwarded and return value forwarded back or exception propagated as is.
     *
     * <p>For example:
     *
     * {@snippet :
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  2. cmd/bucket-policy.go

    		vStr, ok := v.(string)
    		if ok {
    			// Trim any LDAP specific prefix
    			args[strings.ToLower(strings.TrimPrefix(k, "ldap"))] = []string{vStr}
    		}
    	}
    
    	// Add groups claim which could be a list. This will ensure that the claim
    	// `jwt:groups` works.
    	if grpsVal, ok := claims["groups"]; ok {
    		if grpsIs, ok := grpsVal.([]any); ok {
    			grps := []string{}
    			for _, gI := range grpsIs {
    				if g, ok := gI.(string); ok {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Striped.java

      }
    
      /**
       * ReadWriteLock implementation whose read and write locks retain a reference back to this lock.
       * Otherwise, a reference to just the read lock or just the write lock would not suffice to ensure
       * the {@code ReadWriteLock} is retained.
       */
      private static final class WeakSafeReadWriteLock implements ReadWriteLock {
        private final ReadWriteLock delegate;
    
        WeakSafeReadWriteLock() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 16 22:01:32 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/helper/MemoryDataHelper.java

     *
     * <p>The class is thread-safe due to the use of {@code synchronized} keyword on methods that
     * modify the internal data structures. The internal maps are also declared as {@code volatile}
     * to ensure visibility of changes across threads.
     *
     * <p>The class also provides methods to manage URL patterns for inclusion and exclusion, which
     * are stored as {@code Pattern} objects.
     */
    public class MemoryDataHelper {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/ds/DataStoreFactory.java

        /**
         * Timestamp of the last time data store names were loaded from plugin files.
         * Used to implement a time-based cache refresh mechanism.
         * Volatile to ensure visibility across threads.
         */
        protected volatile long lastLoadedTime = 0;
    
        /**
         * Creates a new instance of DataStoreFactory.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/collect/ImmutableSortedMultisetTest.java

        assertEquals(4, list.lastIndexOf("b"));
      }
    
      public void testCopyOfDefensiveCopy() {
        // Depending on JDK version, either toArray() or toArray(T[]) may be called... use this class
        // rather than mocking to ensure that one of those methods is called.
        class TestArrayList<E> extends ArrayList<E> {
          boolean toArrayCalled = false;
    
          @Override
          public Object[] toArray() {
            toArrayCalled = true;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 22.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

        this.replacements = escaperMap.getReplacementArray();
        this.replacementsLength = replacements.length;
        if (safeMax < safeMin) {
          // If the safe range is empty, set the range limits to opposite extremes
          // to ensure the first test of either value will (almost certainly) fail.
          safeMax = Character.MIN_VALUE;
          safeMin = Character.MAX_VALUE;
        }
        this.safeMin = safeMin;
        this.safeMax = safeMax;
      }
    
      /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. api/maven-api-di/src/main/java/org/apache/maven/di/tool/DiIndexProcessor.java

                        writer.write(newContent);
                    }
                } catch (IOException e) {
                    logError("Failed to write to file", e);
                    throw e; // Re-throw to ensure the compilation fails
                }
            } else {
                logMessage(Diagnostic.Kind.NOTE, "Content unchanged. Skipping file update.");
            }
        }
    
        /**
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Apr 03 13:33:59 UTC 2025
    - 7.8K bytes
    - Viewed (0)
  9. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java

            }
    
            /**
             * Establishes a connection to the GCS service.
             * This method creates a GCS Storage client using environment variables for configuration.
             * This method is synchronized to ensure thread-safe connection initialization.
             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

            }
    
            /**
             * Establishes a connection to the S3 service.
             * This method creates an AWS S3 client using environment variables for configuration.
             * This method is synchronized to ensure thread-safe connection initialization.
             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
Back to top