Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for HealObject (0.22 sec)

  1. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// After heal the meta file should be as expected.
    	if !fileInfoPreHeal1.Equals(fileInfoPostHeal1) {
    		t.Fatal("HealObject failed")
    	}
    	if !fileInfoPreHeal1.Equals(fileInfoPostHeal2) {
    		t.Fatal("HealObject failed")
    	}
    
    	err = os.RemoveAll(path.Join(fsDirs[0], bucket, object, "xl.meta"))
    	if err != nil {
    		t.Fatal(err)
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    	if ok {
    		return bgSeq.queueHealTask(healSource{bucket: bucket}, madmin.HealItemBucket)
    	}
    	return nil
    }
    
    // healObject sends the given object/version to the background healing workers
    func healObject(bucket, object, versionID string, scan madmin.HealScanMode) error {
    	// Get background heal sequence to send elements to heal
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:22:13 GMT 2024
    - 14.2K bytes
    - Viewed (1)
  3. cmd/admin-heal-ops.go

    	if !h.settings.Recursive {
    		if h.object != "" {
    			if err := h.healObject(bucket, h.object, "", h.settings.ScanMode); err != nil {
    				return err
    			}
    		}
    
    		return nil
    	}
    
    	if err := objAPI.HealObjects(h.ctx, bucket, h.object, h.settings, h.healObject); err != nil {
    		return errFnHealFromAPIErr(h.ctx, err)
    	}
    	return nil
    }
    
    // healObject - heal the given object and record result
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  4. cmd/erasure-healing.go

    // SetHealing marks object (version) as being healed.
    // Note: this is to be used only from healObject
    func (fi *FileInfo) SetHealing() {
    	if fi.Metadata == nil {
    		fi.Metadata = make(map[string]string)
    	}
    	fi.Metadata[xMinIOHealing] = "true"
    }
    
    // Healing returns true if object is being healed (i.e fi is being passed down
    // from healObject)
    func (fi FileInfo) Healing() bool {
    	_, ok := fi.Metadata[xMinIOHealing]
    	return ok
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 08 09:26:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  5. cmd/background-heal-ops.go

    				res, err = healDiskFormat(ctx, objAPI, task.opts)
    			default:
    				if task.object == "" {
    					res, err = objAPI.HealBucket(ctx, task.bucket, task.opts)
    				} else {
    					res, err = objAPI.HealObject(ctx, task.bucket, task.object, task.versionID, task.opts)
    				}
    			}
    
    			if bgSeq != nil {
    				// We increment relevant counter based on the heal result for prometheus reporting.
    				if err != nil {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  6. cmd/mrf.go

    				healBucket(u.bucket, scan)
    			} else {
    				if u.allVersions {
    					z.serverPools[u.poolIndex].sets[u.setIndex].listAndHeal(u.bucket, u.object, u.scanMode, healObjectVersionsDisparity)
    				} else {
    					healObject(u.bucket, u.object, u.versionID, scan)
    				}
    			}
    
    			wait()
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 20 03:21:15 GMT 2024
    - 3.1K bytes
    - Viewed (0)
  7. cmd/object-api-interface.go

    	// Healing operations.
    	HealFormat(ctx context.Context, dryRun bool) (madmin.HealResultItem, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	HealObject(ctx context.Context, bucket, object, versionID string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	HealObjects(ctx context.Context, bucket, prefix string, opts madmin.HealOpts, fn HealObjectFn) error
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 16.9K bytes
    - Viewed (0)
  8. cmd/erasure-sets.go

    		}
    
    		s.erasureDisksMu.Unlock()
    	}
    
    	return res, nil
    }
    
    // HealObject - heals inconsistent object on a hashedSet based on object name.
    func (s *erasureSets) HealObject(ctx context.Context, bucket, object, versionID string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	return s.getHashedSet(object).HealObject(ctx, bucket, object, versionID, opts)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  9. cmd/erasure-object.go

    			return nil
    		}
    	}
    
    	fivs, err := entry.fileInfoVersions(bucket)
    	if err != nil {
    		healObject(bucket, entry.name, "", madmin.HealDeepScan)
    		return err
    	}
    
    	if len(fivs.Versions) <= 2 {
    		for _, version := range fivs.Versions {
    			healObject(bucket, entry.name, version.VersionID, scanMode)
    		}
    	}
    
    	return nil
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 76.3K bytes
    - Viewed (2)
  10. cmd/erasure-server-pool.go

    	}
    	for _, errs := range poolErrs {
    		for _, err := range errs {
    			if err == nil {
    				continue
    			}
    			return err
    		}
    	}
    	return nil
    }
    
    func (z *erasureServerPools) HealObject(ctx context.Context, bucket, object, versionID string, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	object = encodeDirObject(object)
    
    	errs := make([]error, len(z.serverPools))
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K bytes
    - Viewed (0)
Back to top