Search Options

Results per page
Sort
Preferred Languages
Advance

Results 221 - 230 of 303 for caliper (0.07 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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 15K bytes
    - Viewed (0)
  2. guava/src/com/google/common/hash/HashCode.java

       * most-significant bytes.
       *
       * @since 14.0 (since 11.0 as {@code Hashing.padToLong(HashCode)})
       */
      public abstract long padToLong();
    
      /**
       * Returns the value of this hash code as a byte array. The caller may modify the byte array;
       * changes to it will <i>not</i> be reflected in this {@code HashCode} object or any other arrays
       * returned by this method.
       */
      // TODO(user): consider ByteString here, when that is available
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 19:54:59 UTC 2024
    - 12.6K bytes
    - Viewed (0)
  3. internal/config/identity/plugin/config.go

    func (h *metrics) setConnFailure(reqStartTime time.Time) {
    	h.Lock()
    	defer h.Unlock()
    	h.LastCheckFailure = reqStartTime
    }
    
    func (h *metrics) updateLastFullMinute(currReqMinute time.Time) {
    	// Assumes the caller has h.Lock()'ed
    	h.lastFullMinute = h.currentMinute
    	h.currentMinute = serviceRTTMinuteStats{
    		statsTime: currReqMinute,
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

      // These properties are guarded by [lock].
    
      /**
       * If true, no new exchanges can be created on this connection. It is necessary to set this to
       * true when removing a connection from the pool; otherwise a racing caller might get it from the
       * pool when it shouldn't. Symmetrically, this must always be checked before returning a
       * connection from the pool.
       *
       * Once true this is always true. Guarded by this.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractService.java

       * called multiple times.
       *
       * <p>When this method is called {@link #state()} will return {@link State#STOPPING}, which is the
       * external state observable by the caller of {@link #stopAsync}.
       *
       * @since 27.0
       */
      @ForOverride
      protected void doCancelStart() {}
    
      @CanIgnoreReturnValue
      @Override
      public final Service startAsync() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.7K bytes
    - Viewed (0)
  6. cmd/tier.go

    	return valid
    }
    
    // isTierNameInUse returns tier type and true if there exists a remote tier by
    // name tierName, otherwise returns madmin.Unsupported and false. N B this
    // function is meant for internal use, where the caller is expected to take
    // appropriate locks.
    func (config *TierConfigMgr) isTierNameInUse(tierName string) (madmin.TierType, bool) {
    	if t, ok := config.Tiers[tierName]; ok {
    		return t.Type, true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. cmd/s3-zip-handlers.go

    			return
    		}
    		return
    	}
    }
    
    // listObjectsV2InArchive generates S3 listing result ListObjectsV2Info from zip file, all parameters are already validated by the caller.
    func listObjectsV2InArchive(ctx context.Context, objectAPI ObjectLayer, bucket, prefix, token, delimiter string, maxKeys int, startAfter string, h http.Header) (ListObjectsV2Info, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/Response.kt

       * auth param in the challenge at key null. Invalid headers and challenges are ignored.
       * No semantic validation is done, for example that `Basic` auth must have a `realm`
       * auth param, this is up to the caller that interprets these challenges.
       */
      fun challenges(): List<Challenge> {
        return headers.parseChallenges(
          when (code) {
            HTTP_UNAUTHORIZED -> "WWW-Authenticate"
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jul 06 09:38:30 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

      //    visible to done(). This is because there is no happens before edge between the write and a
      //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
      //    it would just add an edge such that if done() observed non-null, then it would also
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  10. internal/rest/client.go

    		// side-channel check has failed, we shall take
    		// the client offline in such situations.
    		// generally all implementations should simply return
    		// 403, but in situations where there is a dependency
    		// with the caller to take the client offline purpose
    		// fully it should make sure to respond with '412'
    		// instead, see cmd/storage-rest-server.go for ideas.
    		if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top