Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 221 for pools (0.08 sec)

  1. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_test.go

    	}
    
    	var nmeta1 poolMeta
    	nmeta1.Version = poolMetaVersion
    	nmeta1.Pools = append(nmeta1.Pools, meta.Pools...)
    	for i, pool := range nmeta1.Pools {
    		if i == 0 {
    			nmeta1.Pools[i] = PoolStatus{
    				CmdLine:    pool.CmdLine,
    				ID:         i,
    				LastUpdate: UTCNow(),
    				Decommission: &PoolDecommissionInfo{
    					Complete: true,
    				},
    			}
    		}
    	}
    
    	var nmeta2 poolMeta
    	nmeta2.Version = poolMetaVersion
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  3. cmd/rebalance-admin.go

    		}
    		if !ps.Participating {
    			continue
    		}
    		// for participating pools, total bytes to be rebalanced by this pool is given by,
    		// pf_c = (f_i + x)/c_i,
    		// pf_c - percentage free space across pools, f_i - ith pool's free space, c_i - ith pool's capacity
    		// i.e. x = c_i*pfc -f_i
    		totalBytesToRebal := float64(ps.InitCapacity)*meta.PercentFreeGoal - float64(ps.InitFreeSpace)
    		elapsed := time.Since(ps.Info.StartTime)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    		p.Pools[idx].LastUpdate = UTCNow()
    		p.Pools[idx].Decommission.Complete = true
    		p.Pools[idx].Decommission.Failed = false
    		p.Pools[idx].Decommission.Canceled = false
    		return true
    	}
    	return false
    }
    
    func (p *poolMeta) DecommissionFailed(idx int) bool {
    	if p.Pools[idx].Decommission != nil && !p.Pools[idx].Decommission.Failed {
    		p.Pools[idx].LastUpdate = UTCNow()
    		p.Pools[idx].Decommission.StartTime = time.Time{}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  5. cmd/server-main_test.go

    				t.Error("expected success, got failure", err)
    			}
    			if err == nil {
    				if len(sctx.Layout.pools) != 2 {
    					t.Error("expected parsed pools to be 2, not", len(sctx.Layout.pools))
    				}
    				if sctx.Layout.pools[0].cmdline != testcase.hash {
    					t.Error("expected hash", testcase.hash, "got", sctx.Layout.pools[0].cmdline)
    				}
    			}
    		})
    	}
    }
    
    // Tests initializing new object layer.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.1K bytes
    - Viewed (0)
  6. cmd/peer-s3-client.go

    	GetPools() []int
    }
    
    type localPeerS3Client struct {
    	node  Node
    	pools []int
    }
    
    func (l *localPeerS3Client) GetHost() string {
    	return l.node.Host
    }
    
    func (l *localPeerS3Client) SetPools(p []int) {
    	l.pools = make([]int, len(p))
    	copy(l.pools, p)
    }
    
    func (l localPeerS3Client) GetPools() []int {
    	return l.pools
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  7. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  8. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalln(err)
    	}
    
    	zipFile, err := os.Create("format.json.zip")
    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  9. cmd/endpoint-ellipses.go

    	setDriveCount uint64
    }
    
    // buildDisksLayoutFromConfFile supports with and without ellipses transparently.
    func buildDisksLayoutFromConfFile(pools []poolArgs) (layout disksLayout, err error) {
    	if len(pools) == 0 {
    		return layout, errInvalidArgument
    	}
    
    	for _, list := range pools {
    		var endpointsList endpointsList
    
    		for _, arg := range list.args {
    			switch {
    			case ellipses.HasList(arg):
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.6K bytes
    - Viewed (0)
  10. docs/distributed/README.md

    > **NOTE:** **Each pool you add must have the same erasure coding parity configuration as the original pool, so the same data redundancy SLA is maintained.**
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 8.9K bytes
    - Viewed (0)
Back to top