Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for Curr (0.23 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),
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 13.1K 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{
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 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
    					}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 33.3K bytes
    - Viewed (0)
  4. 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 {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  5. 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 {
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 19.6K bytes
    - Viewed (0)
  6. 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
    Go
    - Registered: Tue Apr 23 11:13:09 GMT 2024
    - Last Modified: Fri Mar 08 01:59:14 GMT 2024
    - 26.8K bytes
    - Viewed (0)
  7. configure.py

      """
      stderr = open(os.devnull, 'wb')
      curr_version = run_shell([clang_executable, '--version'],
                               allow_non_zero=True,
                               stderr=stderr)
    
      curr_version_split = curr_version.lower().split('clang version ')
      if len(curr_version_split) > 1:
        curr_version = curr_version_split[1].split()[0]
    
      curr_version_int = convert_version_to_int(curr_version)
    Python
    - Registered: Tue Apr 23 12:39:09 GMT 2024
    - Last Modified: Mon Apr 15 18:25:36 GMT 2024
    - 53.8K bytes
    - Viewed (0)
  8. cmd/site-replication-metrics.go

    			metric.TotalDowntime = epHealth.offlineDuration
    			metric.LastOnline = epHealth.lastOnline
    			metric.Online = epHealth.Online
    			metric.Latency = madmin.LatencyStat{
    				Curr: epHealth.latency.curr,
    				Avg:  epHealth.latency.avg,
    				Max:  epHealth.latency.peak,
    			}
    		}
    		m[dID] = metric
    	}
    	return m
    }
    
    func (srs *SRStatus) updateXferRate(sz int64, duration time.Duration) {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  9. 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)
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  10. 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;
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Apr 12 11:08:37 GMT 2023
    - 9.8K bytes
    - Viewed (0)
Back to top