Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for EncodeMsg (0.06 sec)

  1. cmd/data-usage-cache_gen_test.go

    	v := allTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    	en := msgp.NewWriter(msgp.Nowhere)
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.EncodeMsg(en)
    	}
    	en.Flush()
    }
    
    func BenchmarkDecodeallTierStats(b *testing.B) {
    	v := allTierStats{}
    	var buf bytes.Buffer
    	msgp.Encode(&buf, &v)
    	b.SetBytes(int64(buf.Len()))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 19K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *RenameDataInlineHandlerParams) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 1
    	// write "p"
    	err = en.Append(0x81, 0xa1, 0x70)
    	if err != nil {
    		return
    	}
    	err = z.RenameDataHandlerParams.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "RenameDataHandlerParams")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *dataUsageCache) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 2
    	// write "Info"
    	err = en.Append(0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)
    	if err != nil {
    		return
    	}
    	err = z.Info.EncodeMsg(en)
    	if err != nil {
    		err = msgp.WrapError(err, "Info")
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2_gen.go

    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = ChecksumAlgo(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z ChecksumAlgo) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint8(uint8(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v1_gen.go

    	{
    		var zb0001 uint
    		zb0001, err = dc.ReadUint()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = BitrotAlgorithm(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint(uint(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. cmd/bucket-metadata_gen.go

    				return
    			}
    		default:
    			err = dc.Skip()
    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *BucketMetadata) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 25
    	// write "Name"
    	err = en.Append(0xde, 0x0, 0x19, 0xa4, 0x4e, 0x61, 0x6d, 0x65)
    	if err != nil {
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 25.4K bytes
    - Viewed (0)
  7. cmd/data-usage-cache.go

    			if err != nil {
    				err = msgp.WrapError(err)
    				return
    			}
    			(*z)[zb0003] = struct{}{}
    		}
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z dataUsageHashMap) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteArrayHeader(uint32(len(z)))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	for zb0004 := range z {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  8. cmd/storage-rest-client.go

    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions)))
    
    	var buffer bytes.Buffer
    	encoder := msgp.NewWriter(&buffer)
    	for _, version := range versions {
    		version.EncodeMsg(encoder)
    	}
    	storageLogIf(ctx, encoder.Flush())
    
    	errs = make([]error, len(versions))
    
    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    	defer xhttp.DrainBody(respBody)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    			n, err := mw.Write(data[:])
    			if err != nil {
    				w.CloseWithError(err)
    				return
    			}
    			if n != len(data) {
    				w.CloseWithError(io.ErrShortWrite)
    				return
    			}
    			err = v.EncodeMsg(mw)
    			mw.Flush()
    			w.CloseWithError(err)
    		}()
    		return r
    	}
    
    	globalLocalDrivesMu.RLock()
    	localDrives := cloneDrives(globalLocalDrivesMap)
    	globalLocalDrivesMu.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top