- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 242 for diskfis (0.74 sec)
-
cmd/xl-storage-disk-id-check.go
} func (p *xlStorageDiskIDCheck) GetDiskID() (string, error) { return p.storage.GetDiskID() } func (p *xlStorageDiskIDCheck) SetDiskID(id string) { p.diskID.Store(&id) } func (p *xlStorageDiskIDCheck) checkDiskStale() error { if *p.diskID.Load() == emptyDiskID { // For empty disk-id we allow the call as the server might be // coming up and trying to read format.json or create format.json return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/admin-handlers.go
types = madmin.MetricType(t) } else { types = madmin.MetricsAll } disks := strings.Split(r.Form.Get("disks"), ",") byDisk := strings.EqualFold(r.Form.Get("by-disk"), "true") var diskMap map[string]struct{} if len(disks) > 0 && disks[0] != "" { diskMap = make(map[string]struct{}, len(disks)) for _, k := range disks { if k != "" { diskMap[k] = struct{}{} } } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
cmd/admin-heal-ops.go
func sortDisks(disks []madmin.Disk) { sort.Slice(disks, func(i, j int) bool { a, b := &disks[i], &disks[j] if a.PoolIndex != b.PoolIndex { return a.PoolIndex < b.PoolIndex } if a.SetIndex != b.SetIndex { return a.SetIndex < b.SetIndex } return a.DiskIndex < b.DiskIndex }) } // getLocalHealingDisks returns local healing disks indexed by endpoint.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 18:04:41 UTC 2024 - 25.1K bytes - Viewed (0) -
cmd/erasure-healing_test.go
copy(disks, newDisks) objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock() } getDisk := func(n int) StorageAPI { objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Lock() disk := disks[n] objLayer.(*erasureServerPools).serverPools[0].erasureDisksMu.Unlock() return disk } // Remove 4 disks. setDisks(nil, nil, nil, nil)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/data-scanner_test.go
"github.com/minio/minio/internal/bucket/versioning" ) func TestApplyNewerNoncurrentVersionsLimit(t *testing.T) { objAPI, disks, err := prepareErasure(context.Background(), 8) if err != nil { t.Fatalf("Failed to initialize object layer: %v", err) } defer removeRoots(disks) setObjectLayer(objAPI) globalBucketMetadataSys = NewBucketMetadataSys() globalBucketObjectLockSys = &BucketObjectLockSys{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 03 11:18:58 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/data-scanner.go
healObjectSelect: 0, scanMode: scanMode, weSleep: weSleep, updates: cache.Info.updates, updateCurrentPath: updatePath, disks: disks, disksQuorum: len(disks) / 2, } // Enable healing in XL mode. if globalIsErasure && !cache.Info.SkipHealing { // Do a heal check on an object once every n cycles. Must divide into healFolderInclude
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
cmd/metrics-v3-cache.go
objLayer := newObjectLayerFn() if objLayer == nil { return } storageInfo := objLayer.LocalStorageInfo(GlobalContext, true) onlineDrives, offlineDrives := getOnlineOfflineDisksStats(storageInfo.Disks) totalDrives := onlineDrives.Merge(offlineDrives) v = storageMetrics{ storageInfo: storageInfo, onlineDrives: onlineDrives.Sum(), offlineDrives: offlineDrives.Sum(),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 8.1K bytes - Viewed (0) -
cmd/endpoint.go
// LocalDisksPaths returns the disk paths of the local disks func (l EndpointServerPools) LocalDisksPaths() []string { var disks []string for _, ep := range l { for _, endpoint := range ep.Endpoints { if endpoint.IsLocal { disks = append(disks, endpoint.Path) } } } return disks } // NLocalDisksPathsPerPool returns the disk paths of the local disks per pool
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/util/util_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 05:42:38 UTC 2023 - 10.4K bytes - Viewed (0) -
cmd/erasure-encode.go
nilCount := countErrs(p.errs, nil) if nilCount >= p.writeQuorum { return nil } writeErr := reduceWriteQuorumErrs(ctx, p.errs, objectOpIgnoredErrs, p.writeQuorum) return fmt.Errorf("%w (offline-disks=%d/%d)", writeErr, countErrs(p.errs, errDiskNotFound), len(p.writers)) } // Encode reads from the reader, erasure-encodes the data and writes to the writers.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.9K bytes - Viewed (0)