- Sort Score
- Result 10 results
- Languages All
Results 241 - 250 of 1,055 for Ensure (0.73 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)