- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for addPartialOp (0.2 sec)
-
cmd/erasure-object.go
// - attempt a heal to successfully heal them for future calls. if written == partLength { if errors.Is(err, errFileNotFound) || errors.Is(err, errFileCorrupt) { healOnce.Do(func() { globalMRFState.addPartialOp(PartialOperation{ Bucket: bucket, Object: object, VersionID: fi.VersionID, Queued: time.Now(), SetIndex: er.setIndex, PoolIndex: er.poolIndex,
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 80.4K bytes - Viewed (0) -
cmd/peer-s3-client.go
// buckets only and not the quourum lost ones like this, so // explicit call for bktName, count := range bucketsMap { if count < quorum { // Queue a bucket heal task globalMRFState.addPartialOp(PartialOperation{ Bucket: bktName, Queued: time.Now(), }) } } } result := make([]BucketInfo, 0, len(resultMap)) for _, bi := range resultMap {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
cmd/erasure-multipart.go
return ObjectInfo{}, toObjectErr(err, bucket, object, uploadID) } if !opts.Speedtest && len(versions) > 0 { globalMRFState.addPartialOp(PartialOperation{ Bucket: bucket, Object: object, Queued: time.Now(), Versions: versions, SetIndex: er.setIndex, PoolIndex: er.poolIndex, }) }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Sep 07 16:13:09 UTC 2025 - 47.3K bytes - Viewed (0)