Search Options

Results per page
Sort
Preferred Languages
Advance

Results 191 - 200 of 412 for reeds (0.04 sec)

  1. cmd/metrics-v3-cluster-usage.go

    		"Cluster object size distribution", "range")
    	usageVersionsDistributionMD = NewGaugeMD(usageVersionCountDistribution,
    		"Cluster object version count distribution", "range")
    )
    
    // loadClusterUsageObjectMetrics - reads cluster usage metrics.
    //
    // This is a `MetricsLoaderFn`.
    func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	dataUsageInfo, err := c.dataUsageInfo.Get()
    	if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  2. cmd/tier-sweeper.go

    package cmd
    
    import (
    	"context"
    
    	"github.com/minio/minio/internal/bucket/lifecycle"
    )
    
    // objSweeper determines if a transitioned object needs to be removed from the remote tier.
    // A typical usage would be like,
    // os := newObjSweeper(bucket, object)
    // // Perform a ObjectLayer.GetObjectInfo to fetch object version information
    // goiOpts := os.GetOpts()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Suppliers.java

        public T get() {
          // Another variant of Double Checked Locking.
          //
          // We use two volatile reads. We could reduce this to one by
          // putting our fields into a holder class, but (at least on x86)
          // the extra memory consumption and indirection are more
          // expensive than the extra volatile reads.
          long nanos = expirationNanos;
          long now = System.nanoTime();
          if (nanos == 0 || now - nanos >= 0) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 16.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

          // call to addListener() will callback to setOneValue(), transitively call our cleanup
          // listener, and set this.futures to null.
          // This is not actually a problem, since the foreach only needs this.futures to be non-null
          // at the beginning of the loop.
          int i = 0;
          for (ListenableFuture<? extends InputT> future : futures) {
            int index = i++;
            if (future.isDone()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  5. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    {* ../../docs_src/dependencies/tutorial008_an_py39.py hl[6,14,22] *}
    
    And all of them can use `yield`.
    
    In this case `dependency_c`, to execute its exit code, needs the value from `dependency_b` (here named `dep_b`) to still be available.
    
    And, in turn, `dependency_b` needs the value from `dependency_a` (here named `dep_a`) to be available for its exit code.
    
    {* ../../docs_src/dependencies/tutorial008_an_py39.py hl[18:19,26:27] *}
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

    // Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause
    // getDeclaredField to throw a NoSuchFieldException when the field is definitely there.
    // Since this class only needs CAS on one field, we can avoid this bug by extending AtomicReference
    // instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances
    // and DONE/INTERRUPTED - they have a common ancestor of Runnable.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 10K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *       MoreExecutors.listeningDecorator}.
     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  8. guava/src/com/google/common/collect/Serialization.java

     * serialize collections that are defined elsewhere.
     *
     * @author Jared Levy
     */
    @GwtIncompatible
    @J2ktIncompatible
    final class Serialization {
      private Serialization() {}
    
      /**
       * Reads a count corresponding to a serialized map, multiset, or multimap. It returns the size of
       * a map serialized by {@link #writeMap(Map, ObjectOutputStream)}, the number of distinct elements
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/dcerpc/msrpc/lsarpcIntegrationTest.java

            decodedName.decode(decodeBuffer);
    
            // Verify the decoded data matches
            assertEquals(translatedName.sid_type, decodedName.sid_type);
            // The decode process doesn't preserve the original length, it reads from the buffer
            assertNotNull(decodedName.name);
            assertNotNull(decodedName.name.buffer);
            // Buffer length is based on maximum_length/2 from the encoded data
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  10. docs/en/docs/tutorial/request-files.md

    `UploadFile` has the following `async` methods. They all call the corresponding file methods underneath (using the internal `SpooledTemporaryFile`).
    
    * `write(data)`: Writes `data` (`str` or `bytes`) to the file.
    * `read(size)`: Reads `size` (`int`) bytes/characters of the file.
    * `seek(offset)`: Goes to the byte position `offset` (`int`) in the file.
        * E.g., `await myfile.seek(0)` would go to the start of the file.
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:15:41 UTC 2025
    - 7.3K bytes
    - Viewed (0)
Back to top