Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 12 for HealObject (0.13 seconds)

  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)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 48.5K bytes
    - Click Count (0)
  2. 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
    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)
  3. cmd/mrf.go

    			} else {
    				if len(u.Versions) > 0 {
    					vers := len(u.Versions) / 16
    					if vers > 0 {
    						for i := range vers {
    							healObject(u.Bucket, u.Object, uuid.UUID(u.Versions[16*i:]).String(), scan)
    						}
    					}
    				} else {
    					healObject(u.Bucket, u.Object, u.VersionID, scan)
    				}
    			}
    
    			wait()
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  4. cmd/admin-heal-ops.go

    	}
    
    	if bucketsOnly {
    		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
    func (h *healSequence) healObject(bucket, object, versionID string, scanMode madmin.HealScanMode) error {
    	if h.isQuitting() {
    		return errHealStopSignalled
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  5. 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)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  6. 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
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  7. 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 task.respCh != nil {
    				task.respCh <- healResult{result: res, err: err}
    				continue
    			}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. cmd/erasure-object.go

    	if fi.TransitionStatus == lifecycle.TransitionComplete {
    		return nil
    	}
    
    	if fi.XLV1 {
    		if _, err = er.HealObject(ctx, bucket, object, "", madmin.HealOpts{NoLock: true}); err != nil {
    			return err
    		}
    		// Fetch FileInfo again. HealObject migrates object the latest
    		// format. Among other things this changes fi.DataDir and
    		// possibly fi.Data (if data is inlined).
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  9. 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))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  10. cmd/xl-storage.go

    	// suspended or disabled on this bucket. RenameData will replace
    	// the 'null' version. We add a free-version to track its tiered
    	// content for asynchronous deletion.
    	//
    	// Note: RestoreObject and HealObject requests don't end up replacing the
    	// null version and therefore don't require the free-version to track
    	// anything
    	if fi.VersionID == "" && !fi.IsRestoreObjReq() && !fi.Healing() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 91.7K bytes
    - Click Count (0)
Back to Top