- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 667 for caching (0.06 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)