- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for sr (0.18 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 8.2K bytes - Viewed (0) -
src/archive/tar/reader.go
bf := b[:min(int64(len(b)), holeStart-sr.pos)] nf, err = tryReadFull(sr.fr, bf) } else { // In a hole fragment bf := b[:min(int64(len(b)), holeEnd-sr.pos)] nf, err = tryReadFull(zeroReader{}, bf) } b = b[nf:] sr.pos += int64(nf) if sr.pos >= holeEnd && len(sr.sp) > 1 { sr.sp = sr.sp[1:] // Ensure last fragment always remains } } n = len(b0) - len(b) switch {
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) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 2.2K bytes - Viewed (0) -
src/test/java/jcifs/tests/ConcurrencyTest.java
@Test public void testExclusiveLock () throws InterruptedException, MalformedURLException, UnknownHostException { String fname = makeRandomName(); try ( SmbFile sr = getDefaultShareRoot(); SmbResource exclFile = new SmbFile(sr, fname) ) { ExclusiveLockFirst f = new ExclusiveLockFirst(exclFile); ExclusiveLockSecond s = new ExclusiveLockSecond(f, exclFile);
Java - Registered: Sun Apr 21 00:10:10 GMT 2024 - Last Modified: Sun Nov 14 17:40:50 GMT 2021 - 17.6K bytes - Viewed (0) -
src/bytes/bytes.go
for ; i < len(s) && i < len(t); i++ { sr := s[i] tr := t[i] if sr|tr >= utf8.RuneSelf { goto hasUnicode } // Easy case. if tr == sr { continue } // Make sr < tr to simplify what follows. if tr < sr { tr, sr = sr, tr } // ASCII only, sr/tr must be upper/lower case if 'A' <= sr && sr <= 'Z' && tr == sr+'a'-'A' { continue }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Feb 19 19:51:15 GMT 2024 - 33.8K bytes - Viewed (0) -
src/archive/tar/writer_test.go
{sr("a", prefixSize) + "/", "", "", false}, {sr("a", prefixSize) + "/a", sr("a", prefixSize), "a", true}, {sr("a", nameSize+1), "", "", false}, {sr("/", nameSize+1), sr("/", nameSize-1), "/", true}, {sr("a", prefixSize) + "/" + sr("b", nameSize), sr("a", prefixSize), sr("b", nameSize), true}, {sr("a", prefixSize) + "//" + sr("b", nameSize), "", "", false},
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Feb 27 16:39:23 GMT 2024 - 38.7K 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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/searchResults.jsp
<span aria-hidden="true">«</span> <span class="sr-only"><la:message key="labels.prev_page" /></span> </la:link></li> </c:if> <c:if test="${!existPrevPage}"> <li class="page-item disabled" aria-label="Previous"><a class="page-link" href="#"> <span aria-hidden="true">«</span> <span class="sr-only"><la:message key="labels.prev_page" /></span> </a></li> </c:if>
Others - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Jun 09 04:29:42 GMT 2022 - 9K bytes - Viewed (0) -
src/main/webapp/WEB-INF/orig/view/searchResults.jsp
<span aria-hidden="true">«</span> <span class="sr-only"><la:message key="labels.prev_page" /></span> </la:link></li> </c:if> <c:if test="${!existPrevPage}"> <li class="page-item disabled" aria-label="Previous"><a class="page-link" href="#"> <span aria-hidden="true">«</span> <span class="sr-only"><la:message key="labels.prev_page" /></span> </a></li> </c:if>
Others - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Jun 09 04:29:42 GMT 2022 - 9K bytes - Viewed (1) -
src/bufio/scan_test.go
// reads in Scanner.Scan. type slowReader struct { max int buf io.Reader } func (sr *slowReader) Read(p []byte) (n int, err error) { if len(p) > sr.max { p = p[0:sr.max] } return sr.buf.Read(p) } // genLine writes to buf a predictable but non-trivial line of text of length // n, including the terminal newline and an occasional carriage return.
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Sep 22 16:22:42 GMT 2023 - 14.3K bytes - Viewed (0)