Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1341 - 1350 of 2,060 for must (0.05 sec)

  1. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

          assertTrue(burst <= 1000);
          long afterBurst = measureTotalTimeMillis(limiter, oneSecWorthOfWork, new Random());
          // but work beyond that must take at least one second
          assertTrue(afterBurst >= 1000);
        }
      }
    
      /**
       * This neat test shows that no matter what weights we use in our requests, if we push X amount of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/ImmutableRangeSet.java

         *
         * @throws IllegalArgumentException if {@code range} is empty
         */
        @CanIgnoreReturnValue
        public Builder<C> add(Range<C> range) {
          checkArgument(!range.isEmpty(), "range must not be empty, but was %s", range);
          ranges.add(range);
          return this;
        }
    
        /**
         * Add all ranges from the specified range set to this builder. Adjacent ranges are permitted
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 27K bytes
    - Viewed (0)
  3. tensorflow/c/c_api_experimental.cc

      memcpy(ret, debug_str.c_str(), *len + 1);
      return ret;
    }
    
    // On success, returns a set of TF_Function instances from `text_proto` of
    // GraphDef type. These functions must be deleted by calling TF_DeleteFunction.
    //
    // If `mutate_proto_func` is non-NULL, run it over each FunctionDef proto,
    // before creating a TF_Function out of the possibly mutated proto.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 29.5K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

    /**
     * A single attempt to connect to a remote server, including these steps:
     *
     *  * [TCP handshake][connectSocket]
     *  * Optional [CONNECT tunnels][connectTunnel]. When using an HTTP proxy to reach an HTTPS server
     *    we must send a `CONNECT` request, and handle authorization challenges from the proxy.
     *  * Optional [TLS handshake][connectTls].
     *
     * Each step may fail. If a retry is possible, a new instance is created with the next plan, which
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    	return value == replaceDirective
    }
    
    // userMetadataKeyPrefixes contains the prefixes of used-defined metadata keys.
    // All values stored with a key starting with one of the following prefixes
    // must be extracted from the header.
    var userMetadataKeyPrefixes = []string{
    	"x-amz-meta-",
    	"x-minio-meta-",
    }
    
    // extractMetadataFromReq extracts metadata from HTTP header and HTTP queryString.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    	defer func() {
    		res := make(map[string]string)
    		if err != nil {
    			res["err"] = err.Error()
    		}
    		stopFn(res)
    	}()
    
    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    	var lc *lifecycle.Lifecycle
    
    	// Check if the current bucket has a configured lifecycle policy
    	if globalLifecycleSys != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  7. internal/grid/muxclient.go

    	defer m.respMu.Unlock()
    	if m.closed {
    		return errors.New("mux client closed")
    	}
    	return m.sendLocked(msg)
    }
    
    // sendLocked the message. msg.Seq and msg.MuxID will be set.
    // m.respMu must be held.
    func (m *muxClient) sendLocked(msg message) error {
    	dst := GetByteBufferCap(msg.Msgsize())
    	msg.Seq = m.SendSeq
    	msg.MuxID = m.MuxID
    	msg.Flags |= m.BaseFlags
    	if debugPrint {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/MultimapsTest.java

        assertFalse(unmod.keys().contains("pwnd"));
      }
    
      /**
       * The supplied multimap will be mutated and an unmodifiable instance used in its stead. The
       * multimap must support null keys and values.
       */
      private static void checkUnmodifiableMultimap(
          Multimap<@Nullable String, @Nullable Integer> multimap, boolean permitsDuplicates) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 38.4K bytes
    - Viewed (0)
  9. docs/bucket/replication/DESIGN.md

    `X-Amz-Replication-Status` of `REPLICA`. The status of DeleteMarker replication is returned by `X-Minio-Replication-DeleteMarker-Status` header on `HEAD/GET` calls for the delete marker version in question - i.e with `mc stat --version-id dm-version-id`
    
    It must be noted that if active-active replication is set up with delete marker replication, there is potential for duplicate delete markers to be created if both source and target concurrently set a Delete Marker or if one/both of the clusters went down at...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  10. compat/maven-artifact/src/main/java/org/apache/maven/artifact/versioning/VersionRange.java

            int index = process.indexOf(',');
    
            if (index < 0) {
                if (!lowerBoundInclusive || !upperBoundInclusive) {
                    throw new InvalidVersionSpecificationException("Single version must be surrounded by []: " + spec);
                }
    
                ArtifactVersion version = new DefaultArtifactVersion(process);
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 19K bytes
    - Viewed (0)
Back to top