Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 18 of 18 for getIndex (0.05 seconds)

  1. cmd/metrics-v3-system-drive.go

    		return nil
    	}
    
    	for _, disk := range driveMetrics.storageInfo.Disks {
    		labels := []string{
    			driveL, disk.DrivePath,
    			poolIndexL, strconv.Itoa(disk.PoolIndex),
    			setIndexL, strconv.Itoa(disk.SetIndex),
    			driveIndexL, strconv.Itoa(disk.DiskIndex),
    		}
    
    		m.setDriveBasicMetrics(disk, labels)
    		if dm, found := driveMetrics.ioStats[disk.DrivePath]; found {
    			m.setDriveIOStatMetrics(dm, labels)
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 7.8K bytes
    - Click Count (0)
  2. 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
    	BitrotScan          bool
    }
    
    // mrfState sncapsulates all the information
    // related to the global background MRF.
    type mrfState struct {
    	opCh chan PartialOperation
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  3. cmd/erasure-object.go

    					healOnce.Do(func() {
    						globalMRFState.addPartialOp(PartialOperation{
    							Bucket:     bucket,
    							Object:     object,
    							VersionID:  fi.VersionID,
    							Queued:     time.Now(),
    							SetIndex:   er.setIndex,
    							PoolIndex:  er.poolIndex,
    							BitrotScan: errors.Is(err, errFileCorrupt),
    						})
    					})
    					// Healing is triggered and we have written
    					// successfully the content to client for
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  4. cmd/admin-handlers.go

    		poolInfo, ok := poolsInfo[d.PoolIndex]
    		if !ok {
    			poolInfo = make(map[int]madmin.ErasureSetInfo)
    		}
    		erasureSet, ok := poolInfo[d.SetIndex]
    		if !ok {
    			erasureSet.ID = d.SetIndex
    			cache := dataUsageCache{}
    			if err := cache.load(ctx, z.serverPools[d.PoolIndex].sets[d.SetIndex], dataUsageCacheName); err == nil {
    				dataUsageInfo := cache.dui(dataUsageRoot, nil)
    				erasureSet.ObjectsCount = dataUsageInfo.ObjectsTotalCount
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  5. cmd/erasure-multipart.go

    	if !opts.Speedtest && len(versions) > 0 {
    		globalMRFState.addPartialOp(PartialOperation{
    			Bucket:    bucket,
    			Object:    object,
    			Queued:    time.Now(),
    			Versions:  versions,
    			SetIndex:  er.setIndex,
    			PoolIndex: er.poolIndex,
    		})
    	}
    
    	if !opts.Speedtest && len(versions) == 0 {
    		// Check if there is any offline disk and add it to the MRF list
    		for _, disk := range onlineDisks {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 47.1K bytes
    - Click Count (0)
  6. cmd/erasure-server-pool.go

    			if ok {
    				continue
    			}
    		}
    
    		if disk.PoolIndex > -1 && disk.SetIndex > -1 {
    			if disk.State == madmin.DriveStateOk {
    				si := erasureSetUpCount[disk.PoolIndex][disk.SetIndex]
    				si.online++
    				if disk.Healing {
    					si.healing++
    					drivesHealing++
    				}
    				erasureSetUpCount[disk.PoolIndex][disk.SetIndex] = si
    			}
    		}
    	}
    
    	b := z.BackendInfo()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  7. cmd/erasure-healing.go

    		opts.Error = fmt.Sprintf("unable to heal %d missing blocks on drives", b)
    	}
    
    	opts.Tags = map[string]string{
    		"healObject": auditObjectOp{
    			Name: opts.Object,
    			Pool: er.poolIndex + 1,
    			Set:  er.setIndex + 1,
    		}.String(),
    	}
    
    	auditLogInternal(ctx, opts)
    }
    
    func objectErrToDriveState(reason error) string {
    	switch {
    	case reason == nil:
    		return madmin.DriveStateOk
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  8. cmd/notification.go

    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    					SetIndex:  ep.SetIdx,
    					DiskIndex: ep.DiskIdx,
    				})
    			}
    		}
    	}
    	return offlineDisks
    }
    
    // StorageInfo returns disk information across all peers
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
Back to Top