- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AddSize (0.15 sec)
-
cmd/site-replication-metrics.go
Bytes: rt.SinceUptime.Bytes, }, ErrCounts: errCounts, } } func (rt *RTimedMetrics) addsize(size int64, err error) { // failures seen since uptime atomic.AddInt64(&rt.SinceUptime.Bytes, size) atomic.AddInt64(&rt.SinceUptime.Count, 1) rt.LastMinute.addsize(size) rt.LastHour.addsize(size) if err != nil && minio.ToErrorResponse(err).Code == "AccessDenied" { if rt.ErrCounts == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-stats.go
bs.ReplicatedSize > 0 || bs.ReplicaSize > 0 } func (bs *BucketReplicationStat) updateXferRate(sz int64, duration time.Duration) { if sz > minLargeObjSize { bs.XferRateLrg.addSize(sz, duration) } else { bs.XferRateSml.addSize(sz, duration) } } // RMetricName - name of replication metric type RMetricName string const ( // Large - objects larger than 128MiB Large RMetricName = "Large"
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/data-scanner-metric.go
startTime := time.Now() return func(sz int) { duration := time.Since(startTime) atomic.AddUint64(&p.operations[s], 1) if s < scannerMetricLastRealtime { p.latency[s].addSize(duration, int64(sz)) } } } // incTime will increment time on metric s with a specific duration. // Use for s < scannerMetricLastRealtime func (p *scannerMetrics) incTime(s scannerMetric, d time.Duration) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
mu sync.Mutex init sync.Once lastMinuteLatency } func (e *lockedLastMinuteLatency) add(value time.Duration) { e.addSize(value, 0) } // addSize will add a duration and size. func (e *lockedLastMinuteLatency) addSize(value time.Duration, sz int64) { // alloc on every call, so we have a clean entry to swap in. t := time.Now().Unix() e.init.Do(func() { e.cached.Store(&AccElem{})
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 33.4K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
b.ReplicatedCount++ if rs.TransferDuration > 0 { b.Latency.update(rs.TransferSize, rs.TransferDuration) b.updateXferRate(rs.TransferSize, rs.TransferDuration) } case rs.Failed: b.FailStats.addsize(rs.TransferSize, rs.Err) case rs.Pending: } } type replStat struct { Arn string Completed bool Pending bool Failed bool opType replication.Type // transfer size
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.4K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
func calcAvg(x, y float64, n1, n2 int64) float64 { if n1+n2 == 0 { return 0 } avg := (x*float64(n1) + y*float64(n2)) / float64(n1+n2) return avg } // Add a new transfer func (rx *XferStats) addSize(sz int64, t time.Duration) { if rx.measure == nil { rx.measure = newRateMeasurement(time.Now()) } rx.measure.incrementBytes(uint64(sz)) rx.Curr = rx.measure.getExpMovingAvgBytesPerSecond()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 06:00:45 UTC 2024 - 14.2K bytes - Viewed (0) -
src/cmd/link/internal/loader/symbolbuilder.go
} func (sb *SymbolBuilder) AddCURelativeAddrPlus(arch *sys.Arch, tgt Sym, add int64) int64 { return sb.addSymRef(tgt, add, objabi.R_ADDRCUOFF, arch.PtrSize) } func (sb *SymbolBuilder) AddSize(arch *sys.Arch, tgt Sym) int64 { return sb.addSymRef(tgt, 0, objabi.R_SIZE, arch.PtrSize) } // GenAddAddrPlusFunc returns a function to be called when capturing
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 15:25:19 UTC 2023 - 13.9K bytes - Viewed (0) -
src/cmd/link/internal/ld/elf.go
} func elfwritedynentsymsize(ctxt *Link, s *loader.SymbolBuilder, tag elf.DynTag, t loader.Sym) { if elf64 { s.AddUint64(ctxt.Arch, uint64(tag)) } else { s.AddUint32(ctxt.Arch, uint32(tag)) } s.AddSize(ctxt.Arch, t) } func elfinterp(sh *ElfShdr, startva uint64, resoff uint64, p string) int { interp = p n := len(interp) + 1 sh.Addr = startva + resoff - uint64(n) sh.Off = resoff - uint64(n)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 13:29:54 UTC 2024 - 63.6K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0)