- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 37 for Biscardi (0.42 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // If the peer sends more data than we can handle, discard it and close the connection. if (flowControlError) { source.skip(remainingByteCount) closeLater(ErrorCode.FLOW_CONTROL_ERROR) return } // Discard data received after the stream is finished. It's probably a benign race. if (finished) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
src/archive/tar/reader.go
// one or more "header files" until it finds a "normal file". format := FormatUSTAR | FormatPAX | FormatGNU for { // Discard the remainder of the file and any padding. if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil { return nil, err } if _, err := tryReadFull(tr.r, tr.blk[:tr.pad]); err != nil { return nil, err } tr.pad = 0
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
internal/bpool/bpool.go
func (bp *BytePoolCap) Put(b []byte) { if bp == nil { return } select { case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
src/archive/tar/tar_test.go
for _, v := range vectors { b.Run(v.label, func(b *testing.B) { b.ReportAllocs() for i := 0; i < b.N; i++ { // Writing to io.Discard because we want to // test purely the writer code and not bring in disk performance into this. tw := NewWriter(io.Discard) for _, file := range v.files { if err := tw.WriteHeader(file.hdr); err != nil { b.Errorf("unexpected WriteHeader error: %v", err)
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24K bytes - Viewed (0) -
cmd/metacache.go
if m == nil { return false } cache := m switch { case !cache.finished() && time.Since(cache.lastUpdate) > metacacheMaxRunningAge: // Not finished and update for metacacheMaxRunningAge, discard it. return false case cache.finished() && time.Since(cache.lastHandout) > 5*metacacheMaxClientWait: // Keep for 15 minutes after we last saw the client.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/CrawlerStatsHelper.java
buf.append('\t').append("error:").append(escapeValue(e.getLocalizedMessage()).replaceAll("\\s", " ")); log(buf); } }); } public void discard(final Object keyObj) { getCacheKey(keyObj).ifPresent(key -> { try { final StatsObject data = statsCache.getIfPresent(key); if (data != null) {
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.9K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
} // SiteReplicationDevNull - everything goes to io.Discard // [POST] /minio/admin/v3/site-replication/devnull func (a adminAPIHandlers) SiteReplicationDevNull(w http.ResponseWriter, r *http.Request) { ctx := r.Context() globalSiteNetPerfRX.Connect() defer globalSiteNetPerfRX.Disconnect() connectTime := time.Now() for { n, err := io.CopyN(xioutil.Discard, r.Body, 128*humanize.KiByte)
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) -
src/test/java/org/codelibs/fess/helper/CrawlerStatsHelperTest.java
} public void test_beginWithRecordAndDiscard() { String key = "test"; crawlerStatsHelper.begin(key); crawlerStatsHelper.record(key, "aaa"); crawlerStatsHelper.discard(key); logger.info(localLogMsg.get()); assertNull(localLogMsg.get()); crawlerStatsHelper.done(key); logger.info(localLogMsg.get()); assertNull(localLogMsg.get());
Java - Registered: Mon May 06 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6K bytes - Viewed (0) -
ci/official/utilities/setup_macos.sh
# for running smoke tests in nightly/release wheel builds. if [[ "${TFCI_MACOS_UPGRADE_PYENV_ENABLE}" == 1 ]]; then # The TFCI Mac VM image seems to have uncommitted local changes to the Pyenv # repository so we have to discard them and reset the working directory before # we can pull in the latest changes. cd /Users/kbuilder/.pyenv/ && git reset --hard HEAD && git pull && cd - fi
Shell Script - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Feb 15 15:23:28 GMT 2024 - 6.2K bytes - Viewed (0)