Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for dataDir (0.06 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 17.4K bytes
    - Viewed (0)
  3. cmd/erasure-metadata-utils.go

    func reduceCommonDataDir(dataDirs []string, writeQuorum int) (dataDir string) {
    	dataDirsCount := make(map[string]int)
    	for _, ddir := range dataDirs {
    		dataDirsCount[ddir]++
    	}
    
    	maxCnt := 0
    	for ddir, count := range dataDirsCount {
    		if maxCnt < count {
    			maxCnt = count
    			dataDir = ddir
    		}
    	}
    
    	if maxCnt >= writeQuorum {
    		return dataDir
    	}
    
    	return ""
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  4. cmd/erasure-healing_test.go

    	}
    
    	err = firstDisk.Delete(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(t.Context(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1_gen.go

    		case "VersionID":
    			z.VersionID, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "VersionID")
    				return
    			}
    		case "DataDir":
    			z.DataDir, err = dc.ReadString()
    			if err != nil {
    				err = msgp.WrapError(err, "DataDir")
    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Dec 15 22:50:12 UTC 2024
    - 41.4K bytes
    - Viewed (0)
  6. cmd/erasure-healing-common.go

    		meta := partsMetadata[i]
    		corrupted := false
    		if filterByETag {
    			corrupted = meta.Metadata["etag"] != latestMeta.Metadata["etag"]
    		} else {
    			corrupted = !meta.ModTime.Equal(latestMeta.ModTime) || meta.DataDir != latestMeta.DataDir
    		}
    
    		if corrupted {
    			metaErrs[i] = errFileCorrupt
    			partsMetadata[i] = FileInfo{}
    			onlineDisks[i] = nil
    			continue
    		}
    
    		if erasureDistributionReliable {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 12K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    		}
    	}
    	partsMetadata[0] = partsMetadataBackup // Revert before going to the next test
    
    	// Test 3: Not synchronized DataDir
    	erasureDisks = s.getDisks()
    	partsMetadataBackup = partsMetadata[1]
    	partsMetadata[1].DataDir = "foo-random"
    
    	errs = make([]error, len(erasureDisks))
    	_, _ = checkObjectWithAllParts(ctx, erasureDisks, partsMetadata,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  8. cmd/erasure-metadata_test.go

    		}
    	}
    }
    
    func TestFindFileInfoInQuorum(t *testing.T) {
    	getNFInfo := func(n int, quorum int, t int64, dataDir string, succModTimes []time.Time, numVersions []int) []FileInfo {
    		fi := newFileInfo("test", 8, 8)
    		fi.AddObjectPart(1, "etag", 100, 100, UTCNow(), nil, nil)
    		fi.ModTime = time.Unix(t, 0)
    		fi.DataDir = dataDir
    		fis := make([]FileInfo, n)
    		for i := range fis {
    			fis[i] = fi
    			fis[i].Erasure.Index = i + 1
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    	readQuorum := fi.ReadQuorum(er.defaultRQuorum())
    	// Read Part info for all parts
    	partPath := pathJoin(uploadIDPath, fi.DataDir) + SlashSeparator
    
    	// List parts in quorum
    	partNums, err := er.listParts(ctx, onlineDisks, partPath, readQuorum)
    	if err != nil {
    		// This means that fi.DataDir, is not yet populated so we
    		// return an empty response.
    		if errors.Is(err, errFileNotFound) {
    			return result, nil
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  10. cmd/erasure-healing.go

    	// differentiate it with dstDataDir for readability
    	// srcDataDir is the one used with newBitrotReader()
    	// to read existing content.
    	srcDataDir := latestMeta.DataDir
    	dstDataDir := latestMeta.DataDir
    	if latestMeta.XLV1 {
    		dstDataDir = migrateDataDir
    	}
    
    	var inlineBuffers []*bytes.Buffer
    	if !latestMeta.Deleted && !latestMeta.IsRemote() {
    		if latestMeta.InlineData() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
Back to top