- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for serverPools (0.74 sec)
-
docs/distributed/DESIGN.md
```go func getAvailablePoolIdx(ctx context.Context) int { serverPools := z.getServerPoolsAvailableSpace(ctx) total := serverPools.TotalAvailable() // choose when we reach this many choose := rand.Uint64() % total atTotal := uint64(0) for _, pool := range serverPools { atTotal += pool.Available
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Aug 15 23:04:20 UTC 2023 - 8K bytes - Viewed (0) -
cmd/rebalance-admin.go
// Load latest rebalance status meta := &rebalanceMeta{} err = meta.load(ctx, z.serverPools[0]) if err != nil { return r, err } // Compute disk usage percentage si := z.StorageInfo(ctx, true) diskStats := make([]struct { AvailableSpace uint64 TotalSpace uint64 }, len(z.serverPools)) for _, disk := range si.Disks { // Ignore invalid.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 22 00:56:43 UTC 2023 - 3.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
meta := objLayer1.(*erasureServerPools).poolMeta pools := objLayer1.(*erasureServerPools).serverPools objLayer2, fsDirs, err := prepareErasurePools() if err != nil { t.Fatalf("Initialization of object layer failed for Erasure setup: %s", err) } defer removeRoots(fsDirs) newPools := objLayer2.(*erasureServerPools).serverPools reducedPools := pools[1:] orderChangePools := []*erasureSets{ pools[1], pools[0], }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 01 14:38:46 UTC 2024 - 4.8K bytes - Viewed (0) -
cmd/data-usage.go
cachevalue.Opts{ReturnLastGood: true, NoWait: true}, func(ctx context.Context) (map[string]uint64, error) { m := make(map[string]uint64) for _, pool := range z.serverPools { for _, er := range pool.sets { // Load bucket usage prefixes ctx, done := context.WithTimeout(ctx, 2*time.Second) ok := cache.load(ctx, er, bucket+slashSeparator+dataUsageCacheName) == nil done()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 09 00:51:34 UTC 2024 - 5.6K bytes - Viewed (0) -
cmd/erasure-metadata-utils_test.go
testShuffleDisks(t, z) } // Test shuffleDisks which returns shuffled slice of disks for their actual distribution. func testShuffleDisks(t *testing.T, z *erasureServerPools) { disks := z.serverPools[0].GetDisks(0)() distribution := []int{16, 14, 12, 10, 8, 6, 4, 2, 1, 3, 5, 7, 9, 11, 13, 15} shuffledDisks := shuffleDisks(disks, distribution) // From the "distribution" above you can notice that:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.4K bytes - Viewed (0)