- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 3,352 for Retries (0.3 sec)
-
cmd/metacache-set.go
pr.CloseWithError(err) tmp.Close() entries.o = append(entries.o, e.o...) if o.Limit > 0 && entries.len() > o.Limit { entries.truncate(o.Limit) return entries, nil } if err == nil { // We stopped within the listing, we are done for now... return entries, nil } if err != nil && !errors.Is(err, io.EOF) { switch toObjectErr(err, minioMetaBucket, o.objectPath(partN)).(type) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 22:18:44 UTC 2024 - 30.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/testing/internal/util/RetryUtil.groovy
*/ package org.gradle.testing.internal.util final class RetryUtil { private RetryUtil() {} static int retry(int retries = 3, int waitMsBetweenRetries = 0, Closure closure) { int retryCount = 0 Throwable lastException = null while (retryCount++ < retries) { try { closure.call() return retryCount } catch (Throwable e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 1.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go
func (a *poller) configuration() (runtime.Object, error) { a.once.Do(a.bootstrapping) a.lock.RLock() defer a.lock.RUnlock() retries := 1 if !a.bootstrapped { retries = a.bootstrapRetries } for count := 0; count < retries; count++ { if count > 0 { a.lock.RUnlock() time.Sleep(a.interval) a.lock.RLock() } if a.ready { return a.mergedConfiguration, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Nov 06 02:02:38 UTC 2017 - 4.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
// herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++ // after 20 retries start logging that servers are not reachable yet if retries >= 20 { logger.Info(fmt.Sprintf("Waiting for at least %d remote servers with valid configuration to be online", len(clnts)/2)) if len(offlineEndpoints) > 0 {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.5K bytes - Viewed (0) -
platforms/software/maven/src/integTest/groovy/org/gradle/api/publish/maven/MavenPublishJavaRetriesIntegTest.groovy
ExecutionResult result = run "publish", '--info' then: verifyPublications() outputContains("Waiting 1000ms before next retry, 2 retries left") outputContains("Waiting 2000ms before next retry, 1 retries left") outputContains("after 2 retries") } def expectPublication() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 4.3K bytes - Viewed (0) -
src/runtime/retry.go
for tries := 0; tries < 20; tries++ { errno := fn() if errno != _EAGAIN { return errno } usleep_no_g(uint32(tries+1) * 1000) // milliseconds } return _EAGAIN
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 10 20:44:45 UTC 2022 - 760 bytes - Viewed (0) -
security/pkg/cmd/constants.go
DefaultRootCertGracePeriodPercentile = 20 // ReadSigningCertRetryInterval specifies the time to wait between retries on reading the signing key and cert. ReadSigningCertRetryInterval = time.Second * 5 // ReadSigningCertRetryMax specifies the total max time to wait between retries on reading the signing key and cert. ReadSigningCertRetryMax = time.Second * 30
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 07 03:27:36 UTC 2020 - 1.7K bytes - Viewed (0) -
platforms/software/ivy/src/integTest/groovy/org/gradle/api/publish/ivy/IvyPublishJavaRetriesIntegTest.groovy
ExecutionResult result = run "publish", '--info' then: verifyPublications() outputContains("Waiting 1000ms before next retry, 2 retries left") outputContains("Waiting 2000ms before next retry, 1 retries left") outputContains("after 2 retries") } def expectPublication() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 14:02:46 UTC 2023 - 3.8K bytes - Viewed (0) -
pkg/test/util/retry/retry.go
func MaxAttempts(attempts int) Option { return func(cfg *config) { cfg.maxAttempts = attempts } } // RetriableFunc a function that can be retried. type RetriableFunc func() (result any, completed bool, err error) // UntilSuccess retries the given function until success, timeout, or until the passed-in function returns nil. func UntilSuccess(fn func() error, options ...Option) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 5.6K bytes - Viewed (0) -
src/cmd/go/internal/robustio/robustio_flaky.go
//go:build windows || darwin package robustio import ( "errors" "math/rand" "os" "syscall" "time" ) const arbitraryTimeout = 2000 * time.Millisecond // retry retries ephemeral errors from f up to an arbitrary timeout // to work around filesystem flakiness on Windows and Darwin. func retry(f func() (err error, mayRetry bool)) error { var ( bestErr error lowestErrno syscall.Errno
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 2.5K bytes - Viewed (0)