Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 18 of 18 for dataAddr (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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]++
    	}
    
    	maxCnt := 0
    	for ddir, count := range dataDirsCount {
    		if maxCnt < count {
    			maxCnt = count
    			dataDir = ddir
    		}
    	}
    
    	if maxCnt >= writeQuorum {
    		return dataDir
    	}
    
    	return ""
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.7K bytes
    - Click Count (0)
  2. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 13.4K bytes
    - Click Count (0)
  3. 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
    		}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  4. 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() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  5. cmd/erasure-metadata.go

    			for _, part := range meta.Parts {
    				fmt.Fprintf(h, "part.%d", part.Number)
    				fmt.Fprintf(h, "part.%d", part.Size)
    			}
    			// Previously we checked if we had quorum on DataDir value.
    			// We have removed this check to allow reading objects with different DataDir
    			// values in a few drives (due to a rebalance-stop race bug)
    			// provided their their etags or ModTimes match.
    
    			if !meta.Deleted && meta.Size != 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 21.3K bytes
    - Click Count (0)
  6. cmd/object-api-multipart_test.go

    	}
    
    	var dataDir string
    	for _, folder := range dataDirs {
    		if strings.HasSuffix(folder, SlashSeparator) {
    			dataDir = folder
    			break
    		}
    	}
    
    	toDel := (len(erasureDisks) / 2) + 1
    	for _, disk := range erasureDisks[:toDel] {
    		disk.DeleteBulk(context.Background(), minioMetaMultipartBucket, []string{pathJoin(uploadIDPath, dataDir, "part.2")}...)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 89.4K bytes
    - Click Count (0)
  7. cmd/erasure-sets.go

    		// of the content, instead we add a reference, we disallow legacy
    		// objects to be self referenced in this manner so make sure
    		// that we actually create a new dataDir for legacy objects.
    		if dstOpts.Versioned && srcOpts.VersionID != dstOpts.VersionID && !srcInfo.Legacy {
    			srcInfo.versionOnly = true
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  8. cmd/xl-storage-disk-id-check.go

    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricRenameData, srcPath, fi.DataDir, dstVolume, dstPath)
    	if err != nil {
    		return res, err
    	}
    	defer func() {
    		if err == nil && !skipAccessChecks(dstVolume) {
    			p.storage.setWriteAttribute(p.totalWrites.Add(1))
    		}
    		done(0, &err)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Apr 25 05:41:04 GMT 2025
    - 34.5K bytes
    - Click Count (0)
Back to Top