- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 65 for attempt (0.14 sec)
-
cmd/erasure-object.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/rest/client.go
// Protect against integer overflow panic("unit cannot exceed one hour") } return func(attempt uint) time.Duration { if attempt > 16 { // Protect against integer overflow attempt = 16 } // sleep = random_between(unit, min(cap, base * 2 ** attempt)) sleep := unit * time.Duration(1<<attempt) if sleep > cap { sleep = cap } sleep -= time.Duration(r.Float64() * float64(sleep-unit))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/server_test.go
response, err = s.client.Do(request) c.Assert(err, nil) // Assert the response status code. c.Assert(response.StatusCode, http.StatusNoContent) } // TestDeleteBucketNotEmpty - Validates the operation during an attempt to delete a non-empty bucket. func (s *TestSuiteCommon) TestDeleteBucketNotEmpty(c *check) { // generate a random bucket name. bucketName := getRandomBucketName() // HTTP request to create the bucket.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/erasure-server-pool.go
}) // initialize the object layer. defer setObjectLayer(z) r := rand.New(rand.NewSource(time.Now().UnixNano())) attempt := 1 for { var err error bootstrapTrace(fmt.Sprintf("poolMeta.Init: loading pool metadata, attempt: %d", attempt), func() { err = z.Init(ctx) // Initializes all pools. }) if err != nil { if !configRetriableErrors(err) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/api-errors.go
}, ErrCastFailed: { Code: "CastFailed", Description: "Attempt to convert from one data type to another using CAST failed in the SQL expression.", HTTPStatusCode: http.StatusBadRequest, }, ErrInvalidCast: { Code: "InvalidCast", Description: "Attempt to convert from one data type to another using CAST failed in the SQL expression.",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 91.4K bytes - Viewed (7) -
cmd/speedtest.go
errStr = fmt.Sprintf("no results for downloads upon first attempt, concurrency %d and duration %s", opts.concurrencyStart, opts.duration) } // if the default concurrency yields zero results, throw an error. if throughputHighestResults[i].Uploads == 0 && opts.concurrencyStart == concurrency { errStr = fmt.Sprintf("no results for uploads upon first attempt, concurrency %d and duration %s", opts.concurrencyStart, opts.duration)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 9K bytes - Viewed (0) -
cmd/os-reliable.go
if err = reliableMkdirAll(path.Dir(dstFilePath), 0o777, baseDir); err != nil { return err } i := 0 for { // After a successful parent directory create attempt a renameAll. if err = Rename(srcFilePath, dstFilePath); err != nil { // Retry only for the first retryable error. if osIsNotExist(err) && i == 0 { i++ continue } } break }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/storage-rest-client.go
if !client.IsOnline() { // make sure to check if the disk is offline, since the underlying // value is cached we should attempt to invalidate it if such calls // were attempted. This can lead to false success under certain conditions // - this change attempts to avoid stale information if the underlying // transport is already down. return "", errDiskNotFound }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/logger/logrotate.go
return err } // close everything before we delete. if err = gw.Close(); err != nil { return err } if err = r.Close(); err != nil { return err } // Attempt to remove after all fd's are closed. return os.Remove(oldLgFile) } func (w *Writer) rotate() error { if w.f != nil { if err := w.closeCurrentFile(); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/erasure-sets_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() nDisks := 16 // Maximum disks. var erasureDisks []string for i := 0; i < nDisks; i++ { // Do not attempt to create this path, the test validates // so that newErasureSets initializes non existing paths // and successfully returns initialized object layer. disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:21:56 GMT 2024 - 6.9K bytes - Viewed (0)