- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 271 for curr (0.04 sec)
-
cmd/bucket-replication-metrics.go
sma *SMA `json:"-"` } // Clone returns a copy of XferStats func (rx *XferStats) Clone() *XferStats { curr := rx.curr() peak := rx.Peak if curr > peak { peak = curr } return &XferStats{ Curr: curr, Avg: rx.Avg, Peak: peak, N: rx.N, measure: rx.measure, } } func newXferStats() *XferStats { return &XferStats{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
cmd/bucket-stats.go
lpeak = math.Max(math.Max(v[Large].Peak, lpeak), v[Large].Curr) speak = math.Max(math.Max(v[Small].Peak, speak), v[Small].Curr) if lpeak > 0 || speak > 0 { count++ } } if count > 0 { lrg := XferStats{ Avg: lavg / float64(count), Curr: lcurr / float64(count), Peak: lpeak, } sml := XferStats{ Avg: savg / float64(count), Curr: scurr / float64(count),
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics_gen.go
err = msgp.WrapError(err, "Curr") return } for zb0002 > 0 { zb0002-- field, err = dc.ReadMapKeyPtr() if err != nil { err = msgp.WrapError(err, "Curr") return } switch msgp.UnsafeString(field) { case "Count": z.Curr.Count, err = dc.ReadFloat64() if err != nil { err = msgp.WrapError(err, "Curr", "Count") return }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 21 17:21:35 UTC 2024 - 33.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/util.go
} return out } // returns a set of objects that are in `old` but not in `curr` // For example: // old = {a1, a2, a3} // curr = {a1, a2, a4, a5} // difference(old, curr) = {a3} func difference(old, curr map[types.NamespacedName]*config.Config) []types.NamespacedName { var out []types.NamespacedName for key := range old { if _, ok := curr[key]; !ok { out = append(out, key) } } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.9K bytes - Viewed (0) -
src/runtime/vdso_freebsd.go
for { if timekeepSharedPage.enabled == 0 { return zeroBintime } curr := atomic.Load(&timekeepSharedPage.current) // atomic_load_acq_32 th := &timehands[curr] gen := atomic.Load(&th.gen) // atomic_load_acq_32 bt = th.offset if tc, ok := th.getTimecounter(); !ok { return zeroBintime } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.4K bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/order.go
g = unordered return } } func transitionReady(g uint64, curr, init gState) bool { return g == unordered || (init.seq == noseq || init.seq == curr.seq) && init.status == curr.status } func transition(gs map[uint64]gState, g uint64, init, next gState) error { if g == unordered { return nil } curr := gs[g] if !transitionReady(g, curr, init) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 4K bytes - Viewed (0) -
cmd/metrics-v3-replication.go
m.Set(replicationMaxQueuedCount, float64(qt.Max.Count)) m.Set(replicationLastMinuteQueuedBytes, float64(qt.Curr.Bytes)) m.Set(replicationLastMinuteQueuedCount, float64(qt.Curr.Count)) qa := qs.ActiveWorkers m.Set(replicationAverageActiveWorkers, float64(qa.Avg)) m.Set(replicationCurrentActiveWorkers, float64(qa.Curr)) m.Set(replicationMaxActiveWorkers, float64(qa.Max)) if len(qs.XferStats) > 0 { tots := qs.XferStats[Total]
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
pluralGroup := strings.SplitN(name, ".", 2) list, err := c.crdLister.List(labels.Everything()) if err != nil { return err } for _, curr := range list { if curr.Spec.Group == pluralGroup[1] && curr.Name != name { c.queue.Add(curr.Name) } } return nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
func (s *Controller) serviceEntryHandler(old, curr config.Config, event model.Event) { log.Debugf("Handle event %s for service entry %s/%s", event, curr.Namespace, curr.Name) currentServiceEntry := curr.Spec.(*networking.ServiceEntry) cs := convertServices(curr) configsUpdated := sets.New[model.ConfigKey]() key := curr.NamespacedName() s.mutex.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/internal/typeparams/coretype.go
for chans := identical; chans < len(terms); chans++ { curr, ok := terms[chans].Type().Underlying().(*types.Chan) if !ok { return nil } if !types.Identical(ch.Elem(), curr.Elem()) { return nil // channel elements are not identical. } if ch.Dir() == types.SendRecv { // ch is bidirectional. We can safely always use curr's direction. ch = curr } else if curr.Dir() != types.SendRecv && ch.Dir() != curr.Dir() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 5.3K bytes - Viewed (0)