Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 979 for pool (0.02 sec)

  1. cmd/erasure-server-pool.go

    func (z *erasureServerPools) poolsWithObject(pools []PoolObjInfo, opts ObjectOptions) (errs []poolErrs) {
    	for _, pool := range pools {
    		if opts.SkipDecommissioned && z.IsSuspended(pool.Index) {
    			continue
    		}
    		// Skip object if it's from pools participating in a rebalance operation.
    		if opts.SkipRebalancing && z.IsPoolRebalancing(pool.Index) {
    			continue
    		}
    		if isErrReadQuorum(pool.Err) || pool.Err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_test.go

    	for i, pool := range nmeta2.Pools {
    		if i == 0 {
    			nmeta2.Pools[i] = PoolStatus{
    				CmdLine:    pool.CmdLine,
    				ID:         i,
    				LastUpdate: UTCNow(),
    				Decommission: &PoolDecommissionInfo{
    					Complete: false,
    				},
    			}
    		}
    	}
    
    	testCases := []struct {
    		meta           poolMeta
    		pools          []*erasureSets
    		expectedUpdate bool
    		expectedErr    bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 01 14:38:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. 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]
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. 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
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. 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
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance_gen.go

    Krishnan Parthasarathi <******@****.***> 1711041695 -0700
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. internal/bpool/bpool.go

    		// someone tried to put back buffer which is not part of this buffer pool
    		// we simply don't put this back into pool, a modified buffer provided
    		// by this package is no more usable, callers make sure to not modify
    		// the capacity of the buffer.
    		return
    	}
    
    	select {
    	case bp.c <- b[:bp.w]:
    		// buffer went back into pool
    	default:
    		// buffer didn't go back into pool, just discard
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 3K bytes
    - Viewed (0)
  8. 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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  9. 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)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  10. docs/distributed/CONFIG.md

    `v1` format
    ```yaml
    pools: # Specify the nodes and drives with pools
      -
        - "https://server-example-pool1:9000/mnt/disk{1...4}/"
        - "https://server{1...2}-pool1:9000/mnt/disk{1...4}/"
        - "https://server3-pool1:9000/mnt/disk{1...4}/"
        - "https://server4-pool1:9000/mnt/disk{1...4}/"
    ```
    
    to `v2` format
    
    ```yaml
    pools:
      - args:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 25 02:30:18 UTC 2024
    - 4.2K bytes
    - Viewed (0)
Back to top