- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 50 for absDate (0.22 sec)
-
subprojects/core/src/integTest/groovy/org/gradle/execution/taskgraph/RuleTaskExecutionIntegrationTest.groovy
gradle.taskGraph.whenReady { println "task container node state when task graph ready: ${registry.state(tasksPath)}" } gradle.buildFinished { registry.atState(tasksPath, ModelNode.State.GraphClosed) println "task container node state after graph closing: ${registry.state(tasksPath)}" } ''' then: succeeds "t1"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 20 11:16:24 UTC 2024 - 7.4K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/core/ModelReference.java
} public ModelReference<T> withPath(ModelPath path) { return Cast.uncheckedCast(new ModelReference<T>(path, type, scope, state, description)); } public ModelReference<T> atState(ModelNode.State state) { if (state.equals(this.state)) { return this; } return Cast.uncheckedCast(new ModelReference<T>(path, type, scope, state, description)); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 6.4K bytes - Viewed (0) -
hack/boilerplate/boilerplate.py
parser = argparse.ArgumentParser() parser.add_argument( "filenames", help="list of files to check, all files if unspecified", nargs="*" ) rootdir = os.path.dirname(__file__) + "/../../" rootdir = os.path.abspath(rootdir) parser.add_argument("--rootdir", default=rootdir, help="root directory to examine") default_boilerplate_dir = os.path.join(rootdir, "hack/boilerplate")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:51 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
func (c *Controller) Run(ch <-chan struct{}) { // wait until process is ready wait.PollImmediateUntil(100*time.Millisecond, func() (bool, error) { var code int c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code) return code == http.StatusOK, nil }, ch) wait.NonSlidingUntil(func() { // Service definition is not reconciled after first
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug_lines_test.go
} else { defer os.RemoveAll(tmpdir) } source, err := filepath.Abs(filepath.Join("testdata", file)) if err != nil { panic(fmt.Sprintf("Could not get abspath of testdata directory and file, %v", err)) } cmd := testenv.Command(t, testenv.GoToolPath(t), "build", "-o", "foo.o", "-gcflags=-d=ssa/genssa/dump="+function+" "+moreGCFlags, source) cmd.Dir = tmpdir
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:24:52 UTC 2023 - 8.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/cmd/server/testing/testserver.go
} err = wait.Poll(100*time.Millisecond, time.Minute, func() (bool, error) { select { case err := <-errCh: return false, err default: } result := client.CoreV1().RESTClient().Get().AbsPath("/healthz").Do(context.TODO()) status := 0 result.StatusCode(&status) if status == 200 { return true, nil } return false, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 9K bytes - Viewed (1) -
cmd/endpoint.go
var absPaths []string for _, endpoint := range endpoints { if endpoint.IsLocal { var absPath string absPath, err = filepath.Abs(endpoint.Path) if err != nil { return err } absPaths = append(absPaths, absPath) } } return mountinfo.CheckCrossDevice(absPaths) } // PoolEndpointList is a temporary type to holds the list of endpoints
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
func (c *PeerEndpointLeaseController) Run(stopCh <-chan struct{}) { // wait until process is ready wait.PollImmediateUntil(100*time.Millisecond, func() (bool, error) { var code int c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code) return code == http.StatusOK, nil }, stopCh) wait.NonSlidingUntil(func() { if err := c.UpdatePeerEndpointLeases(); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
cmd/kubeadm/app/util/apiclient/wait.go
context.Background(), constants.KubernetesAPICallRetryInterval, w.timeout, true, func(ctx context.Context) (bool, error) { healthStatus := 0 w.client.Discovery().RESTClient().Get().AbsPath("/healthz").Do(ctx).StatusCode(&healthStatus) if healthStatus != http.StatusOK { return false, nil } return true, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/testing/testserver.go
err = wait.Poll(100*time.Millisecond, time.Minute, func() (bool, error) { select { case err := <-errCh: return false, err default: } req := client.CoreV1().RESTClient().Get().AbsPath("/healthz") // The storage version bootstrap test wraps the storage version post-start // hook, so the hook won't become health when the server bootstraps if instanceOptions.StorageVersionWrapFunc != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 17.6K bytes - Viewed (0)