- Sort Score
- Result 10 results
- Languages All
Results 301 - 310 of 417 for timeouts (0.09 sec)
-
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* _last_ request, but it remembers the (expected) time of the _next_ request. This also enables * us to tell immediately (see tryAcquire(timeout)) whether a particular timeout is enough to get * us to the point of the next scheduling time, since we always maintain that. And what we mean by * "an unused RateLimiter" is also defined by that notion: when we observe that the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_cluster_test.cc
TestRemoteExecuteUpdateServerDefResourceAccess(true); } void TestRemoteExecuteUpdateServerDefWithFailures(bool async) { // Fail fast on GetStatus requests so we can get errors instead of timeout // when updating cluster with non-exsitent worker tensorflow::setenv("GRPC_FAIL_FAST", "TRUE", /*overwrite=*/1); tensorflow::ServerDef server_def = GetServerDef(2);
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-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return shutdown; } @Override public boolean isTerminated() { return shutdown; } @Override public boolean awaitTermination(long timeout, TimeUnit unit) { return true; } @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:18:12 UTC 2024 - 6.6K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
return nil, fmt.Errorf("unexpected request") } }), } getFirstPodFunc = func(client corev1client.PodsGetter, namespace string, selector string, timeout time.Duration, sortBy func([]*corev1.Pod) sort.Interface) ( *corev1.Pod, int, error, ) { return attachPod(namespace), 1, nil } for _, tt := range tests {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jun 09 18:17:49 UTC 2023 - 6.6K bytes - Viewed (0) -
cmd/utils.go
func NewHTTPTransport() *http.Transport { return NewHTTPTransportWithTimeout(1 * time.Minute) } // Default values for dial timeout const defaultDialTimeout = 5 * time.Second // NewHTTPTransportWithTimeout allows setting a timeout. func NewHTTPTransportWithTimeout(timeout time.Duration) *http.Transport { return xhttp.ConnSettings{ LookupHost: globalDNSCache.LookupHost, DialTimeout: defaultDialTimeout,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 13 22:22:04 UTC 2024 - 31.9K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokio/SegmentPool;->take()Lokio/Segment; HSPLokio/SocketAsyncTimeout;-><init>(Ljava/net/Socket;)V HSPLokio/Timeout$Companion$NONE$1;-><init>()V HSPLokio/Timeout;-><clinit>()V HSPLokio/Timeout;-><init>()V HSPLokio/Timeout;->throwIfReached()V HSPLokio/Timeout;->timeout(JLjava/util/concurrent/TimeUnit;)Lokio/Timeout; HSPLokio/_UtilKt;->arrayRangeEquals([BI[BII)Z HSPLokio/_UtilKt;->checkOffsetAndCount(JJJ)V
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
istioctl/pkg/writer/compare/testdata/configdump_diff.json
}, "route": { "cluster": "inbound-vip|9080|http|details.default.svc.cluster.local", "timeout": "0s", "max_stream_duration": { "max_stream_duration": "0s", "grpc_timeout_header_max": "0s"
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Mar 12 10:02:09 UTC 2024 - 51.6K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.h
// Caller must call TF_DeleteTensor() over the returned tensor. If the queue is // empty, this call is blocked. // // Tensors are enqueued via the corresponding TF enqueue op. // TODO(hongm): Add support for `timeout_ms`. TF_CAPI_EXPORT extern TF_Tensor* TF_DequeueNamedTensor(TF_Session* session, int tensor_id, TF_Status* status);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Thu Apr 27 21:07:00 UTC 2023 - 15.1K bytes - Viewed (0) -
lib/wasm/wasm_exec.js
() => { this._resume(); while (this._scheduledTimeouts.has(id)) { // for some reason Go failed to register the timeout event, log and try again // (temporary workaround for https://github.com/golang/go/issues/28975) console.warn("scheduleTimeoutEvent: missed timeout event"); this._resume(); } }, getInt64(sp + 8), ));
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Aug 30 19:15:21 UTC 2024 - 16.5K bytes - Viewed (0) -
.github/workflows/build.yml
run: ./gradlew -PgraalBuild=true native-image-tests:nativeImage - name: Run Checks run: ./native-image-tests/build/graal/ConsoleLauncher testandroid: runs-on: ubuntu-latest timeout-minutes: 30 if: github.ref == 'refs/heads/master' || contains(github.event.pull_request.labels.*.name, 'android') || contains(github.event.pull_request.labels.*.name, 'renovate') strategy: fail-fast: false
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Aug 17 10:05:29 UTC 2024 - 17.2K bytes - Viewed (0)