Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for PoolIndex (0.3 sec)

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

    	if err != nil {
    		metricsLogIf(ctx, err)
    		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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 7.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    			if skip {
    				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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. cmd/admin-handlers.go

    	for _, d := range allDisks {
    		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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  5. cmd/endpoint.go

    		if ep.CmdLine != pool {
    			continue
    		}
    		return id
    	}
    	return -1
    }
    
    // GetLocalPoolIdx returns the pool which endpoint belongs to locally.
    // if ep is remote this code will return -1 poolIndex
    func (l EndpointServerPools) GetLocalPoolIdx(ep Endpoint) int {
    	for i, zep := range l {
    		for _, cep := range zep.Endpoints {
    			if cep.IsLocal && ep.IsLocal {
    				if reflect.DeepEqual(cep, ep) {
    					return i
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 21 11:43:18 GMT 2024
    - 34.1K bytes
    - Viewed (0)
  6. cmd/notification.go

    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    				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
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
Back to top