Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for disksInfo (0.29 sec)

  1. cmd/storage-datatypes.go

    	DiskID  string `msg:"id"`
    	Metrics bool   `msg:"m"`
    	NoOp    bool   `msg:"np"`
    }
    
    // DiskInfo is an extended type which returns current
    // disk usage per path.
    // The above means that any added/deleted fields are incompatible.
    //
    // The above means that any added/deleted fields are incompatible.
    //
    //msgp:tuple DiskInfo
    type DiskInfo struct {
    	Total      uint64
    	Free       uint64
    	Used       uint64
    	UsedInodes uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  2. cmd/xl-storage-disk-id-check.go

    		return nil
    	}
    	// not the same disk we remember, take it offline.
    	return errDiskNotFound
    }
    
    func (p *xlStorageDiskIDCheck) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    	if contextCanceled(ctx) {
    		return DiskInfo{}, ctx.Err()
    	}
    
    	si := p.updateStorageMetrics(storageMetricDiskInfo)
    	defer si(0, &err)
    
    	if opts.NoOp {
    		if opts.Metrics {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  3. cmd/background-newdisks-heal-ops.go

    func getLocalDisksToHeal() (disksToHeal Endpoints) {
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    	for _, disk := range localDrives {
    		_, err := disk.DiskInfo(context.Background(), DiskInfoOptions{})
    		if errors.Is(err, errUnformattedDisk) {
    			disksToHeal = append(disksToHeal, disk.Endpoint())
    			continue
    		}
    		if h := disk.Healing(); h != nil && !h.Finished {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. cmd/global-heal.go

    		if err := bgSeq.healBucket(objAPI, bucket, true); err != nil {
    			// Log bucket healing error if any, we shall retry again.
    			healingLogIf(ctx, err)
    		}
    	}
    
    	info, err := tracker.disk.DiskInfo(ctx, DiskInfoOptions{})
    	if err != nil {
    		return fmt.Errorf("unable to get disk information before healing it: %w", err)
    	}
    
    	var numHealers uint64
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	} else if err := s.checkODirectDiskSupport(info.FSType); err == nil {
    		s.oDirect = true
    	} else {
    		return s, err
    	}
    
    	// Initialize DiskInfo cache
    	s.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{},
    		func(ctx context.Context) (DiskInfo, error) {
    			dcinfo := DiskInfo{}
    			di, root, err := getDiskInfo(s.drivePath)
    			if err != nil {
    				return dcinfo, err
    			}
    			dcinfo.RootDisk = root
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. cmd/storage-datatypes_gen.go

    	s = 1 + 2 + msgp.ArrayHeaderSize
    	for za0001 := range z.Errs {
    		s += msgp.StringPrefixSize + len(z.Errs[za0001])
    	}
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *DiskInfo) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	if zb0001 != 18 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    	}
    
    	// Check if we should do healing at all.
    	s.shouldHeal = func() bool {
    		if skipHeal.Load() {
    			return false
    		}
    		if s.healObjectSelect == 0 {
    			return false
    		}
    		if di, _ := drive.DiskInfo(ctx, DiskInfoOptions{}); di.Healing {
    			skipHeal.Store(true)
    			return false
    		}
    		return true
    	}
    
    	// Enable healing in XL mode.
    	if globalIsErasure && !cache.Info.SkipHealing {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top