Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 567 for uint24 (0.17 sec)

  1. internal/s3select/sql/value.go

    func (v Value) ToFloat() (val float64, ok bool) {
    	switch x := v.value.(type) {
    	case float64:
    		return x, true
    	case int64:
    		return float64(x), true
    	}
    	return 0, false
    }
    
    // ToInt returns the value if int.
    func (v Value) ToInt() (val int64, ok bool) {
    	val, ok = v.value.(int64)
    	return
    }
    
    // ToString returns the value if string.
    func (v Value) ToString() (val string, ok bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils_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 BenchmarkUnmarshalBucketReplicationResyncStatus(b *testing.B) {
    	v := BucketReplicationResyncStatus{}
    	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 Aug 22 23:53:06 UTC 2022
    - 23K bytes
    - Viewed (0)
  3. cmd/storage-rest-common_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *nsScannerOptions) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 7.9K bytes
    - Viewed (0)
  4. cmd/xl-storage-meta-inline.go

    func (x xlMetaInlineData) find(key string) []byte {
    	if len(x) == 0 || !x.versionOK() {
    		return nil
    	}
    	sz, buf, err := msgp.ReadMapHeaderBytes(x.afterVersion())
    	if err != nil || sz == 0 {
    		return nil
    	}
    	for i := uint32(0); i < sz; i++ {
    		var found []byte
    		found, buf, err = msgp.ReadMapKeyZC(buf)
    		if err != nil || sz == 0 {
    			return nil
    		}
    		if string(found) == key {
    			val, _, _ := msgp.ReadBytesZC(buf)
    			return val
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  5. cmd/veeam-sos-api.go

    		binfo := globalBucketQuotaSys.GetBucketUsageInfo(ctx, bucket)
    
    		ci := capacityInfo{
    			Used: int64(binfo.Size),
    		}
    
    		var quotaSize int64
    		if q != nil && q.Type == madmin.HardQuota {
    			if q.Size > 0 {
    				quotaSize = int64(q.Size)
    			} else if q.Quota > 0 {
    				quotaSize = int64(q.Quota)
    			}
    		}
    
    		if quotaSize == 0 {
    			info := objAPI.StorageInfo(ctx, true)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  6. 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)
  7. cmd/site-replication-utils_gen.go

    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *SiteResyncStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, err = dc.ReadMapHeader()
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0001 > 0 {
    		zb0001--
    		field, err = dc.ReadMapKeyPtr()
    		if err != nil {
    			err = msgp.WrapError(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 14 15:16:40 UTC 2022
    - 7.2K bytes
    - Viewed (0)
  8. internal/grid/benchmark_test.go

    				defer cancel()
    				b.ReportAllocs()
    				b.SetBytes(int64(len(payload) * 2))
    				b.ResetTimer()
    				t := time.Now()
    				var ops int64
    				var lat int64
    				b.SetParallelism(par)
    				b.RunParallel(func(pb *testing.PB) {
    					rng := rand.New(rand.NewSource(time.Now().UnixNano()))
    					n := 0
    					var latency int64
    					managers := grid.Managers
    					hosts := grid.Hosts
    					for pb.Next() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom_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 BenchmarkUnmarshalPoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	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: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  10. cmd/batch-job-common-types_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 BenchmarkUnmarshalBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	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: Sat Dec 02 10:51:33 UTC 2023
    - 11.3K bytes
    - Viewed (0)
Back to top