Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Curr (0.02 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 11:39:51 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    }
    
    type latencyStat struct {
    	lastmin lastMinuteLatency
    	curr    time.Duration
    	avg     time.Duration
    	peak    time.Duration
    	N       int64
    }
    
    func (l *latencyStat) update(d time.Duration) {
    	l.lastmin.add(d)
    	l.N++
    	if d > l.peak {
    		l.peak = d
    	}
    	l.curr = l.lastmin.getTotal().avg()
    	l.avg = time.Duration((int64(l.avg)*(l.N-1) + int64(l.curr)) / l.N)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  6. src/archive/tar/writer.go

    	/*
    		// Write the sparse map and setup the sparse writer if necessary.
    		if len(spd) > 0 {
    			// Use tw.curr since the sparse map is accounted for in hdr.Size.
    			if _, err := tw.curr.Write(spb); err != nil {
    				return err
    			}
    			tw.curr = &sparseFileWriter{tw.curr, spd, 0}
    		}
    	*/
    	return nil
    }
    
    func (tw *Writer) writeGNUHeader(hdr *Header) error {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 14:22:59 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
        prev.set("done");
        assertTrue(orig.isDone());
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 47.1K bytes
    - Viewed (0)
  8. okhttp-idna-mapping-table/src/main/kotlin/okhttp3/internal/idn/MappingTables.kt

      var i = 0
      while (i < ranges.size) {
        val curr = ranges[i]
        if (curr is MappedRange.InlineDelta) {
          val j = i + 1
          mergeAdjacent@ while (j < ranges.size) {
            val next = ranges[j]
            if (next is MappedRange.InlineDelta &&
              curr.codepointDelta == next.codepointDelta
            ) {
              ranges.removeAt(j)
            } else {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  9. src/archive/tar/reader.go

    	if isHeaderOnlyType(hdr.Typeflag) {
    		nb = 0
    	}
    	if nb < 0 {
    		return ErrHeader
    	}
    
    	tr.pad = blockPadding(nb)
    	tr.curr = &regFileReader{r: tr.r, nb: nb}
    	return nil
    }
    
    // handleSparseFile checks if the current file is a sparse format of any type
    // and sets the curr reader appropriately.
    func (tr *Reader) handleSparseFile(hdr *Header, rawHdr *block) error {
    	var spd sparseDatas
    	var err error
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Mar 08 01:59:14 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  10. impl/maven-core/src/main/java/org/apache/maven/internal/aether/ReverseTreeRepositoryListener.java

                            .listIterator(collectStepTrace.getPath().size());
                    while (iter.hasPrevious()) {
                        DependencyNode curr = iter.previous();
                        indent += "  ";
                        trackingData.add(indent + curr + " (" + collectStepTrace.getContext() + ")");
                    }
                }
            }
    
            if (trackingFile == null) {
                return;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 9.8K bytes
    - Viewed (0)
Back to top