- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 357 for pool (0.12 sec)
-
cmd/metacache-server-pool.go
// Use ID as the object name... o.pool = z.getAvailablePoolIdx(ctx, minioMetaBucket, o.ID, 10<<20) if o.pool < 0 { // No space or similar, don't persist the listing. o.pool = 0 o.Create = false o.ID = "" o.Transient = true return entries, errDiskFull } o.set = z.serverPools[o.pool].getHashedSetIndex(o.ID) saver := z.serverPools[o.pool].sets[o.set]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
for idx, pool := range pools { specifiedPools[pool.endpoints.CmdLine] = idx } var update bool // Check if specified pools need to be removed from decommissioned pool. for k := range specifiedPools { pi, ok := rememberedPools[k] if !ok { // we do not have the pool anymore that we previously remembered, since all // the CLI checks out we can allow updates since we are mostly adding a pool here. update = true }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/erasure-server-pool-rebalance.go
) //go:generate msgp -file $GOFILE -unexported // rebalanceStats contains per-pool rebalance statistics like number of objects, // versions and bytes rebalanced out of a pool type rebalanceStats struct { InitFreeSpace uint64 `json:"initFreeSpace" msg:"ifs"` // Pool free space at the start of rebalance InitCapacity uint64 `json:"initCapacity" msg:"ic"` // Pool capacity at the start of rebalance
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance_gen.go
Krishnan Parthasarathi <******@****.***> 1711041695 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 26.8K bytes - Viewed (0) -
cmd/admin-handlers-pools.go
return } vars := mux.Vars(r) v := vars["pool"] byID := vars["by-id"] == "true" pools := strings.Split(v, ",") poolIndices := make([]int, 0, len(pools)) for _, pool := range pools { var idx int if byID { var err error idx, err = strconv.Atoi(pool) if err != nil { // We didn't find any matching pools, invalid input
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 10.9K bytes - Viewed (0) -
internal/grid/types.go
type ArrayOf[T RoundTripper] struct { aPool sync.Pool // Arrays ePool sync.Pool // Elements } // NewArrayOf returns a new ArrayOf. // You must provide a function that returns a new instance of T. func NewArrayOf[T RoundTripper](newFn func() T) *ArrayOf[T] { return &ArrayOf[T]{ ePool: sync.Pool{New: func() any { return newFn() }}, } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
docs/metrics/v3.md
| `minio_cluster_erasure_set_online_drives_count` | `gauge` | Count of online drives in the erasure set in a pool | `pool_id,set_id` | | `minio_cluster_erasure_set_healing_drives_count` | `gauge` | Count of healing drives in the erasure set in a pool | `pool_id,set_id` |
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 28.5K bytes - Viewed (0) -
cmd/metacache-set_gen.go
case "StopDiskAtLimit": z.StopDiskAtLimit, err = dc.ReadBool() if err != nil { err = msgp.WrapError(err, "StopDiskAtLimit") return } case "pool": z.pool, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "pool") return } case "set": z.set, err = dc.ReadInt() if err != nil { err = msgp.WrapError(err, "set") return } default:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
// Running at time 75, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(75L)).isEqualTo(75L) assertThat(pool.connectionCount()).isEqualTo(2) // Running at time 149, the pool returns that nothing can be evicted until time 150. assertThat(pool.closeConnections(149L)).isEqualTo(1L) assertThat(pool.connectionCount()).isEqualTo(2)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
cmd/endpoint.go
} 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 } // GetLocalPoolIdx returns the pool which endpoint belongs to locally.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0)