- Sort Score
- Result 10 results
- Languages All
Results 681 - 690 of 976 for closer (0.21 sec)
-
tests/lru_test.go
t.Fatalf("values differs from expected") } } // func TestExpirableMultipleClose(_ *testing.T) { // lc :=lru.NewLRU[string, string](10, nil, 0) // lc.Close() // // should not panic // lc.Close() // } func TestLRUWithPurge(t *testing.T) { var evicted []string lc := lru.NewLRU(10, func(key string, value string) { evicted = append(evicted, key, value) }, 150*time.Millisecond)
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Sun May 25 07:40:40 UTC 2025 - 10.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/TestIntegerSetGenerator.java
* * <p>Note: This default implementation is overkill (but valid) for an unordered container. An * equally valid implementation for an unordered container is to throw an exception. The chosen * implementation, however, has the advantage of working for insertion-ordered containers, as * well. */ @Override public List<Integer> order(List<Integer> insertionOrder) { return insertionOrder; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Dec 21 14:50:24 UTC 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/androidMain/kotlin/okhttp3/internal/platform/android/AndroidLog.kt
object AndroidLogHandler : Handler() { override fun publish(record: LogRecord) { androidLog(record.loggerName, record.androidLevel, record.message, record.thrown) } override fun flush() { } override fun close() { } } @SuppressSignatureCheck object AndroidLog { private const val MAX_LOG_LENGTH = 4000 // Keep references to loggers to prevent their configuration from being GC'd.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 22 20:03:31 UTC 2025 - 4K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/HashingTest.java
private void countRemaps(long h, AtomicLongMap<Integer> map) { int last = 0; for (int shards = 2; shards <= MAX_SHARDS; shards++) { int chosen = Hashing.consistentHash(h, shards); if (chosen != last) { map.incrementAndGet(shards); last = chosen; } } } private static final int ITERS = 10000; private static final int MAX_SHARDS = 500;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 26.4K bytes - Viewed (2) -
src/main/java/jcifs/smb1/util/MimeMap.java
inLen += n; } if (inLen < 100 || inLen == IN_SIZE) { throw new IOException("Error reading jcifs/smb1/util/mime.map resource"); } is.close(); } /** * Returns the MIME type for the given file extension. * If no mapping is found, returns "application/octet-stream" as the default. *Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/suggest/settings/ElevateWordSettingsTest.java
runner.ensureYellow(); } @AfterClass public static void afterClass() throws Exception { runner.close(); runner.clean(); } @Before public void before() throws Exception { try { runner.admin().indices().prepareDelete("_all").execute().actionGet(); } catch (IndexNotFoundException ignore) { } runner.refresh();
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Thu Aug 07 02:41:28 UTC 2025 - 5.6K bytes - Viewed (0) -
docs/sts/assume-role.go
if sessionPolicyFile != "" { var policy string if f, err := os.Open(sessionPolicyFile); err != nil { log.Fatalf("Unable to open session policy file: %v", err) } else { defer f.Close() bs, err := io.ReadAll(f) if err != nil { log.Fatalf("Error reading session policy file: %v", err) } policy = string(bs) } stsOpts.Policy = policy } if expiryDuration != 0 {Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sat Aug 17 01:24:54 UTC 2024 - 4.4K bytes - Viewed (1) -
PULL_REQUESTS_ETIQUETTE.md
- Document testing steps in the PR summary if manual testing was performed. 4. **Before Submitting**: - Run `make verify` to check formatting, linting, and tests. - Reference related issues (e.g., “Closes #1234”). - Notify team members via GitHub `@mentions` if urgent or complex. ## Reviewing PRs Reviewers ensure MinIO’s commit history remains a clear, reliable record. Responsibilities include:
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun May 25 16:32:03 UTC 2025 - 4.7K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/io/ByteSourceAsCharSourceReadBenchmark.java
// one. (StringCoding$StringDecoder vs. StreamDecoder). StringCoding has a ton of special cases // theoretically we could duplicate all that logic here to try to beat 'new String' or at least // come close. USING_DECODER_WITH_SIZE_HINT { @Override String read(ByteSource byteSource, Charset cs) throws IOException { Optional<Long> size = byteSource.sizeIfKnown();Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 5.2K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComReadAndX.java
this.maxCount = this.minCount = maxCount; } @Override protected int getBatchLimit(final Configuration cfg, final byte cmd) { return cmd == SMB_COM_CLOSE ? cfg.getBatchLimit("ReadAndX.Close") : 0; } @Override protected int writeParameterWordsWireFormat(final byte[] dst, int dstIndex) { final int start = dstIndex; SMBUtil.writeInt2(this.fid, dst, dstIndex);Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 5.4K bytes - Viewed (0)