- Sort Score
- Result 10 results
- Languages All
Results 621 - 630 of 876 for caller (0.04 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/IgnoreCloseInputStream.java
* governing permissions and limitations under the License. */ package org.codelibs.fess.crawler.util; import java.io.IOException; import java.io.InputStream; /** * A wrapper for an {@link InputStream} that ignores the {@link #close()} method call. * This can be useful when you want to prevent the underlying input stream from being closed. *
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 5.3K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java
String result = response.toString(); // Assert assertNotNull(result); assertTrue(result.contains("TransPeekNamedPipeResponse")); // Verify that parent's toString is called (should contain standard fields) assertTrue(result.length() > "TransPeekNamedPipeResponse[]".length()); } @Test @DisplayName("Multiple instances should be independent")
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 15.8K bytes - Viewed (0) -
docs/distributed/README.md
start using the least used cluster. This expansion strategy works endlessly, so you can perpetually expand your clusters as needed. When you restart, it is immediate and non-disruptive to the applications. Each group of servers in the command-line is called a pool. There are 2 server pools in this example. New objects are placed in server pools in proportion to the amount of free space in each pool. Within each pool, the location of the erasure-set of drives is determined based on a deterministic hashing...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 8.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/rank/fusion/RankFusionProcessor.java
* is performed by the init() method which is called after construction. */ public RankFusionProcessor() { // Default constructor - initialization is done in init() method } /** * Initializes the rank fusion processor after construction. * Sets up the window size based on configuration and loads available searchers. * This method is called automatically after the bean is constructed. */
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 24.8K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/base/EnumsBenchmark.java
* See the License for the specific language governing permissions and * limitations under the License. */ package com.google.common.base; import com.google.caliper.BeforeExperiment; import com.google.caliper.Benchmark; import com.google.caliper.Param; import java.util.ArrayList; import java.util.Collections; import java.util.List; import org.jspecify.annotations.NullUnmarked;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 29.4K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/net/NetShareEnumResponseTest.java
assertEquals(type, share.type); assertEquals(remark, share.remark); } @Test @DisplayName("Test setUseUnicode is called with false") void testSetUseUnicode() throws Exception { // Create a spy to verify method call NetShareEnumResponse spyResponse = spy(new NetShareEnumResponse(mockConfig)); setNumEntries(spyResponse, 0); byte[] buffer = new byte[100];
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 20.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/FileOperator.kt
mutablePos += bytesWritten mutableByteCount -= bytesWritten } } /** * Copy [byteCount] bytes from the file at [pos] into `sink`. It is the * caller's responsibility to make sure there are sufficient bytes to read: if there aren't this * method throws an `EOFException`. */ fun read( pos: Long, sink: Buffer, byteCount: Long, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter.awaitWaiting(); PollingThread poller = new PollingThread(future); poller.start(); PollingThread poller2 = new PollingThread(future); poller2.start(); PollingThread poller3 = new PollingThread(future); poller3.start(); poller.awaitInLoop(); poller2.awaitInLoop(); poller3.awaitInLoop(); // The waiter queue should be {poller x 3}->waiter1 waiter.interrupt();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 46.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* either it got collected, or {@link #clear} was called, or it wasn't set in the first place). */ @Nullable V get(); /** Returns the entry which contains this {@link WeakValueReference}. */ E getEntry(); /** Unsets the referenced value. Subsequent calls to {@link #get} will return {@code null}. */ void clear(); /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 90K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/rank/fusion/RankFusionSearcherTest.java
assertEquals("no_suffix_impl", noSuffixSearcher.getName()); } public void test_search_withValidParameters() { // Test that search method is properly called with valid parameters TestRankFusionSearcher testSearcher = new TestRankFusionSearcher(); String query = "test query"; SearchRequestParams params = createTestSearchRequestParams();
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 10.3K bytes - Viewed (0)