Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for HealObject (0.07 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)
    	}
    
    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/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)
  3. 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)
  4. cmd/mrf.go

    			} else {
    				if len(u.Versions) > 0 {
    					vers := len(u.Versions) / 16
    					if vers > 0 {
    						for i := 0; i < vers; i++ {
    							healObject(u.Bucket, u.Object, uuid.UUID(u.Versions[16*i:]).String(), scan)
    						}
    					}
    				} else {
    					healObject(u.Bucket, u.Object, u.VersionID, scan)
    				}
    			}
    
    			wait()
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. 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)
  6. 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
    			}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  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))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top