- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getPoolIdx (0.08 sec)
-
cmd/admin-handlers-pools.go
if err != nil { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } } else { idx = globalEndpoints.GetPoolIdx(pool) if idx == -1 { // We didn't find any matching pools, invalid input writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL) return } } var pool *erasureSets
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 00:22:30 UTC 2024 - 10.9K bytes - Viewed (0) -
cmd/endpoint.go
for _, v := range nodesMap { nodes = append(nodes, v) } sort.Slice(nodes, func(i, j int) bool { return nodes[i].Host < nodes[j].Host }) return } // GetPoolIdx return pool index func (l EndpointServerPools) GetPoolIdx(pool string) int { for id, ep := range globalEndpoints { if ep.CmdLine != pool { continue } return id } return -1 }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 34.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
z.poolMeta = newMeta z.poolMetaMutex.Unlock() } pools := meta.returnResumablePools() poolIndices := make([]int, 0, len(pools)) for _, pool := range pools { idx := globalEndpoints.GetPoolIdx(pool.CmdLine) if idx == -1 { return fmt.Errorf("unexpected state present for decommission status pool(%s) not found", pool.CmdLine) } poolIndices = append(poolIndices, idx) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 42.2K bytes - Viewed (0)