Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 891 for Caller (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. src/test/java/jcifs/SmbTreeHandleTest.java

        }
    
        /**
         * Test for close() method.
         * Verifies that the close method can be called without throwing an exception.
         * @throws CIFSException
         */
        @Test
        void testClose() throws CIFSException {
            smbTreeHandle.close();
            // Verify that close() was called on the mock
            verify(smbTreeHandle).close();
        }
    
        /**
    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)
  6. 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)
  7. 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)
  8. 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)
  9. 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 {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  10. 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 false
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.2K bytes
    - Click Count (0)
Back to Top