Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for healObject (0.06 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 Sep 07 19:28:11 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K 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 Sep 07 19:28:11 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 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 Sep 07 19:28:11 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  9. src/test/java/jcifs/internal/fscc/FileInformationTest.java

        void testFileInformationWithSpy() throws SMBProtocolDecodingException {
            // Create spy on real object
            FileEndOfFileInformation realObject = new FileEndOfFileInformation(4096L);
            FileEndOfFileInformation spy = Mockito.spy(realObject);
    
            // Call methods
            byte level = spy.getFileInformationLevel();
            int size = spy.size();
            byte[] buffer = new byte[8];
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  10. cmd/object-handlers_test.go

    	TooBigDecodedLength
    	BadSignature
    	BadMD5
    	MissingUploadID
    )
    
    // Wrapper for calling HeadObject API handler tests for both Erasure multiple disks and FS single drive setup.
    func TestAPIHeadObjectHandler(t *testing.T) {
    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testAPIHeadObjectHandler, endpoints: []string{"HeadObject"}})
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 163.1K bytes
    - Viewed (0)
Back to top