- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 28 for ExponentialBackOff (0.31 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/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) -
pkg/kubelet/volumemanager/reconciler/reconciler_common.go
} } } } } } // ignore nestedpendingoperations.IsAlreadyExists and exponentialbackoff.IsExponentialBackoff errors, they are expected. func isExpectedError(err error) bool { return nestedpendingoperations.IsAlreadyExists(err) || exponentialbackoff.IsExponentialBackoff(err) || operationexecutor.IsMountFailedPreconditionError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:23:12 UTC 2024 - 14.8K bytes - Viewed (0)