- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for healObject (0.22 sec)
-
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) -
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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 04 13:49:12 UTC 2025 - 16.2K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
cmd/bucket-replication-metrics.go
const ( putObjectTaggingAPI replProxyAPI = "PutObjectTagging" getObjectTaggingAPI replProxyAPI = "GetObjectTagging" removeObjectTaggingAPI replProxyAPI = "RemoveObjectTagging" headObjectAPI replProxyAPI = "HeadObject" getObjectAPI replProxyAPI = "GetObject" ) // ProxyMetric holds stats for replication proxying type ProxyMetric struct { PutTagTotal uint64 `json:"putTaggingProxyTotal" msg:"ptc"`
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/api-router.go
t := router.Methods(r.methods...). HandlerFunc(collectAPIStats(r.api, httpTraceAll(notImplementedHandler))). Queries(r.queries...) t.Path(r.path) } // Object operations // HeadObject router.Methods(http.MethodHead).Path("/{object:.+}"). HandlerFunc(s3APIMiddleware(api.HeadObjectHandler)) // GetObjectAttributes router.Methods(http.MethodGet).Path("/{object:.+}").
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed May 07 15:37:12 UTC 2025 - 23.3K bytes - Viewed (0)