Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for disksInfo (0.11 sec)

  1. cmd/erasure.go

    	// reportability of offline drives on local setups.
    	if len(disksInfo) == (rootDiskCount + offlineDisks.Sum()) {
    		// Success.
    		return onlineDisks, offlineDisks
    	}
    
    	// Root disk should be considered offline
    	for i := range disksInfo {
    		ep := disksInfo[i].Endpoint
    		if disksInfo[i].RootDisk {
    			offlineDisks[ep]++
    			onlineDisks[ep]--
    		}
    	}
    
    	return onlineDisks, offlineDisks
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. cmd/data-usage_test.go

    			sizeS.totalSize = s.Size()
    			sizeS.versions++
    			return sizeS, nil
    		}
    		return
    	}
    	xls := xlStorage{drivePath: base, diskInfoCache: cachevalue.New[DiskInfo]()}
    	xls.diskInfoCache.InitOnce(time.Second, cachevalue.Opts{}, func(ctx context.Context) (DiskInfo, error) {
    		return DiskInfo{Total: 1 << 40, Free: 1 << 40}, nil
    	})
    	weSleep := func() bool { return false }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/naughty-disk_test.go

    		return info, err
    	}
    	return d.disk.NSScanner(ctx, cache, updates, scanMode, weSleep)
    }
    
    func (d *naughtyDisk) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    	if err := d.calcError(); err != nil {
    		return info, err
    	}
    	return d.disk.DiskInfo(ctx, opts)
    }
    
    func (d *naughtyDisk) MakeVolBulk(ctx context.Context, volumes ...string) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    	return *client.diskID.Load(), nil
    }
    
    func (client *storageRESTClient) SetDiskID(id string) {
    	client.diskID.Store(&id)
    }
    
    func (client *storageRESTClient) DiskInfo(ctx context.Context, opts DiskInfoOptions) (info DiskInfo, err error) {
    	if !client.IsOnlineWS() {
    		// make sure to check if the disk is offline, since the underlying
    		// value is cached we should attempt to invalidate it if such calls
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. 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)
  6. cmd/metacache-set.go

    			}
    		}
    		if max < readQuorum {
    			return 0
    		}
    		return commonCount
    	}
    
    	return filter()
    }
    
    func getQuorumDiskInfos(disks []StorageAPI, infos []DiskInfo, readQuorum int) (newDisks []StorageAPI, newInfos []DiskInfo) {
    	commonMutations := calcCommonCounter(infos, readQuorum)
    	for i, info := range infos {
    		mutations := info.Metrics.TotalDeletes + info.Metrics.TotalWrites
    		if mutations >= commonMutations {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  7. cmd/format-erasure.go

    	newFormats := make([][]*formatErasureV3, setCount)
    	for i := range refFormat.Erasure.Sets {
    		newFormats[i] = make([]*formatErasureV3, setDriveCount)
    	}
    	currentDisksInfo := make([][]DiskInfo, setCount)
    	for i := range refFormat.Erasure.Sets {
    		currentDisksInfo[i] = make([]DiskInfo, setDriveCount)
    	}
    	for i := range refFormat.Erasure.Sets {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  8. cmd/storage-rest-server.go

    	storageDiskInfoRPC         = grid.NewSingleHandler[*DiskInfoOptions, *DiskInfo](grid.HandlerDiskInfo, func() *DiskInfoOptions { return &DiskInfoOptions{} }, func() *DiskInfo { return &DiskInfo{} }).WithSharedResponse().AllowCallRequestPool(true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  9. cmd/storage-rest_test.go

    func testStorageAPIDiskInfo(t *testing.T, storage StorageAPI) {
    	testCases := []struct {
    		expectErr bool
    	}{
    		{true},
    	}
    
    	for i, testCase := range testCases {
    		_, err := storage.DiskInfo(context.Background(), DiskInfoOptions{Metrics: true})
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. 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)
Back to top