Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for poolsStatus (0.09 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)
Back to top