Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 620 for uint24 (0.09 sec)

  1. internal/s3select/genmessage.go

    	headerLength := len(header)
    	payloadLength := 0
    	totalLength := totalByteLength(headerLength, payloadLength)
    
    	buf = new(bytes.Buffer)
    	binary.Write(buf, binary.BigEndian, uint32(totalLength))
    	binary.Write(buf, binary.BigEndian, uint32(headerLength))
    	prelude := buf.Bytes()
    	binary.Write(buf, binary.BigEndian, crc32.ChecksumIEEE(prelude))
    	buf.Write(header)
    	message := buf.Bytes()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  2. internal/ioutil/ioutil.go

    type LimitWriter struct {
    	io.Writer
    	skipBytes int64
    	wLimit    int64
    }
    
    // Write implements the io.Writer interface limiting upto
    // configured length, also skips the first N bytes.
    func (w *LimitWriter) Write(p []byte) (n int, err error) {
    	n = len(p)
    	var n1 int
    	if w.skipBytes > 0 {
    		if w.skipBytes >= int64(len(p)) {
    			w.skipBytes -= int64(len(p))
    			return n, nil
    		}
    		p = p[w.skipBytes:]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  3. cmd/dynamic-timeouts.go

    )
    
    // timeouts that are dynamically adapted based on actual usage results
    type dynamicTimeout struct {
    	timeout       int64
    	minimum       int64
    	entries       int64
    	log           [dynamicTimeoutLogSize]time.Duration
    	mutex         sync.Mutex
    	retryInterval time.Duration
    }
    
    type dynamicTimeoutOpts struct {
    	timeout       time.Duration
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 19 23:21:05 UTC 2022
    - 4.5K bytes
    - Viewed (0)
  4. cmd/metacache_gen_test.go

    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    func BenchmarkUnmarshalmetacache(b *testing.B) {
    	v := metacache{}
    	bts, _ := v.MarshalMsg(nil)
    	b.ReportAllocs()
    	b.SetBytes(int64(len(bts)))
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		_, err := v.UnmarshalMsg(bts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  5. cmd/object-api-multipart_test.go

    		{bucketNames[0], objectNames[0], uploadIDs[0], 4, "mnop", "e132e96a5ddad6da8b07bba6f6131fef", int64(len("abcd"))},
    		// Part with size larger than 5Mb.
    		{bucketNames[0], objectNames[0], uploadIDs[0], 5, string(validPart), validPartMD5, int64(len(validPart))},
    		{bucketNames[0], objectNames[0], uploadIDs[0], 6, string(validPart), validPartMD5, int64(len(validPart))},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  6. internal/event/targetlist.go

    type Stats struct {
    	TotalEvents        int64 // Deprecated
    	EventsSkipped      int64
    	CurrentQueuedCalls int64 // Deprecated
    	EventsErrorsTotal  int64 // Deprecated
    	CurrentSendCalls   int64 // Deprecated
    
    	TargetStats map[TargetID]TargetStat
    }
    
    // TargetStat is the stats of a single target.
    type TargetStat struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. cmd/tier-last-day-stats_gen_test.go

    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    func BenchmarkUnmarshalDailyAllTierStats(b *testing.B) {
    	v := DailyAllTierStats{}
    	bts, _ := v.MarshalMsg(nil)
    	b.ReportAllocs()
    	b.SetBytes(int64(len(bts)))
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. internal/bucket/bandwidth/monitor_gen_test.go

    	bts, _ = v.MarshalMsg(bts[0:0])
    	b.SetBytes(int64(len(bts)))
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		bts, _ = v.MarshalMsg(bts[0:0])
    	}
    }
    
    func BenchmarkUnmarshalBucketBandwidthReport(b *testing.B) {
    	v := BucketBandwidthReport{}
    	bts, _ := v.MarshalMsg(nil)
    	b.ReportAllocs()
    	b.SetBytes(int64(len(bts)))
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  9. cmd/erasure-sets.go

    	k0, k1 := binary.LittleEndian.Uint64(id[0:8]), binary.LittleEndian.Uint64(id[8:16])
    	sum64 := siphash.Hash(k0, k1, []byte(key))
    	return int(sum64 % uint64(cardinality))
    }
    
    func crcHashMod(key string, cardinality int) int {
    	if cardinality <= 0 {
    		return -1
    	}
    	keyCrc := crc32.Checksum([]byte(key), crc32.IEEETable)
    	return int(keyCrc % uint32(cardinality))
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  10. internal/hash/reader.go

    // are not empty then it will check whether the computed
    // match the reference values.
    type Reader struct {
    	src         io.Reader
    	bytesRead   int64
    	expectedMin int64
    	expectedMax int64
    
    	size       int64
    	actualSize int64
    
    	checksum      etag.ETag
    	contentSHA256 []byte
    
    	// Content checksum
    	contentHash   Checksum
    	contentHasher hash.Hash
    	disableMD5    bool
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
Back to top