Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for readAllFileInfo (0.12 sec)

  1. cmd/erasure-healing_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    		if countErrs(errs, nil) != len(fileInfos) {
    			t.Fatal("Expected all xl.meta healed, but partial heal detected")
    		}
    
    		fileInfos, errs = readAllFileInfo(ctx, erasureDisks, "", minioMetaBucket, cfgFile, "", false, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/erasure-healing-common_test.go

    			if err != nil {
    				t.Fatalf("Failed to putObject %v", err)
    			}
    
    			partsMetadata, errs := readAllFileInfo(ctx, erasureDisks, "", bucket, object, "", false, true)
    			fi, err := getLatestFileInfo(ctx, partsMetadata, z.serverPools[0].sets[0].defaultParityCount, errs)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    	})
    	_, err = obj.PutObject(ctx, bucket, object1, mustGetPutObjReader(t, bytes.NewReader(data), int64(len(data)), "", ""), opts)
    	if err != nil {
    		t.Fatalf("Failed to putObject %v", err)
    	}
    
    	parts1, errs1 := readAllFileInfo(ctx, erasureDisks, "", bucket, object1, "", false, false)
    	parts1SC := globalStorageClass
    
    	// Object for test case 2 - No StorageClass defined, MetaData in PutObject requesting RRS Class
    	object2 := "object2"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  4. cmd/erasure-metadata-utils.go

    		nums[i-1] = 1 + ((start + i) % cardinality)
    	}
    	return nums
    }
    
    // Reads all `xl.meta` metadata as a FileInfo slice.
    // Returns error slice indicating the failed metadata reads.
    func readAllFileInfo(ctx context.Context, disks []StorageAPI, origbucket string, bucket, object, versionID string, readData, healing bool) ([]FileInfo, []error) {
    	metadataArray := make([]FileInfo, len(disks))
    
    	opts := ReadOptions{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  5. cmd/erasure-healing.go

    		if err != nil {
    			return result, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    
    	// Re-read when we have lock...
    	partsMetadata, errs := readAllFileInfo(ctx, storageDisks, "", bucket, object, versionID, true, true)
    	if isAllNotFound(errs) {
    		err := errFileNotFound
    		if versionID != "" {
    			err = errFileVersionNotFound
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    	storageDisks := er.getDisks()
    
    	var metaArr []FileInfo
    	var errs []error
    
    	// Read metadata associated with the object from all disks.
    	if srcOpts.VersionID != "" {
    		metaArr, errs = readAllFileInfo(ctx, storageDisks, "", srcBucket, srcObject, srcOpts.VersionID, true, false)
    	} else {
    		metaArr, errs = readAllXL(ctx, storageDisks, srcBucket, srcObject, true, false)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  7. cmd/object-api-utils_test.go

    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false)
    	for i := range parts {
    		if errs[i] == nil {
    			if parts[i].Name == objectName {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  8. cmd/post-policy_test.go

    	// Now check if we actually wrote to backend (regardless of the response
    	// returned by the server).
    	z := obj.(*erasureServerPools)
    	xl := z.serverPools[0].sets[0]
    	erasureDisks := xl.getDisks()
    	parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName+"/upload.txt", "", false, false)
    	for i := range parts {
    		if errs[i] == nil {
    			if parts[i].Name == objectName+"/upload.txt" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    		}
    	}()
    
    	uploadIDPath := er.getUploadIDDir(bucket, object, uploadID)
    
    	storageDisks := er.getDisks()
    
    	// Read metadata associated with the object from all disks.
    	partsMetadata, errs := readAllFileInfo(ctx, storageDisks, bucket, minioMetaMultipartBucket,
    		uploadIDPath, "", false, false)
    
    	readQuorum, writeQuorum, err := objectQuorumFromMeta(ctx, partsMetadata, errs, er.defaultParityCount)
    	if err != 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)
Back to top