- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for serverPools (0.1 sec)
-
cmd/erasure-server-pool.go
serverPools := make(serverPoolsAvailableSpace, len(z.serverPools)) storageInfos := make([][]*DiskInfo, len(z.serverPools)) nSets := make([]int, len(z.serverPools)) g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { // Skip suspended pools or pools participating in rebalance for any new // I/O.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
} z := obj.(*erasureServerPools) er := z.serverPools[0].sets[0] erasureDisks := er.getDisks() ridx := rand.Intn(len(erasureDisks)) z.serverPools[0].erasureDisksMu.Lock() er.getDisks = func() []StorageAPI { erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk) return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.4K bytes - Viewed (0) -
cmd/test-utils_test.go
if err != nil { removeRoots(fsDirs) return nil, nil, err } // Wait up to 10 seconds for disks to come online. pools := obj.(*erasureServerPools) t := time.Now() for _, pool := range pools.serverPools { for _, sets := range pool.erasureDisks { for _, s := range sets { if !s.IsLocal() { for !s.IsOnline() { time.Sleep(100 * time.Millisecond) if time.Since(t) > 10*time.Second {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0)