Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 52 for discard (0.04 seconds)

  1. internal/ioutil/discard.go

    import (
    	"io"
    )
    
    // Discard is just like io.Discard without the io.ReaderFrom compatible
    // implementation which is buggy on NUMA systems, we have to use a simpler
    // io.Writer implementation alone avoids also unnecessary buffer copies,
    // and as such incurred latencies.
    var Discard io.Writer = discard{}
    
    // discard is /dev/null for Golang.
    type discard struct{}
    
    func (discard) Write(p []byte) (int, error) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 1.3K bytes
    - Click Count (0)
  2. src/bufio/bufio_test.go

    				continue
    			}
    		}
    		discarded, err := br.Discard(tt.n)
    		if ge, we := fmt.Sprint(err), fmt.Sprint(tt.wantErr); discarded != tt.want || ge != we {
    			t.Errorf("%s: Discard(%d) = (%v, %v); want (%v, %v)", tt.name, tt.n, discarded, ge, tt.want, we)
    			continue
    		}
    		if bn := br.Buffered(); bn != tt.wantBuffered {
    			t.Errorf("%s: after Discard, Buffered = %d; want %d", tt.name, bn, tt.wantBuffered)
    		}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 01:08:54 GMT 2025
    - 51.6K bytes
    - Click Count (0)
  3. src/bufio/bufio.go

    		}
    	}
    	return b.buf[b.r : b.r+n], err
    }
    
    // Discard skips the next n bytes, returning the number of bytes discarded.
    //
    // If Discard skips fewer than n bytes, it also returns an error.
    // If 0 <= n <= b.Buffered(), Discard is guaranteed to succeed without
    // reading from the underlying io.Reader.
    func (b *Reader) Discard(n int) (discarded int, err error) {
    	if n < 0 {
    		return 0, ErrNegativeCount
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Sep 03 14:04:47 GMT 2025
    - 22K bytes
    - Click Count (0)
  4. cmd/storage-datatypes_test.go

    		Endpoint:  "http://localhost:9001/tmp/drive1",
    		MountPath: "/tmp/drive1",
    		ID:        "uuid",
    		Error:     "",
    	}
    
    	b.SetBytes(1)
    	b.ReportAllocs()
    
    	for b.Loop() {
    		err := msgp.Encode(io.Discard, &v)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkEncodeDiskInfoGOB(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    		Used:      1000,
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  5. internal/ioutil/ioutil_test.go

    	}
    }
    
    func TestCloseOnWriter(t *testing.T) {
    	writer := WriteOnClose(io.Discard)
    	if writer.HasWritten() {
    		t.Error("WriteOnCloser must not be marked as HasWritten")
    	}
    	writer.Write(nil)
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    
    	writer = WriteOnClose(io.Discard)
    	writer.Close()
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  6. 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)
  7. internal/hash/reader_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = io.Copy(io.Discard, r)
    	if err != nil {
    		t.Fatal(err)
    	}
    	md5sum := r.MD5Current()
    	if hex.EncodeToString(md5sum) != "e2fc714c4727ee9395f324cd2e7f331f" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  8. 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)
  9. internal/s3select/select.go

    	},
    }
    
    var bufioWriterPool = bpool.Pool[*bufio.Writer]{
    	New: func() *bufio.Writer {
    		// io.Discard is just used to create the writer. Actual destination
    		// writer is set later by Reset() before using it.
    		return bufio.NewWriter(xioutil.Discard)
    	},
    }
    
    // UnmarshalXML - decodes XML data.
    func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  10. cmd/metacache-entries.go

    					if other.isDir() {
    						if serverDebugLog {
    							console.Debugln("mergeEntryChannels: discarding directory", other.name, "for object", best.name)
    						}
    						// Discard the directory.
    						if err := selectFrom(otherIdx); err != nil {
    							return err
    						}
    						continue
    					}
    					// Replace directory with object.
    					if serverDebugLog {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 24.1K bytes
    - Click Count (0)
Back to Top