- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for Petry (0.17 sec)
-
okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt
var tlsConnectDelayNanos = 0L var tlsConnectThrowable: Throwable? = null var connectTlsNextPlan: FakePlan? = null fun createRetry(): FakePlan { check(retry == null) return FakePlan(nextPlanId++) .also { retry = it } } fun createConnectTcpNextPlan(): FakePlan { check(connectTcpNextPlan == null) return FakePlan(nextPlanId++) .also {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 6.2K bytes - Viewed (0) -
.teamcity/src/test/kotlin/ApplyDefaultConfigurationTest.kt
"GRADLE_RUNNER", "KILL_ALL_GRADLE_PROCESSES", "CLEAN_UP_GIT_UNTRACKED_FILES_AND_DIRECTORIES", "GRADLE_RETRY_RUNNER", "KILL_PROCESSES_STARTED_BY_GRADLE", "CHECK_CLEAN_M2_ANDROID_USER_HOME" ), steps.items.map(BuildStep::name) )
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 6.5K bytes - Viewed (0) -
cmd/global-heal.go
} for _, bucket := range healBuckets { _, err := objAPI.HealBucket(ctx, bucket, madmin.HealOpts{ScanMode: scanMode}) if err != nil { // Log bucket healing error if any, we shall retry again. healingLogIf(ctx, err) } } info, err := tracker.disk.DiskInfo(ctx, DiskInfoOptions{}) if err != nil { return fmt.Errorf("unable to get disk information before healing it: %w", err) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
* * We get plan0 and plan1 from the route planner. * We get plan2 as a follow-up to plan1, typically retry the same IP but different TLS. * We get plan3 as a retry of plan0, which was canceled when it lost the race. * * This test confirms that we prefer to do the TLS follow-up (plan2) before the TCP retry (plan3). * It also confirms we enforce the 250 ms delay in each race. */ @Test
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 20.9K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/PerformanceTest.kt
else -> param("env.PATH", "%env.PATH%:/opt/swift/4.2.3/usr/bin:/opt/swift/4.2.4-RELEASE-ubuntu18.04/usr/bin") } } failureConditions { // We have test-retry to handle the crash in tests javaCrash = false // We want to see the flaky tests for flakiness detection supportTestRetry = (performanceTestBuildSpec.type != PerformanceTestType.flakinessDetection)
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 5.3K bytes - Viewed (0) -
.teamcity/src/main/kotlin/configurations/GradleBuildConfigurationDefaults.kt
extraParameters: String = "", daemon: Boolean = true, maxParallelForks: String = "%maxParallelForks%", isRetry: Boolean = false, ) { val stepName: String = if (isRetry) "GRADLE_RETRY_RUNNER" else "GRADLE_RUNNER" val stepExecutionMode: ExecutionMode = if (isRetry) ExecutionMode.RUN_ONLY_ON_FAILURE else ExecutionMode.DEFAULT
Plain Text - Registered: Wed Apr 24 11:36:11 GMT 2024 - Last Modified: Wed Apr 24 08:17:56 GMT 2024 - 7.9K bytes - Viewed (0) -
cmd/server-main.go
if err == nil { return false } notInitialized := strings.Contains(err.Error(), "Server not initialized, please try again") || errors.Is(err, errServerNotInitialized) // Initializing sub-systems needs a retry mechanism for // the following reasons: // - Read quorum is lost just after the initialization // of the object layer. // - Write quorum not met when upgrading configuration
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
cmd/erasure-server-pool.go
}) if err != nil { if !configRetriableErrors(err) { logger.Fatal(err, "Unable to initialize backend") } retry := time.Duration(r.Float64() * float64(5*time.Second)) storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry)) time.Sleep(retry) attempt++ continue } break } return z, nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 80.1K bytes - Viewed (0) -
cmd/metacache-set.go
if err != nil { switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) { case ObjectNotFound, InsufficientReadQuorum: retryWait() continue } // Allow one fast retry for other errors. if retries > 0 { return entries, fmt.Errorf("reading first part metadata: %v", err) } retryWait() continue } partN, err := o.findFirstPart(fi) switch {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/erasure-object.go
oi := objInfo.Clone() oi.metadataOnly = true // Perform only metadata updates. // allow retry in the case of failure to restore delete(oi.UserDefined, xhttp.AmzRestore) if _, err := er.CopyObject(ctx, bucket, object, bucket, object, oi, ObjectOptions{ VersionID: oi.VersionID, }, ObjectOptions{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 76.9K bytes - Viewed (2)