- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 145 for timediv (0.26 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
copied := newObj.DeepCopyObject() if customReconciler != nil { err = customReconciler(namespace, name, newObj) } select { case reconciledObjects <- copied: case <-ctx.Done(): panic("timed out attempting to deliver reconcile event") } return err } waitForReconcile = func(obj runtime.Object) error { select { case reconciledObj := <-reconciledObjects:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
src/crypto/tls/tls.go
if err != nil { return nil, err } return NewListener(l, config), nil } type timeoutError struct{} func (timeoutError) Error() string { return "tls: DialWithDialer timed out" } func (timeoutError) Timeout() bool { return true } func (timeoutError) Temporary() bool { return true } // DialWithDialer connects to the given network address using dialer.Dial and
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
if err != nil { return storage.NewInternalErrorf("unable to transform key %q: %v", kv.Key, err) } // Check if the request has already timed out before decode object select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return storage.NewTimeoutError(string(kv.Key), "request did not complete within requested timeout") default: }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/webhook.go
} return sarErr }, webhook.DefaultShouldRetry); err != nil { klog.Errorf("Failed to make webhook authorizer request: %v", err) // we're returning NoOpinion, and the parent context has not timed out or been canceled if w.decisionOnError == authorizer.DecisionNoOpinion && ctx.Err() == nil { w.metrics.RecordWebhookFailOpen(ctx, w.name, metricsResult) } return w.decisionOnError, "", err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 18.4K bytes - Viewed (0) -
tests/integration/pilot/analyze_test.go
istioCtl := istioctl.NewOrFail(t, t, istioctl.Config{}) // We should time out immediately. _, err := istioctlSafe(t, istioCtl, ns.Name(), true, "--timeout=0s") g.Expect(err.Error()).To(ContainSubstring("timed out")) }) } // Verify the error line number in the message is correct func TestErrorLine(t *testing.T) { // nolint: staticcheck framework. NewTest(t). RequiresSingleCluster().
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 16.3K bytes - Viewed (0) -
platforms/documentation/docs/src/docs/userguide/authoring-builds/tasks/controlling_task_execution.adoc
The task will be marked as `FAILED`. <<sec:finalizer_tasks,Finalizer tasks>> are executed. If `--continue` is used, other tasks continue running. Tasks that don't respond to interrupts can't be timed out. All of Gradle's built-in tasks respond to timeouts. ==== include::sample[dir="snippets/tasks/timeout/kotlin",files="build.gradle.kts[tags=without-import]"]
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Mar 23 22:37:03 UTC 2024 - 14.2K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
t.Fatal("Write which previously failed should still time out") } // Verify the error if ne := err.(net.Error); ne.Temporary() != false { t.Error("Write timed out but incorrectly classified the error as Temporary") } if !isTimeoutError(err) { t.Error("Write timed out but did not classify the error as a Timeout") } } type readerFunc func([]byte) (int, error)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver_test.go
expectedFailure: true, }, } for _, c := range cases { _, err := r.GetPublicKey(c.in[0], c.in[1], c.timeout) if c.timeout < serverDelay && err == nil { t.Errorf("GetPublicKey(\"\", %+v) fails: did not timed out as expected", c) } else if c.timeout >= serverDelay && err != nil { t.Errorf("GetPublicKey(\"\", %+v) fails: expected no error, got (%v)", c, err) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
private Futures() {} /** * Creates a {@code ListenableFuture} which has its value set immediately upon construction. The * getters just return the value. This {@code Future} can't be canceled or timed out and its * {@code isDone()} method always returns {@code true}. */ public static <V extends @Nullable Object> ListenableFuture<V> immediateFuture( @ParametricNullness V value) { if (value == null) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0)