- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 594 for ensures (0.21 sec)
-
guava/src/com/google/common/collect/RegularImmutableMap.java
new RegularImmutableMap<>((Entry<Object, Object>[]) ImmutableMap.EMPTY_ENTRY_ARRAY, null, 0); /** * Closed addressing tends to perform well even with high load factors. Being conservative here * ensures that the table is still likely to be relatively sparse (hence it misses fast) while * saving space. */ @VisibleForTesting static final double MAX_LOAD_FACTOR = 1.2; /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 28 18:11:09 UTC 2024 - 16.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
// // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do // blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last. // This ensures that we never wait for a blocking operation while holding 'this'. /** True if this peer initiated the connection. */ internal val client: Boolean = builder.client
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt
/** * Access every declaration that is deprecated with [DeprecationLevel.ERROR]. Although new Kotlin * code shouldn't use these, they're necessary for clients migrating from OkHttp 3.x and this test * ensures the symbols remain available and with the expected parameter and return types. */ @Suppress( "DEPRECATION_ERROR", "UNUSED_VALUE", "UNUSED_VARIABLE", "VARIABLE_WITH_REDUNDANT_INITIALIZER", )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* calling thread wait for that time. * * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after * the last one, then we achieve the intended rate. If a request comes and the last request was
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
cmd/erasure-decode.go
// Subsequent reads will reuse this buffer. p.buf[bufIdx] = make([]byte, p.shardSize) } // For the last shard, the shardsize might be less than previous shard sizes. // Hence the following statement ensures that the buffer size is reset to the right size. p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize] n, err := rr.ReadAt(p.buf[bufIdx], p.offset) if err != nil { switch { case errors.Is(err, errFileNotFound):
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
guava/src/com/google/common/base/FinalizableReferenceQueue.java
* // You might also share this between several objects. * * private static final Set<Reference<?>> references = Sets.newConcurrentHashSet(); * // This ensures that the FinalizablePhantomReference itself is not garbage-collected. * * private final ServerSocket serverSocket; * * private MyServer(...) { * ... * this.serverSocket = new ServerSocket(...);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Jul 11 20:51:36 UTC 2024 - 13.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
return this.handle; } return this.handle.acquire(); } /** * Ensures that the file descriptor is openend * * @throws CIFSException */ public void open () throws CIFSException { try ( SmbFileHandleImpl fh = ensureOpen() ) {} } @Override
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Wed Jan 08 12:01:33 UTC 2020 - 18.5K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java
throw new RepositoryMetadataReadException( "Cannot read metadata from '" + mappingFile + "': " + e.getMessage(), e); } } /** * Ensures the last updated timestamp of the specified metadata does not refer to the future and fixes the local * metadata if necessary to allow proper merging/updating of metadata during deployment. */
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 18.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/CompactHashSet.java
} Set<E> delegate = delegateOrNull(); return (delegate != null) ? delegate.toArray(a) : ObjectArrays.toArrayImpl(requireElements(), 0, size, a); } /** * Ensures that this {@code CompactHashSet} has the smallest representation in memory, given its * current size. */ public void trimToSize() { if (needsAllocArrays()) { return; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 20:24:49 UTC 2024 - 24K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// newFuture's lifetime is determined by taskFuture, which can't complete before oldFuture // unless taskFuture is cancelled, in which case it falls back to oldFuture. This ensures that // if the future we return is cancelled, we don't begin execution of the next task until after // oldFuture completes. Runnable listener = () -> { if (taskFuture.isDone()) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0)