- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 29 for discard (0.04 seconds)
-
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
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 26.9K bytes - Click Count (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)
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 19.4K bytes - Click Count (0) -
internal/bpool/bpool.go
// the capacity of the buffer. return } select { case bp.c <- b[:bp.w]: // 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 }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 3K bytes - Click Count (0) -
impl/maven-core/src/main/java/org/apache/maven/internal/transformation/impl/DefaultConsumerPomBuilder.java
LinkedHashMap::new)); // for each managed dep in the model: // * if there is no corresponding node in the tree, discard the managed dep // * if there's a direct dependency, apply the managed dependency to it and discard the managed dep // * else keep the managed dep managedDependencies.keySet().retainAll(nodes.keySet());Created: Sun Dec 28 03:35:09 GMT 2025 - Last Modified: Thu Nov 27 07:40:26 GMT 2025 - 21.2K bytes - Click Count (0) -
cmd/perf-tests.go
errOnce.Do(func() { retError = err.Error() }) } downloadsCancel() return } fbr := firstByteRecorder{ r: r, } n, err := xioutil.Copy(xioutil.Discard, &fbr) r.Close() if err == nil { response := time.Since(t) ttfb := time.Since(*fbr.t) // Only capture success criteria - do not // have to capture failed reads, truncated
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.8K bytes - Click Count (0) -
src/archive/tar/reader_test.go
} cnt++ if s2 == "manual" { if _, err = tr.writeTo(io.Discard); err != nil { break } } } if err != v.err { t.Errorf("test %d, NewReader(%s) with %s discard: got %v, want %v", i, s1, s2, err, v.err) } if cnt != v.cnt { t.Errorf("test %d, NewReader(%s) with %s discard: got %d headers, want %d headers", i, s1, s2, cnt, v.cnt) } } }
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Mon Dec 15 16:34:13 GMT 2025 - 47.5K bytes - Click Count (0) -
src/archive/zip/reader_test.go
if err != nil { t.Fatal(err) } for i, f := range z.File { r, err := f.Open() if err != nil { continue } if f.UncompressedSize64 < 1e6 { n, err := io.Copy(io.Discard, r) if i == 3 && err != io.ErrUnexpectedEOF { t.Errorf("File[3] error = %v; want io.ErrUnexpectedEOF", err) } if err == nil && uint64(n) != f.UncompressedSize64 {Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Fri Oct 17 20:10:27 GMT 2025 - 56.5K bytes - Click Count (0) -
cmd/streaming-signature-v4.go
cred, seedSignature, region, seedDate, errCode := calculateSeedSignature(req, trailer) if errCode != ErrNone { return nil, errCode } if trailer { // Discard anything unsigned. req.Trailer = make(http.Header) trailers := req.Header.Values(awsTrailerHeader) for _, key := range trailers { req.Trailer.Add(key, "") } } else { req.Trailer = nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 18.2K bytes - Click Count (0) -
cmd/peer-rest-server.go
for m := range re { if err := enc.Encode(m); err != nil { s.writeErrorResponse(w, errors.New("Encoding mrf failed: "+err.Error())) return } } } // DevNull - everything goes to io.Discard func (s *peerRESTServer) DevNull(w http.ResponseWriter, r *http.Request) { if !s.IsValid(w, r) { s.writeErrorResponse(w, errors.New("invalid request")) return } globalNetPerfRX.Connect()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/admin-handlers-users_test.go
r, err := client.GetObject(ctx, bucket, object, minio.GetObjectOptions{}) if err != nil { c.Fatalf("user was unable to download the object: %v", err) } defer r.Close() _, err = io.Copy(io.Discard, r) if err != nil { c.Fatalf("user was unable to download the object: %v", err) } } func (c *check) mustHeadObject(ctx context.Context, client *minio.Client, bucket, object string, tagCount int) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 50.6K bytes - Click Count (0)