- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 133 for dropCR (0.04 sec)
-
guava-tests/test/com/google/common/cache/PopulatedCachesTest.java
return warmUp(cache, WARMUP_MIN, WARMUP_MAX); } /** * Returns the entries that were added to the map, so they won't fall out of a map with weak or * soft references until the caller drops the reference to the returned entries. */ private List<Entry<Object, Object>> warmUp( LoadingCache<Object, Object> cache, int minimum, int maximum) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 15.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactLinkedHashMap.java
@GwtIncompatible // not worth using in GWT for now final class CompactLinkedHashMap<K extends @Nullable Object, V extends @Nullable Object> extends CompactHashMap<K, V> { // TODO(lowasser): implement removeEldestEntry so this can be used as a drop-in replacement /** Creates an empty {@code CompactLinkedHashMap} instance. */ public static <K extends @Nullable Object, V extends @Nullable Object> CompactLinkedHashMap<K, V> create() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 10.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/RetryAndFollowUpInterceptor.kt
requestBuilder.removeHeader("Transfer-Encoding") requestBuilder.removeHeader("Content-Length") requestBuilder.removeHeader("Content-Type") } } // When redirecting across hosts, drop all authentication headers. This // is potentially annoying to the application layer since they have no // way to retain them. if (!userResponse.request.url.canReuseConnectionFor(url)) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 12.4K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// from a placeholder node "arg_tensor_enqueue_<tensor_id>". // // `tensor` is still owned by the caller. This call will be blocked if the queue // has reached its capacity, and will be unblocked when the queued tensors again // drop below the capacity due to dequeuing. // // Tensors are dequeued via the corresponding TF dequeue op. // TODO(hongm): Add support for `timeout_ms`. TF_CAPI_EXPORT extern void TF_EnqueueNamedTensor(TF_Session* session,
Registered: Tue Dec 30 12:39:10 UTC 2025 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
* Use a exclusive connection for this tree * * If an exclusive connection is used the caller must make sure that the tree handle is kept alive, * otherwise the connection will be disconnected once the usage drops to zero. * * @param np * whether to use an exclusive connection */ void setNonPooled(final boolean np) { this.nonPooled = np; } /**Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 30.4K bytes - Viewed (1) -
src/test/java/jcifs/smb/SmbTreeHandleImplTest.java
@DisplayName("acquire after release reacquires underlying tree connection") void acquireAfterReleaseReacquires() { // After dropping to zero, acquire() should reacquire the underlying connection // Drop usage to zero handle.release(); verify(treeConnection, times(1)).release(); // Acquire from 0 -> 1 should acquire underlying when(treeConnection.acquire()).thenReturn(treeConnection);Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/CompactHashMap.java
@GwtIncompatible // not worth using in GWT for now class CompactHashMap<K extends @Nullable Object, V extends @Nullable Object> extends AbstractMap<K, V> implements Serializable { /* * TODO: Make this a drop-in replacement for j.u. versions, actually drop them in, and test the * world. Figure out what sort of space-time tradeoff we're actually going to get here with the
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Jul 08 18:32:10 UTC 2025 - 39.6K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
h.LastCheckFailure = reqStartTime } } // Round the request time *down* to whole minute. reqTimeMinute := reqStartTime.Truncate(time.Minute) if reqTimeMinute.After(h.currentMinute.statsTime) { // Drop the last full minute now, since we got a request for a time we // are not yet tracking. h.updateLastFullMinute(reqTimeMinute) } var entry *serviceRTTMinuteStats switch {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 13.3K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-HostnamesCommon.kt
*/ internal fun String.toCanonicalHost(): String? { val host: String = this // If the input contains a :, it’s an IPv6 address. if (":" in host) { // If the input is encased in square braces "[...]", drop 'em. val inetAddressByteArray = ( if (host.startsWith("[") && host.endsWith("]")) { decodeIpv6(host, 1, host.length - 1) } else { decodeIpv6(host, 0, host.length)
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 11.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
maxRetries := h.config.MaxRetry retry: // If the channel reaches above half capacity // we spawn more workers. The workers spawned // from this main worker routine will exit // once the channel drops below half capacity // and when it's been at least 30 seconds since // we launched a new worker. if mainWorker && len(h.logCh) > cap(h.logCh)/2 { nWorkers := h.workers.Load() if nWorkers < h.maxWorkers {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0)