- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 637 for waits (0.07 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) -
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) -
src/sync/waitgroup.go
package sync import ( "internal/race" "sync/atomic" "unsafe" ) // A WaitGroup waits for a collection of goroutines to finish. // The main goroutine calls [WaitGroup.Add] to set the number of // goroutines to wait for. Then each of the goroutines // runs and calls [WaitGroup.Done] when finished. At the same time, // [WaitGroup.Wait] can be used to block until all goroutines have finished. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0) -
pkg/keepalive/options.go
type Options struct { // After a duration of this time if the server/client doesn't see any activity it pings the peer to see if the transport is still alive. Time time.Duration // After having pinged for keepalive check, the server waits for a duration of Timeout and if no activity is seen even after that // the connection is closed. Timeout time.Duration // MaxServerConnectionAge is a duration for the maximum amount of time a
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.9K bytes - Viewed (0)