Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for healObject (0.42 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    		return err
    	}
    
    	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() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    	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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 17.5K bytes
    - Viewed (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)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37K bytes
    - Viewed (1)
  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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 80.4K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K 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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  10. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

             */
            private HeadObjectResponse getHeadObject() throws IOException {
                if (headObject == null) {
                    final HeadObjectRequest request = HeadObjectRequest.builder().bucket(bucketName).key(objectName).build();
                    try {
                        headObject = s3Client.headObject(request);
                    } catch (final S3Exception e) {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
Back to top