- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 41 for getTicks (0.17 sec)
-
cmd/background-newdisks-heal-ops.go
} if tracker.HealID == "" { // HealID was empty only before Feb 2023 bugLogIf(ctx, tracker.delete(ctx)) return nil } // Remove .healing.bin from all disks with similar heal-id disks, err := z.GetDisks(poolIdx, setIdx) if err != nil { return err } for _, disk := range disks { if disk == nil { continue } t, err := loadHealingTracker(ctx, disk) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:32 UTC 2024 - 14.5K bytes - Viewed (0) -
cmd/object-api-interface.go
CompleteMultipartUpload(ctx context.Context, bucket, object, uploadID string, uploadedParts []CompletePart, opts ObjectOptions) (objInfo ObjectInfo, err error) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) // return the disks belonging to pool and set. SetDriveCounts() []int // list of erasure stripe size for each pool in order. // Healing operations.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 20:27:52 UTC 2024 - 17K bytes - Viewed (0) -
cmd/object-api-utils_test.go
defer cancel() // Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] erasureDisks := xl.getDisks() parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName, "", false, false) for i := range parts { if errs[i] == nil { if parts[i].Name == objectName {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 23.4K bytes - Viewed (0) -
cmd/post-policy_test.go
defer cancel() // Now check if we actually wrote to backend (regardless of the response // returned by the server). z := obj.(*erasureServerPools) xl := z.serverPools[0].sets[0] erasureDisks := xl.getDisks() parts, errs := readAllFileInfo(ctx, erasureDisks, "", bucketName, objectName+"/upload.txt", "", false, false) for i := range parts { if errs[i] == nil { if parts[i].Name == objectName+"/upload.txt" {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 30.2K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
t.Fatalf("%s : %s", instanceType, err.Error()) } z := obj.(*erasureServerPools) er := z.serverPools[0].sets[0] erasureDisks := er.getDisks() ridx := rand.Intn(len(erasureDisks)) z.serverPools[0].erasureDisksMu.Lock() er.getDisks = func() []StorageAPI { erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk) return erasureDisks }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 77.1K bytes - Viewed (0) -
platforms/jvm/language-java/src/main/java/org/gradle/external/javadoc/StandardJavadocDocletOptions.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 43.4K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/provider-task-properties.txt
Method <org.gradle.api.tasks.javadoc.Groovydoc.getHeader()> does not have raw return type assignable to org.gradle.api.provider.Property in (Groovydoc.java:0) Method <org.gradle.api.tasks.javadoc.Groovydoc.getLinks()> does not have raw return type assignable to org.gradle.api.provider.Property in (Groovydoc.java:0)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 13:33:20 UTC 2024 - 51.8K bytes - Viewed (0) -
cmd/test-utils_test.go
return nil, nil, err } var formattedDisks []StorageAPI // Should use the object layer tests for validating cache. if z, ok := objLayer.(*erasureServerPools); ok { formattedDisks = z.serverPools[0].GetDisks(0)() } // Success. return objLayer, formattedDisks, nil } // removeRoots - Cleans up initialized directories during tests. func removeRoots(roots []string) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
cmd/admin-handlers.go
if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } } stale := r.Form.Get("stale") == "true" // list also stale locks peerLocks := globalNotificationSys.GetLocks(ctx, r) topLocks := topLockEntries(peerLocks, stale) // Marshal API response upto requested count. if len(topLocks) > count && count > 0 { topLocks = topLocks[:count] }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/xl-storage.go
objAPI := newObjectLayerFn() // object layer not initialized, return. if objAPI == nil { return cache, errServerNotInitialized } poolIdx, setIdx, _ := s.GetDiskLoc() disks, err := objAPI.GetDisks(poolIdx, setIdx) if err != nil { return cache, err } cache.Info.updates = updates dataUsageInfo, err := scanDataFolder(ctx, disks, s.drivePath, cache, func(item scannerItem) (sizeSummary, error) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (2)