Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 145 for timediv (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. istioctl/pkg/waypoint/waypoint.go

    								programmed = true
    								break
    							}
    						}
    					}
    					if programmed {
    						break
    					}
    					if time.Since(startTime) > waitTimeout {
    						errorMsg := fmt.Sprintf("timed out while waiting for waypoint %v/%v", gw.Namespace, gw.Name)
    						if err != nil {
    							errorMsg += fmt.Sprintf(": %s", err)
    						}
    						return fmt.Errorf(errorMsg)
    					}
    				}
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 15:59:33 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top