- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for metaErrs (0.09 sec)
-
cmd/erasure-healing-common.go
erasureDistributionReliable = false } metaErrs := make([]error, len(errs)) for i, onlineDisk := range onlineDisks { if errs[i] != nil { metaErrs[i] = errs[i] continue } if onlineDisk == OfflineDisk { metaErrs[i] = errDiskNotFound continue } meta := partsMetadata[i] corrupted := false if filterByETag {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/erasure-metadata_test.go
fi.TransitionStatus = "complete" fi.Size = 1 << 20 metaArr := make([]FileInfo, N) for i := range N { fi.Erasure.Index = i + 1 metaArr[i] = fi if i < agree { continue } metaArr[i].TransitionTier, metaArr[i].TransitionedObjName = "", "" metaArr[i].TransitionStatus = "" } return metaArr } mkParities := func(N, agreedParity, disagreedParity, agree int) []int {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:02:50 UTC 2024 - 13.5K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
}, } for idx, test := range tests { var metaArr []FileInfo for i := 0; i < 12; i++ { fi := test.fi1 if i%2 == 0 { fi = test.fi2 } metaArr = append(metaArr, fi) } parities := listObjectParities(metaArr, make([]error, len(metaArr))) parity := commonParity(parities, 5) var match int for _, fi := range metaArr { if fi.Erasure.ParityBlocks == parity { match++
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0) -
cmd/erasure-metadata.go
var candidate FileInfo var found bool for i, hash := range metaHashes { if hash == maxHash { if metaArr[i].IsValid() { if !found { candidate = metaArr[i] found = true } props := objProps{ succModTime: metaArr[i].SuccessorModTime, numVersions: metaArr[i].NumVersions, } otherPropsMap[props]++ } } } if found {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 21.3K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
func shuffleDisksAndPartsMetadataByIndex(disks []StorageAPI, metaArr []FileInfo, fi FileInfo) (shuffledDisks []StorageAPI, shuffledPartsMetadata []FileInfo) { shuffledDisks = make([]StorageAPI, len(disks)) shuffledPartsMetadata = make([]FileInfo, len(disks)) distribution := fi.Erasure.Distribution var inconsistent int for i, meta := range metaArr { if disks[i] == nil { // Assuming offline drives as inconsistent,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.7K bytes - Viewed (0) -
cmd/metacache-set.go
if retries == 1 { time.Sleep(retryDelay) } else { time.Sleep(retryDelay250) } } // Load first part metadata... // Read metadata associated with the object from all disks. fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, minioMetaBucket, o.objectPath(0), ObjectOptions{}, true) if err != nil { switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 30.7K bytes - Viewed (0) -
cmd/api-response.go
data := ListVersionsResponse{} var lastObjMetaName string var tagErr, metaErr APIErrorCode = -1, -1 for _, object := range resp.Objects { if object.Name == "" { continue } // Cache checks for the same object if metadata != nil && lastObjMetaName != object.Name { tagErr = metadata(object.Name, policy.GetObjectTaggingAction) metaErr = metadata(object.Name, policy.GetObjectAction) lastObjMetaName = object.Name
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 19:27:06 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/erasure-healing.go
} } for _, m := range metaArr { if m.IsValid() { validMeta = m break } } if !validMeta.IsValid() { // validMeta is invalid because all xl.meta is missing apparently // we should figure out if dataDirs are also missing > dataBlocks. dataBlocks := (len(metaArr) + 1) / 2 if notFoundPartsErrs > dataBlocks {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 02 17:50:41 UTC 2024 - 34.4K bytes - Viewed (0) -
cmd/erasure-multipart.go
} // checkUploadIDExists - verify if a given uploadID exists and is valid. func (er erasureObjects) checkUploadIDExists(ctx context.Context, bucket, object, uploadID string, write bool) (fi FileInfo, metArr []FileInfo, err error) { defer func() { if errors.Is(err, errFileNotFound) { err = errUploadIDNotFound } }() uploadIDPath := er.getUploadIDDir(bucket, object, uploadID)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 44.7K bytes - Viewed (0)