- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 891 for Caller (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
src/bufio/bufio.go
b.r++ b.lastByte = int(c) return c, nil } // UnreadByte unreads the last byte. Only the most recently read byte can be unread. // // UnreadByte returns an error if the most recent method called on the // [Reader] was not a read operation. Notably, [Reader.Peek], [Reader.Discard], and [Reader.WriteTo] are not // considered read operations. func (b *Reader) UnreadByte() error {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Fri Feb 06 17:28:40 GMT 2026 - 22K bytes - Click Count (0) -
guava/src/com/google/common/collect/Streams.java
} /** * An analogue of {@link java.util.function.Function} also accepting an index. * * <p>This interface is only intended for use by callers of {@link #mapWithIndex(Stream, * FunctionWithIndex)}. * * @since 21.0 (but only since 33.4.0 in the Android flavor) */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 36.4K 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) -
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) -
src/test/java/jcifs/smb1/smb1/SmbTreeTest.java
ServerMessageBlock response = new SmbComOpenAndXResponse(); // Execute send tree.send(request, response); // Verify session.send was called and tid was set verify(session).send(request, response); assertEquals(123, request.tid); } @Test void testSendWithDfs() throws SmbException {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 07:14:38 GMT 2025 - 10.2K bytes - Click Count (0) -
cmd/service.go
return syscall.Exec(argv0, os.Args, os.Environ()) } // freezeServices will freeze all incoming S3 API calls. // For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
* {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a * method equivalent to {@linkCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 11.5K bytes - Click Count (0) -
src/test/java/jcifs/smb/SSPContextTest.java
} // Verify that calculateMIC was never called verify(mockCtx, never()).calculateMIC(any()); // Verify that supportsIntegrity was checked once verify(mockCtx, times(1)).supportsIntegrity(); // Due to short-circuit evaluation, isEstablished should never be called // when supportsIntegrity returns falseCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 15.2K bytes - Click Count (0)