- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for PoolIndex (0.16 sec)
-
cmd/background-newdisks-heal-ops_gen.go
switch msgp.UnsafeString(field) { case "ID": z.ID, err = dc.ReadString() if err != nil { err = msgp.WrapError(err, "ID") return } case "PoolIndex": z.PoolIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "PoolIndex") return } case "SetIndex": z.SetIndex, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "SetIndex") return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Feb 28 17:05:40 GMT 2024 - 21.5K bytes - Viewed (0) -
cmd/admin-heal-ops.go
tracker.mu.RUnlock() } // Sort by zone, set and disk index 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 }) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
for _, disk := range si.Disks { // Ignore invalid. if disk.PoolIndex < 0 || len(diskStats) <= disk.PoolIndex { // https://github.com/minio/minio/issues/16500 continue } totalCap += disk.TotalSpace totalFree += disk.AvailableSpace diskStats[disk.PoolIndex].AvailableSpace += disk.AvailableSpace diskStats[disk.PoolIndex].TotalSpace += disk.TotalSpace }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/notification-summary.go
for _, disk := range diskInfo { // Ignore invalid. if disk.PoolIndex < 0 || len(s.Backend.StandardSCData) <= disk.PoolIndex { // https://github.com/minio/minio/issues/16500 continue } // Ignore parity disks if disk.DiskIndex < s.Backend.StandardSCData[disk.PoolIndex] { capacity += disk.TotalSpace } } return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 20 00:53:08 GMT 2023 - 2.2K bytes - Viewed (0) -
cmd/mrf.go
// but not written in all disks (having quorum) type partialOperation struct { bucket string object string versionID string versions []byte setIndex, poolIndex int queued time.Time scanMode madmin.HealScanMode } // mrfState sncapsulates all the information // related to the global background MRF. type mrfState struct {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 3.2K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
if h.disk.Healing() == nil { return fmt.Errorf("healingTracker: drive %q is not marked as healing", h.ID) } h.mu.Lock() if h.ID == "" || h.PoolIndex < 0 || h.SetIndex < 0 || h.DiskIndex < 0 { h.ID, _ = h.disk.GetDiskID() h.PoolIndex, h.SetIndex, h.DiskIndex = h.disk.GetDiskLoc() } h.mu.Unlock() return h.save(ctx) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.7K bytes - Viewed (0) -
cmd/erasure-object.go
globalMRFState.addPartialOp(partialOperation{ bucket: bucket, object: object, versionID: fi.VersionID, queued: time.Now(), setIndex: er.setIndex, poolIndex: er.poolIndex, scanMode: scan, }) }) // Healing is triggered and we have written // successfully the content to client for // the specific part, we should `nil` this error
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/rebalance-admin.go
TotalSpace uint64 }, len(z.serverPools)) for _, disk := range si.Disks { // Ignore invalid. if disk.PoolIndex < 0 || len(diskStats) <= disk.PoolIndex { // https://github.com/minio/minio/issues/16500 continue } diskStats[disk.PoolIndex].AvailableSpace += disk.AvailableSpace diskStats[disk.PoolIndex].TotalSpace += disk.TotalSpace } stopTime := meta.StoppedAt r = rebalanceAdminStatus{ ID: meta.ID,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 22 00:56:43 GMT 2023 - 3.8K bytes - Viewed (0) -
cmd/metrics-v3.go
// of buckets is not known until the request is made. So we keep a separate // map for bucket metrics and handle them specially. // Add the serverName and poolIndex labels to all non-cluster metrics. // // Also create metric group maps and set the cache. metricsCache := newMetricsCache() mgMap := make(map[collectorPath]*MetricsGroup)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 10.7K bytes - Viewed (0) -
cmd/global-heal.go
for _, disk := range si.Disks { setIdx := fmt.Sprintf("%d-%d", disk.PoolIndex, disk.SetIndex) indexed[setIdx] = append(indexed[setIdx], disk) } for id, disks := range indexed { ss := madmin.SetStatus{ ID: id, SetIndex: disks[0].SetIndex, PoolIndex: disks[0].PoolIndex, } for _, disk := range disks { ss.Disks = append(ss.Disks, disk) if disk.Healing {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 15K bytes - Viewed (1)