- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for newXferStats (0.19 sec)
-
cmd/bucket-replication-stats.go
bs, ok := r.Cache[bucket] if !ok { bs = newBucketReplicationStats() r.Cache[bucket] = bs } b, ok := bs.Stats[ri.Arn] if !ok { b = &BucketReplicationStat{ XferRateLrg: newXferStats(), XferRateSml: newXferStats(), } bs.Stats[ri.Arn] = b } switch { case rs.Completed: b.ReplicatedSize += rs.TransferSize b.ReplicatedCount++ if rs.TransferDuration > 0 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/site-replication-metrics.go
} func (sr *SRStats) update(st replStat, dID string) { sr.lock.Lock() defer sr.lock.Unlock() srs, ok := sr.M[dID] if !ok { srs = &SRStatus{ XferRateLrg: newXferStats(), XferRateSml: newXferStats(), } } srs.Endpoint = st.Endpoint srs.Secure = st.Secure switch { case st.Completed: srs.ReplicatedSize += st.TransferSize srs.ReplicatedCount++
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
cmd/bucket-stats.go
qs.ActiveWorkers = globalReplicationStats.ActiveWorkers() qs.XferStats = make(map[RMetricName]XferStats) qs.QStats = r.qCache.getSiteStats() r.RLock() defer r.RUnlock() tx := newXferStats() for _, brs := range r.Cache { for _, v := range brs.Stats { tx := tx.merge(*v.XferRateLrg) tx = tx.merge(*v.XferRateSml) } } qs.XferStats[Total] = *tx return qs }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 13.1K bytes - Viewed (0) -
cmd/bucket-replication-metrics.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0)