Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 28 for dataDirs (0.12 sec)

  1. cmd/erasure-metadata-utils.go

    func reduceCommonDataDir(dataDirs []string, writeQuorum int) (dataDir string) {
    	dataDirsCount := make(map[string]int)
    	for _, ddir := range dataDirs {
    		dataDirsCount[ddir]++
    	}
    
    	max := 0
    	for ddir, count := range dataDirsCount {
    		if max < count {
    			max = count
    			dataDir = ddir
    		}
    	}
    
    	if max >= writeQuorum {
    		return dataDir
    	}
    
    	return ""
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    					versions = dversions
    				}
    				break
    			}
    		}
    		dataDir = reduceCommonDataDir(dataDirs, writeQuorum)
    	}
    
    	// We can safely allow RenameData errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure.
    	return evalDisks(disks, errs), versions, dataDir, err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  3. cmd/object-api-multipart_test.go

    	dataDirs, err := erasureDisks[0].ListDir(context.Background(), minioMetaMultipartBucket, minioMetaMultipartBucket, uploadIDPath, -1)
    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	var dataDir string
    	for _, folder := range dataDirs {
    		if strings.HasSuffix(folder, SlashSeparator) {
    			dataDir = folder
    			break
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  4. cmd/erasure-healing.go

    	notFoundMetaErrs, nonActionableMetaErrs := danglingMetaErrsCount(errs)
    
    	notFoundPartsErrs, nonActionablePartsErrs := 0, 0
    	for _, dataErrs := range dataErrsByPart {
    		if nf, na := danglingPartErrsCount(dataErrs); nf > notFoundPartsErrs {
    			notFoundPartsErrs, nonActionablePartsErrs = nf, na
    		}
    	}
    
    	for _, m := range metaArr {
    		if m.IsValid() {
    			validMeta = m
    			break
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    			return nil
    		})
    		if err != nil {
    			return err
    		}
    
    		if foundObjects && globalIsErasure {
    			// If we found an object in erasure mode, we skip subdirs (only datadirs)...
    			break
    		}
    
    		// If we have many subfolders, compact ourself.
    		shouldCompact := f.newCache.Info.Name != folder.name &&
    			len(existingFolders)+len(newFolders) >= dataScannerCompactAtFolders ||
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    		metaArr          []FileInfo
    		errs             []error
    		dataErrs         map[int][]int
    		expectedMeta     FileInfo
    		expectedDangling bool
    	}{
    		{
    			name: "FileInfoExists-case1",
    			metaArr: []FileInfo{
    				{},
    				{},
    				fi,
    				fi,
    			},
    			errs: []error{
    				errFileNotFound,
    				errDiskNotFound,
    				nil,
    				nil,
    			},
    			dataErrs:         nil,
    			expectedMeta:     fi,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common.go

    			if verifyErr != nil {
    				dataErrsByPart[p][i] = convPartErrToInt(verifyErr)
    			} else {
    				dataErrsByPart[p][i] = verifyResp.Results[p]
    			}
    		}
    	}
    
    	// Build dataErrs by disk from dataErrs by part
    	for part, disks := range dataErrsByPart {
    		for disk := range disks {
    			dataErrsByDisk[disk][part] = dataErrsByPart[part][disk]
    		}
    	}
    
    	for i, onlineDisk := range onlineDisks {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2_test.go

    	}{
    		{ // transitioned object version
    			xlmeta: xlMetaV2Object{
    				VersionID: vID,
    				DataDir:   dataDir,
    				MetaSys:   transitioned,
    			},
    			uses: false,
    		},
    		{ // to be restored (requires object version to be transitioned)
    			xlmeta: xlMetaV2Object{
    				VersionID: vID,
    				DataDir:   dataDir,
    				MetaSys:   transitioned,
    				MetaUser:  toBeRestored,
    			},
    			uses: false,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Mar 08 17:50:48 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  9. cmd/storage-datatypes.go

    }
    
    // GetDataDir returns an expected dataDir given FileInfo
    //   - deleteMarker returns "delete-marker"
    //   - returns "legacy" if FileInfo is XLV1 and DataDir is
    //     empty, returns DataDir otherwise
    //   - returns "dataDir"
    func (fi FileInfo) GetDataDir() string {
    	if fi.Deleted {
    		return "delete-marker"
    	}
    	if fi.XLV1 && fi.DataDir == "" {
    		return "legacy"
    	}
    	return fi.DataDir
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v2.go

    		if fi.Deleted {
    			err = x.addVersion(ventry)
    		}
    		if x.SharedDataDirCount(ver.ObjectV2.VersionID, ver.ObjectV2.DataDir) > 0 {
    			// Found that another version references the same dataDir
    			// we shouldn't remove it, and only remove the version instead
    			return "", nil
    		}
    		return uuid.UUID(ver.ObjectV2.DataDir).String(), err
    	}
    
    	if fi.Deleted {
    		err = x.addVersion(ventry)
    		return "", err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
Back to top