Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 26 for Biscardi (0.21 sec)

  1. cmd/storage-datatypes_test.go

    		MountPath: "/tmp/drive1",
    		ID:        "uuid",
    		Error:     "",
    	}
    
    	b.SetBytes(1)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		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,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  2. 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" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 10.3K bytes
    - Viewed (0)
  3. internal/s3select/select.go

    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = sync.Pool{
    	New: func() interface{} {
    		// 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 21K bytes
    - Viewed (0)
  4. cmd/erasure-object_test.go

    			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
    		}
    	}
    	if gr != nil {
    		_, err = io.Copy(io.Discard, gr)
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
    		}
    		gr.Close()
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	volumeDir, err := s.getVolDir(volume)
    	if err != nil {
    		return err
    	}
    
    	discard := true
    
    	var legacyJSON bool
    	buf, _, err := s.readAllData(ctx, volume, volumeDir, pathJoin(volumeDir, path, xlStorageFormatFile), discard)
    	if err != nil {
    		if !errors.Is(err, errFileNotFound) {
    			return err
    		}
    
    		s.RLock()
    		legacy := s.formatLegacy
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  6. 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
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 18.2K bytes
    - Viewed (0)
  7. cmd/object-api-listobjects_test.go

    				foundPrefixes = append(foundPrefixes, result.Prefixes...)
    				if !result.IsTruncated {
    					break
    				}
    				marker = result.NextMarker
    				if len(result.Objects) > 0 {
    					// Discard marker, so it cannot resume listing.
    					marker = result.Objects[len(result.Objects)-1].Name
    				}
    			}
    
    			if len(testCase.result.Objects) != len(foundObjects) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 11:07:40 GMT 2024
    - 73.1K bytes
    - Viewed (0)
  8. 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) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 06 22:26:08 GMT 2023
    - 1.3K bytes
    - Viewed (0)
  9. 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)
  10. 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")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 02 11:02:31 GMT 2024
    - 5.1K bytes
    - Viewed (0)
Back to top