Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 26 for DataDir (0.07 sec)

  1. cmd/erasure-healing-common_test.go

    		}
    	}
    	partsMetadata[0] = partsMetadataBackup // Revert before going to the next test
    
    	// Test 3: Not synchronized DataDir
    	partsMetadataBackup = partsMetadata[1]
    	partsMetadata[1].DataDir = "foo-random"
    
    	errs = make([]error, len(erasureDisks))
    	filteredDisks, _, _ = disksWithAllParts(ctx, erasureDisks, partsMetadata,
    		errs, fi, false, bucket, object, madmin.HealDeepScan)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K 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]++
    	}
    
    	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)
  4. cmd/xl-storage-format-v2_gen.go

    						err = msgp.WrapError(err, "ObjectV2")
    						return
    					}
    					switch msgp.UnsafeString(field) {
    					case "DDir":
    						err = dc.ReadExactBytes((z.ObjectV2.DataDir)[:])
    						if err != nil {
    							err = msgp.WrapError(err, "ObjectV2", "DataDir")
    							return
    						}
    					default:
    						err = dc.Skip()
    						if err != nil {
    							err = msgp.WrapError(err, "ObjectV2")
    							return
    						}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-utils.go

    	if versionID == "" {
    		versionID = nullVersionID
    	}
    
    	fi.Data = inData.find(versionID)
    	if len(fi.Data) == 0 {
    		// PR #11758 used DataDir, preserve it
    		// for users who might have used master
    		// branch
    		fi.Data = inData.find(fi.DataDir)
    	}
    	return fi, nil
    }
    
    // hashDeterministicString will return a deterministic hash for the map values.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  7. cmd/xl-storage-free-version_test.go

    		Volume:           "volume",
    		Name:             "object-name",
    		VersionID:        "00000000-0000-0000-0000-000000000001",
    		IsLatest:         true,
    		Deleted:          false,
    		TransitionStatus: "",
    		DataDir:          "bffea160-ca7f-465f-98bc-9b4f1c3ba1ef",
    		XLV1:             false,
    		ModTime:          time.Now(),
    		Size:             0,
    		Mode:             0,
    		Metadata:         nil,
    		Parts:            nil,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 02 05:11:03 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. 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)
  10. 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 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
Back to top