Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 75 for DecodeMsg (0.28 sec)

  1. cmd/erasure-server-pool-decom_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *PoolDecommissionInfo) 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--
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 04 21:02:54 GMT 2022
    - 26.7K bytes
    - Viewed (0)
  2. cmd/bucket-replication-metrics_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalInQueueMetric(t *testing.T) {
    	v := InQueueMetric{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Feb 06 06:00:45 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	if err != nil {
    		return fi, err
    	}
    	defer xhttp.DrainBody(respBody)
    
    	dec := msgpNewReader(respBody)
    	defer readMsgpReaderPoolPut(dec)
    
    	err = fi.DecodeMsg(dec)
    	return fi, err
    }
    
    // ReadXL - reads all contents of xl.meta of a file.
    func (client *storageRESTClient) ReadXL(ctx context.Context, volume string, path string, readData bool) (rf RawFileInfo, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/local-locker_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshallockRequesterInfo(t *testing.T) {
    	v := lockRequesterInfo{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 19 22:54:46 GMT 2024
    - 6.7K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalErasureInfo(t *testing.T) {
    	v := ErasureInfo{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 13.2K bytes
    - Viewed (0)
  6. cmd/storage-datatypes_test.go

    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.Log("Size:", buf.Len(), "bytes")
    	b.SetBytes(1)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkDecodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    		Used:      1000,
    		FSType:    "xfs",
    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)
  7. cmd/erasure-server-pool-decom_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalPoolStatus(t *testing.T) {
    	v := PoolStatus{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 12 02:48:43 GMT 2022
    - 11K bytes
    - Viewed (0)
  8. internal/grid/msg_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalconnectResp(t *testing.T) {
    	v := connectResp{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    		t.Fatal(err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 10.8K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2_gen_test.go

    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	rd := msgp.NewEndlessReader(buf.Bytes(), b)
    	dc := msgp.NewReader(rd)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func TestMarshalUnmarshalxlMetaV2DeleteMarker(t *testing.T) {
    	v := xlMetaV2DeleteMarker{}
    	bts, err := v.MarshalMsg(nil)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Nov 18 20:15:22 GMT 2021
    - 11.5K bytes
    - Viewed (0)
  10. cmd/bootstrap-peer-server_gen.go

    package cmd
    
    // Code generated by github.com/tinylib/msgp DO NOT EDIT.
    
    import (
    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *ServerSystemConfig) 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--
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 21:36:44 GMT 2024
    - 6.4K bytes
    - Viewed (0)
Back to top