Search Options

Results per page
Sort
Preferred Languages
Advance

Results 481 - 490 of 667 for caching (0.09 sec)

  1. cmd/admin-handlers-config-kv.go

    		return
    	}
    
    	writeSuccessResponseHeadersOnly(w)
    }
    
    // GetConfigHandler - GET /minio/admin/v3/config
    //
    // This endpoint is mainly for exporting and backing up the configuration.
    // Secrets are not redacted.
    func (a adminAPIHandlers) GetConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_cluster_test.cc

      TFE_DeleteOp(op);
    
      // The device of var_handle1 is remote device, which was replaced during
      // cluster update. Removing resource with invalid device should fail
      // gracefully (i.e., with error status) instead of crashing with segfaults.
      op = TFE_NewOp(ctx, "DestroyResourceOp", status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_OpAddInput(op, var_handle1, status);
      TFE_OpSetDevice(op, dev1_name, status);
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/CompactHashSet.java

     */
    
    package com.google.common.collect;
    
    import static com.google.common.collect.CollectPreconditions.checkRemove;
    import static com.google.common.collect.CompactHashing.UNSET;
    import static com.google.common.collect.Hashing.smearedHash;
    import static java.lang.Math.max;
    import static java.lang.Math.min;
    import static java.util.Objects.requireNonNull;
    
    import com.google.common.annotations.GwtIncompatible;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/reflect/InvokableTest.java

      // case, but we do check that its API still has the same public methods. We exclude some methods
      // that were added in Java 9 and that people probably weren't calling via Invokable, namely
      // `boolean canAccess(Object)`.
      public void testApiCompatibleWithAccessibleObject() {
        ImmutableSet<String> invokableMethods =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

       * permits in a cool state, where X = rate * timeToCoolDown, and we have specified a
       * timeToWarmUp() period, it will cost as the prescribed amount of time. E.g., calling
       * [acquire(5), acquire(1)] takes exactly the same time as [acquire(2), acquire(3), acquire(1)].
       */
      public void testTimeToWarmUpIsHonouredEvenWithWeights() {
        Random random = new Random();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

       * permits in a cool state, where X = rate * timeToCoolDown, and we have specified a
       * timeToWarmUp() period, it will cost as the prescribed amount of time. E.g., calling
       * [acquire(5), acquire(1)] takes exactly the same time as [acquire(2), acquire(3), acquire(1)].
       */
      public void testTimeToWarmUpIsHonouredEvenWithWeights() {
        Random random = new Random();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/reflect/InvokableTest.java

      // case, but we do check that its API still has the same public methods. We exclude some methods
      // that were added in Java 9 and that people probably weren't calling via Invokable, namely
      // `boolean canAccess(Object)` and `boolean trySetAccessible()`.
      public void testApiCompatibleWithAccessibleObject() {
        ImmutableSet<String> invokableMethods =
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 13:00:28 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  8. cmd/metacache-stream.go

    			current.Last = o.name
    		}
    		if n > 0 || current.n == 0 {
    			current.EOS = true
    			finishBlock()
    		}
    	}()
    	return &w
    }
    
    // Close the stream.
    // The incoming channel must be closed before calling this.
    // Returns the first error the occurred during the writing if any.
    func (w *metacacheBlockWriter) Close() error {
    	w.wg.Wait()
    	return w.streamErr
    }
    
    type metacacheBlock struct {
    	data  []byte
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  9. internal/grid/muxclient.go

    	}
    	return m.parent.send(m.ctx, dst)
    }
    
    // RequestStateless will send a single payload request and stream back results.
    // req may not be read/written to after calling.
    // TODO: Not implemented
    func (m *muxClient) RequestStateless(h HandlerID, req []byte, out chan<- Response) {
    	if m.init {
    		out <- Response{Err: errors.New("mux client already used")}
    	}
    	m.init = true
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/Optional.java

       * Number value = first.or(0.5); // error
       * }</pre>
       *
       * <p>As a workaround, it is always safe to cast an {@code Optional<? extends T>} to {@code
       * Optional<T>}. Casting either of the above example {@code Optional} instances to {@code
       * Optional<Number>} (where {@code Number} is the desired output type) solves the problem:
       *
       * <pre>{@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 15.4K bytes
    - Viewed (0)
Back to top