Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for poolsStatus (0.21 sec)

  1. cmd/admin-handlers-pools.go

    		return
    	}
    
    	poolsStatus := make([]PoolStatus, len(globalEndpoints))
    	for idx := range globalEndpoints {
    		status, err := pools.Status(r.Context(), idx)
    		if err != nil {
    			writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    			return
    		}
    		poolsStatus[idx] = status
    	}
    
    	adminLogIf(r.Context(), json.NewEncoder(w).Encode(poolsStatus))
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 28 00:22:30 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-decom_gen_test.go

    	}
    }
    
    func BenchmarkMarshalMsgPoolStatus(b *testing.B) {
    	v := PoolStatus{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgPoolStatus(b *testing.B) {
    	v := PoolStatus{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-rebalance_gen.go

    			if err != nil {
    				err = msgp.WrapError(err, "PoolStats")
    				return
    			}
    			if cap(z.PoolStats) >= int(zb0002) {
    				z.PoolStats = (z.PoolStats)[:zb0002]
    			} else {
    				z.PoolStats = make([]*rebalanceStats, zb0002)
    			}
    			for za0001 := range z.PoolStats {
    				if dc.IsNil() {
    					err = dc.ReadNil()
    					if err != nil {
    						err = msgp.WrapError(err, "PoolStats", za0001)
    						return
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen.go

    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *PoolStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 04 21:02:54 UTC 2022
    - 26.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom.go

    }
    
    // Clone returns a copy of PoolStatus
    func (ps PoolStatus) Clone() PoolStatus {
    	return PoolStatus{
    		ID:           ps.ID,
    		CmdLine:      ps.CmdLine,
    		LastUpdate:   ps.LastUpdate,
    		Decommission: ps.Decommission.Clone(),
    	}
    }
    
    //go:generate msgp -file $GOFILE -unexported
    type poolMeta struct {
    	Version int          `msg:"v"`
    	Pools   []PoolStatus `msg:"pls"`
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance.go

    	r := z.rebalMeta
    	poolStats := r.PoolStats[poolIdx]
    	if poolStats.Info.Status == rebalCompleted {
    		return true
    	}
    
    	pfi := float64(poolStats.InitFreeSpace+poolStats.Bytes) / float64(poolStats.InitCapacity)
    	// Mark pool rebalance as done if within 5% from PercentFreeGoal.
    	if diff := math.Abs(pfi - r.PercentFreeGoal); diff <= 0.05 {
    		r.PoolStats[poolIdx].Info.Status = rebalCompleted
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 28.4K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-decom_test.go

    		pools[1],
    		pools[0],
    	}
    
    	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
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 01 14:38:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. cmd/rebalance-admin.go

    	}
    
    	stopTime := meta.StoppedAt
    	r = rebalanceAdminStatus{
    		ID:        meta.ID,
    		StoppedAt: meta.StoppedAt,
    		Pools:     make([]rebalancePoolStatus, len(meta.PoolStats)),
    	}
    	for i, ps := range meta.PoolStats {
    		r.Pools[i] = rebalancePoolStatus{
    			ID:     i,
    			Status: ps.Info.Status.String(),
    			Used:   float64(diskStats[i].TotalSpace-diskStats[i].AvailableSpace) / float64(diskStats[i].TotalSpace),
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Dec 22 00:56:43 UTC 2023
    - 3.8K bytes
    - Viewed (0)
Back to top