- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for DiskInfo (0.23 sec)
-
cmd/erasure.go
// - Non-healing disks // - Healing disks (if inclHealing is true) func (er erasureObjects) getOnlineDisksWithHealingAndInfo(inclHealing bool) (newDisks []StorageAPI, newInfos []DiskInfo, healing int) { var wg sync.WaitGroup disks := er.getDisks() infos := make([]DiskInfo, len(disks)) r := rand.New(rand.NewSource(time.Now().UnixNano())) for _, i := range r.Perm(len(disks)) { i := i wg.Add(1) go func() { defer wg.Done()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 16K bytes - Viewed (1) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
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.IsOnline() { // make sure to check if the disk is offline, since the underlying // value is cached we should attempt to invalidate it if such calls
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
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 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
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
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
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) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 11.4K bytes - Viewed (0) -
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(&err) if opts.NoOp { if opts.Metrics {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
cmd/storage-rest-server.go
storageDiskInfoRPC = grid.NewSingleHandler[*DiskInfoOptions, *DiskInfo](grid.HandlerDiskInfo, func() *DiskInfoOptions { return &DiskInfoOptions{} }, func() *DiskInfo { return &DiskInfo{} }).WithSharedResponse().AllowCallRequestPool(true)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/object-api-utils.go
// If a disk is nil or an error is returned the result will be nil as well. func getDiskInfos(ctx context.Context, disks ...StorageAPI) []*DiskInfo { res := make([]*DiskInfo, len(disks)) opts := DiskInfoOptions{} for i, disk := range disks { if disk == nil { continue } if di, err := disk.DiskInfo(ctx, opts); err == nil { res[i] = &di } } return res }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/metrics-resource.go
latestDriveStatsMu.Unlock() globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrives) globalLocalDrivesMu.RUnlock() for _, d := range localDrives { di, err := d.DiskInfo(GlobalContext, DiskInfoOptions{}) labels := map[string]string{"drive": di.Endpoint} if err == nil { updateResourceMetrics(driveSubsystem, usedBytes, float64(di.Used), labels, false)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 23:56:12 GMT 2024 - 17.4K bytes - Viewed (0)