- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for sr (0.16 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) -
cmd/storage-rest-server.go
// Windows can lock up with this optimization, so we fall back to regular copy. sr, ok := rc.(*sendFileReader) if ok { // Sendfile sends in 4MiB chunks per sendfile syscall which is more than enough // for most setups. _, err = rf.ReadFrom(sr.Reader) if !xnet.IsNetworkOrHostDown(err, true) { // do not need to log disconnected clients storageLogIf(r.Context(), err) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
cmd/bucket-replication-stats.go
return } atomic.AddInt64(&r.srStats.ReplicaSize, sz) atomic.AddInt64(&r.srStats.ReplicaCount, 1) } func (r *ReplicationStats) srUpdate(sr replStat) { dID, err := globalSiteReplicationSys.getDeplIDForEndpoint(sr.endpoint()) if err == nil { r.srStats.update(sr, dID) } } // Update updates in-memory replication statistics with new values.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
cmd/generic-handlers.go
} return } if globalDomainIPs.Intersection(set.CreateStringSet(getHostsSlice(sr)...)).IsEmpty() { r.URL.Scheme = "http" if globalIsTLS { r.URL.Scheme = "https" } r.URL.Host = getHostFromSrv(sr) // Make sure we remove any existing headers before // proxying the request to another node. for k := range w.Header() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0) -
cmd/bucket-handlers.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 16:27:27 GMT 2024 - 61.6K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true" return } // SRPeerJoin - PUT /minio/admin/v3/site-replication/join // // used internally to tell current cluster to enable SR with // the provided peer clusters and service account. func (a adminAPIHandlers) SRPeerJoin(w http.ResponseWriter, r *http.Request) { ctx := r.Context()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0) -
cmd/testdata/xl-meta-merge.zip
²1 ñAª^U¼in[Äãvh¢ C\qtO§ºdTÜRu®©£os\qlu2yTA³ì_{•mjK^kRèofÈ iTû 5è %Öu_o^²^eußY|}j ]}¢ Añ ®°» ’~tNNI¨1¯uñPInu mXéë~hãûÕB æpmŸÔ^zjHW`^ys„s\Wxiìô²u}DRWt®kñq¯kSpim»SávyW |ãNsstÜxxböÌ"dI<—7l?‘öFkZPmA_eTܪIpqrBIºUISTñ FI`ãwdV +c@ò;Ö9Fkxxgi\_†à)[x_sKrS âž_SR]ÅýòyiZp˜¤·wAºûy`¼NqËB€V\mˆrKÎpiUsñh^†w__ì ê 05ê‹az‰ tÑ÷ôÕ7jsœ¢qnªK÷4sJDmt¸[Gt©z· JªñNneåP¾~NowGsX `Aan^¼sTÜY¾—_X ‘¢µI~Xs^°¸.mqò ² ò ï@ªBz{}Õmp TßtlgZk²mx„À¬»ÆPsIT¢o}yrû(}¼ / ¢rxpZª—1‘²“2”¸ š ¨¡‚¸šŠ olH ~sM¸Iò¨SWV`¾|be¼~ñs@¨å\CnwX^SqjI. m{{ˆgqn S_mˆ...
ZIP Archive - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0) -
cmd/site-replication.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
go.sum
github.com/hashicorp/go-uuid v1.0.3/go.mod h1:6SBZvOh/SIDV7/2o3Jml5SYk/TvGqwFJ/bN7x4byOro= github.com/hashicorp/golang-lru v0.5.0/go.mod h1:/m3WP610KZHVQ1SGc6re/UDhFvYD7pJ4Ao+sR/qLZy8= github.com/hashicorp/golang-lru v1.0.2 h1:dV3g9Z/unq5DpblPpw+Oqcv4dU/1omnb4Ok8iPY6p1c= github.com/hashicorp/golang-lru v1.0.2/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 12:41:13 GMT 2024 - 84.2K bytes - Viewed (0)