Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for HealObject (0.06 sec)

  1. cmd/global-heal.go

    	}
    	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
    	bgSeq, ok := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if ok {
    		return bgSeq.healObject(bucket, object, versionID, scan)
    	}
    	return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. 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)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  5. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  6. 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).
    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/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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  8. cmd/data-scanner.go

    	}
    	scanMode := madmin.HealNormalScan
    	if i.heal.bitrot {
    		scanMode = madmin.HealDeepScan
    	}
    	healOpts := madmin.HealOpts{
    		Remove:   healDeleteDangling,
    		ScanMode: scanMode,
    	}
    	res, _ := o.HealObject(ctx, i.bucket, i.objectPath(), oi.VersionID, healOpts)
    	if res.ObjectSize > 0 {
    		return res.ObjectSize
    	}
    	return 0
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  9. 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() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top