- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 721 for Scaled (0.08 sec)
-
src/test/java/org/codelibs/fess/helper/AbstractConfigHelperTest.java
configHelper.setLoadCallback(() -> { latch.countDown(); return 1; }); configHelper.update(); assertTrue("Load method should be called within 5 seconds", latch.await(5, TimeUnit.SECONDS)); assertEquals(1, configHelper.getLoadCallCount()); } public void test_update_multipleCallsIncrementLoadCount() throws InterruptedException {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sat Jul 12 00:03:47 UTC 2025 - 4.7K bytes - Viewed (0) -
cmd/local-locker.go
} return true } func (l *localLocker) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > maxDeleteList { return false, fmt.Errorf("internal error: localLocker.Lock called with more than %d resources", maxDeleteList) } // If we have too many waiting, reject this at once. if l.waitMutex.Load() > lockMutexWaitLimit { l.locksOverloaded.Add(1) return false, nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 12K bytes - Viewed (0) -
internal/lru/lru.go
// } // close(c.done) // } // removeOldest removes the oldest item from the cache. Has to be called with lock! func (c *LRU[K, V]) removeOldest() { if ent := c.evictList.Back(); ent != nil { c.removeElement(ent) } } // removeElement is used to remove a given list element from the cache. Has to be called with lock! func (c *LRU[K, V]) removeElement(e *Entry[K, V]) { c.evictList.Remove(e)
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Fri Apr 25 08:22:26 UTC 2025 - 12.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// JVM shutdown will not be prevented from exiting after this service has stopped or failed. // Technically this listener is added after start() was called so it is a little gross, but it // is called within doStart() so we know that the service cannot terminate or fail concurrently // with adding this listener so it is impossible to miss an event that we are interested in. addListener(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* requireNonNull is safe because we don't null out `sequencer` except: * * - after the requireNonNull call below. (And this object has its Runnable.run override * called only once, just as it has its Executor.execute override called only once.) * * - if we return immediately from `execute` (in which case we never get here) *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
docs/integrations/veeam/README.md
### Creating the Scale-out Backup Repository - Under the Backup Infrastructure view, click on Scale-out Repositories and click the Add Scale-out Repository button on the ribbon. - Follow the on screen wizard
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 5.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Callback.kt
import okio.IOException interface Callback { /** * Called when the request could not be executed due to cancellation, a connectivity problem or * timeout. Because networks can fail during an exchange, it is possible that the remote server * accepted the request before the failure. */ fun onFailure( call: Call, e: IOException, ) /**
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 1.6K bytes - Viewed (0) -
android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java
* * <p>If a code point has no mapped replacement then it is checked against the safe range. If it * lies outside that, then {@link #escapeUnsafe} is called, otherwise no escaping is performed. * * @param replacementMap a map of characters to their escaped representations * @param safeMin the lowest character value in the safe range
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 15:45:16 UTC 2025 - 8.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/protwords/ProtwordsCreator.java
*/ public ProtwordsCreator() { super("protwords.*\\.txt"); } /** * Registers this creator with the dictionary manager. * This method is called automatically after construction to add this creator to the dictionary manager. */ @PostConstruct public void register() { if (logger.isInfoEnabled()) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/ForwardingWrapperTester.java
assertEquals(method, calledMethod); assertEquals(method + " invoked more than once.", 0, called.get()); for (int i = 0; i < passedArgs.length; i++) { assertEquals( "Parameter #" + i + " of " + method + " not forwarded", passedArgs[i], args[i]); } called.getAndIncrement(); return returnValue; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 9.1K bytes - Viewed (0)