- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for sr (0.17 sec)
-
cmd/site-replication-metrics.go
} go s.trackEWMA() return &s } func (sr *SRStats) trackEWMA() { for { select { case <-sr.movingAvgTicker.C: sr.updateMovingAvg() case <-GlobalContext.Done(): return } } } func (sr *SRStats) updateMovingAvg() { sr.lock.Lock() defer sr.lock.Unlock() for _, s := range sr.M { s.XferRateLrg.measure.updateExponentialMovingAverage(time.Now())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
docs/debugging/inspect/decrypt-v2.go
return fmt.Errorf("decoding key returned: %w", err) } sr, err := estream.NewReader(r) if err != nil { return err } sr.SetPrivateKey(privKey) sr.ReturnNonDecryptable(true) // Debug corrupted streams. if false { sr.SkipEncrypted(true) return sr.DebugStream(os.Stdout) } extracted := false for { stream, err := sr.NextStream() if err != nil { if err == io.EOF {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0)