- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 30 for ExponentialBackOff (0.28 sec)
-
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java
private final int timeoutMs; private CountdownTimer timer; public static ExponentialBackoff<Signal> of(int amount, TimeUnit unit) { return of(amount, unit, Signal.SLEEP); } public static <T extends Signal> ExponentialBackoff<T> of(int amount, TimeUnit unit, T signal) { return new ExponentialBackoff<T>((int) TimeUnit.MILLISECONDS.convert(amount, unit), signal, SLOT_TIME); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 4.8K bytes - Viewed (0) -
pkg/util/goroutinemap/exponentialbackoff/exponential_backoff.go
See the License for the specific language governing permissions and limitations under the License. */ // Package exponentialbackoff contains logic for implementing exponential // backoff for GoRoutineMap and NestedPendingOperations. package exponentialbackoff import ( "fmt" "time" ) const ( // initialDurationBeforeRetry is the amount of time after an error occurs
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 19 03:30:46 UTC 2022 - 4.2K bytes - Viewed (0) -
pkg/backoff/exponential.go
} type Option struct { InitialInterval time.Duration MaxInterval time.Duration } // ExponentialBackOff is a wrapper of backoff.ExponentialBackOff to override its NextBackOff(). type ExponentialBackOff struct { exponentialBackOff *backoff.ExponentialBackOff } // Default values for ExponentialBackOff. const ( defaultInitialInterval = 500 * time.Millisecond defaultMaxInterval = 60 * time.Second )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 25 01:53:48 UTC 2023 - 3.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
return ExponentialBackoff.Result.successful(lockOutcome); } else { return ExponentialBackoff.Result.notSuccessful(lockOutcome); } }); } } private ExponentialBackoff<AwaitableFileLockReleasedSignal> newExponentialBackoff(int shortTimeoutMs) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0) -
platforms/software/security/src/main/java/org/gradle/security/internal/PublicKeyDownloadService.java
try { ExponentialBackoff<ExponentialBackoff.Signal> backoff = ExponentialBackoff.of(5, TimeUnit.SECONDS, 50, TimeUnit.MILLISECONDS); backoff.retryUntil(() -> { URI baseUri = serversLeft.poll(); if (baseUri == null) { // no more servers left despite retries return ExponentialBackoff.Result.successful(false); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/software/resources-gcs/src/main/java/org/gradle/internal/resource/transport/gcp/gcs/RetryHttpInitializerWrapper.java
import com.google.api.client.http.HttpResponse; import com.google.api.client.http.HttpTransport; import com.google.api.client.http.HttpUnsuccessfulResponseHandler; import com.google.api.client.util.ExponentialBackOff; import com.google.api.client.util.Sleeper; import com.google.common.base.Preconditions; import com.google.common.base.Supplier; import org.gradle.api.logging.Logger; import org.gradle.api.logging.Logging;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.6K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/reconciler/reconciler.go
err := rc.operationExecutor.UnregisterPlugin(registeredPlugin, rc.actualStateOfWorld) if err != nil && !goroutinemap.IsAlreadyExists(err) && !exponentialbackoff.IsExponentialBackoff(err) { // Ignore goroutinemap.IsAlreadyExists and exponentialbackoff.IsExponentialBackoff errors, they are expected. // Log all other errors. klog.ErrorS(err, "OperationExecutor.UnregisterPlugin failed", "plugin", registeredPlugin) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 6.2K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
lock sync.RWMutex } type operation struct { key operationKey operationName string operationPending bool expBackoff exponentialbackoff.ExponentialBackoff } func (grm *nestedPendingOperations) Run( volumeName v1.UniqueVolumeName, podName volumetypes.UniquePodName, nodeName types.NodeName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap.go
cond *sync.Cond lock sync.RWMutex } // operation holds the state of a single goroutine. type operation struct { operationPending bool expBackoff exponentialbackoff.ExponentialBackoff } func (grm *goRoutineMap) Run( operationName string, operationFunc func() error) error { grm.lock.Lock() defer grm.lock.Unlock() existingOp, exists := grm.operations[operationName]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 6.8K bytes - Viewed (0) -
pkg/backoff/exponential_test.go
testMaxInterval = 5 * time.Second ) o := DefaultOption() o.InitialInterval = testInitialInterval o.MaxInterval = testMaxInterval exp := NewExponentialBackOff(o) exp.(ExponentialBackOff).exponentialBackOff.Multiplier = 2 expectedResults := []time.Duration{500, 1000, 2000, 4000, 5000, 5000, 5000, 5000, 5000, 5000} for i, d := range expectedResults { expectedResults[i] = d * time.Millisecond }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 05 16:03:30 UTC 2022 - 2.6K bytes - Viewed (0)