- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 787 for waits (0.04 sec)
-
subprojects/core/src/test/groovy/org/gradle/execution/plan/edges/NodeDependencySetTest.groovy
class NodeDependencySetTest extends Specification { def node = Stub(Node) def set = new DependencySuccessorsOnlyNodeSet() def "does not wait when the set is empty"() { expect: set.getState(node) == Node.DependenciesState.COMPLETE_AND_SUCCESSFUL } def "waits until all dependencies have completed successfully"() { def dep1 = Stub(Node) def dep2 = Stub(Node) given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 12 20:17:10 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/test/util/assert/tracker.go
func (t *Tracker[T]) Empty() { t.t.Helper() t.mu.Lock() defer t.mu.Unlock() if len(t.events) != 0 { t.t.Fatalf("unexpected events: %v", t.events) } } // WaitOrdered waits for an event to happen, in order func (t *Tracker[T]) WaitOrdered(events ...T) { t.t.Helper() for i, event := range events { var err error retry.UntilSuccessOrFail(t.t, func() error { t.mu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 3.6K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return nil } // ExpectError waits until an error is received and returns it func (a *DeltaAdsTest) ExpectError() error { a.t.Helper() select { case <-time.After(a.timeout): a.t.Fatalf("did not get error in time") case err := <-a.error: return err } return nil } // ExpectNoResponse waits a short period of time and ensures no response is received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/wait.go
waitCmd.PersistentFlags().IntVar(&timeoutSeconds, "timeoutSeconds", 60, "maximum number of seconds to wait for Envoy to be ready") waitCmd.PersistentFlags().IntVar(&requestTimeoutMillis, "requestTimeoutMillis", 500, "number of milliseconds to wait for response") waitCmd.PersistentFlags().IntVar(&periodMillis, "periodMillis", 500, "number of milliseconds to wait between attempts")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.5K bytes - Viewed (0) -
src/net/textproto/pipeline.go
mu sync.Mutex id uint wait map[uint]chan struct{} } // Start waits until it is time for the event numbered id to begin. // That is, except for the first event, it waits until End(id-1) has // been called. func (s *sequencer) Start(id uint) { s.mu.Lock() if s.id == id { s.mu.Unlock() return } c := make(chan struct{}) if s.wait == nil { s.wait = make(map[uint]chan struct{}) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 08 16:19:51 UTC 2020 - 3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/ExclusiveCacheAccessingWorkerTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 4.9K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order.go
previousSidecarName = ic.Name } } return to } // waitForTurn waits until it is time for the container with the specified name to begin terminating, up until // the specified grace period. If gracePeriod = 0, there is no wait. func (o *terminationOrdering) waitForTurn(name string, gracePeriod int64) float64 { // if there is no grace period, we don't wait if gracePeriod <= 0 { return 0 } start := time.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 3.8K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
} return nil } // ExpectError waits until an error is received and returns it func (a *AdsTest) ExpectError(t test.Failer) error { t.Helper() select { case <-time.After(a.timeout): t.Fatalf("did not get error in time") case err := <-a.error: return err } return nil } // ExpectNoResponse waits a short period of time and ensures no response is received
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/work/AsyncWorkTracker.java
void registerWork(BuildOperationRef operation, AsyncWorkCompletion completion); /** * Blocks waiting for the completion of all items of asynchronous work associated with the provided build operation. * Only waits for work that has been registered at the moment the method is called. In the event that there are failures in * the asynchronous work, a {@link org.gradle.internal.exceptions.MultiCauseException} will be thrown with any exceptions
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 11:22:05 UTC 2024 - 3K bytes - Viewed (0) -
test/fixedbugs/issue44370.dir/a.go
// Copyright 2021 The Go Authors. All rights reserved. Use of this // source code is governed by a BSD-style license that can be found in // the LICENSE file. package a // A StoppableWaitGroup waits for a collection of goroutines to finish. type StoppableWaitGroup struct { // i is the internal counter which can store tolerate negative values // as opposed the golang's library WaitGroup. i *int64 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 26 02:11:50 UTC 2021 - 682 bytes - Viewed (0)