Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 133 for dropCR (0.41 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top