- Sort Score
- Num 10 results
- Language All
Results 131 - 140 of 849 for halted (0.04 seconds)
-
android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java
* while {@link #escapeUnsafe} is overridden to handle general escaping of the form {@code \\uxxxx}. * * <p>The size of the data structure used by {@link ArrayBasedCharEscaper} is proportional to the * highest valued character that requires escaping. For example a replacement map containing the * single character '{@code \}{@code u1000}' will require approximately 16K of memory. If you needCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 6.2K bytes - Click Count (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/RepositorySystem.java
* mirror, its URL and ID will be updated to match the values from the mirror specification. Repositories without a * matching mirror will pass through unchanged. Note: This method must be called before * {@link #injectAuthentication(List, List)} or the repositories will end up with the wrong credentials. *Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Oct 25 12:31:46 GMT 2024 - 7.7K bytes - Click Count (0) -
src/test/java/jcifs/http/NtlmHttpURLConnectionTest.java
* We mock a simple 200 OK response to test the handshake is called. * @throws IOException */ @Test void testGettersTriggerHandshake() throws IOException { // Arrange // Spy on the connection to verify handshake() is called NtlmHttpURLConnection spiedConnection = spy(ntlmConnection); doNothing().when(spiedConnection).connect();Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 12.6K bytes - Click Count (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 }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 12K bytes - Click Count (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)
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 12.6K bytes - Click Count (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) *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
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()); } @Test public void test_update_multipleCallsIncrementLoadCount() throws InterruptedException {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Jan 14 14:29:07 GMT 2026 - 4.8K bytes - Click Count (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(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
src/test/java/jcifs/SmbTreeHandleTest.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 7.1K bytes - Click Count (0) -
src/test/java/jcifs/smb/DosFileFilterTest.java
// and a mock SmbFile with specific attributes when(mockFile.getAttributes()).thenReturn(fileAttributes); // When the accept method is called boolean result = dosFileFilter.accept(mockFile); // Then the result should be as expected if (expectedResult) { assertTrue(result, "File should be accepted"); } else {Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 6.2K bytes - Click Count (0)