Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for UnmarshalMsg (0.07 sec)

  1. cmd/data-usage-cache_gen.go

    		o = msgp.AppendInt(o, za0002.NumVersions)
    		// string "no"
    		o = append(o, 0xa2, 0x6e, 0x6f)
    		o = msgp.AppendInt(o, za0002.NumObjects)
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *allTierStats) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  2. cmd/storage-datatypes_gen.go

    func (z BaseOptions) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 0
    	_ = z
    	o = append(o, 0x80)
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BaseOptions) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var field []byte
    	_ = field
    	var zb0001 uint32
    	zb0001, bts, err = msgp.ReadMapHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    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/xl-storage-format-v1_gen.go

    func (z BitrotAlgorithm) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint(o, uint(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BitrotAlgorithm) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint
    		zb0001, bts, err = msgp.ReadUintBytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2_gen.go

    func (z ChecksumAlgo) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendUint8(o, uint8(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *ChecksumAlgo) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 uint8
    		zb0001, bts, err = msgp.ReadUint8Bytes(bts)
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    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/data-usage-cache.go

    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0004 := range z {
    		o = msgp.AppendString(o, zb0004)
    	}
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *dataUsageHashMap) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	var zb0002 uint32
    	zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  6. cmd/background-newdisks-heal-ops.go

    		return nil, err
    	}
    	b, err := disk.ReadAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename))
    	if err != nil {
    		return nil, err
    	}
    	var h healingTracker
    	_, err = h.UnmarshalMsg(b)
    	if err != nil {
    		return nil, err
    	}
    	if h.ID != diskID && h.ID != "" {
    		return nil, fmt.Errorf("loadHealingTracker: drive id mismatch expected %s, got %s", h.ID, diskID)
    	}
    	h.disk = disk
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. cmd/data-scanner.go

    	if len(buf) == 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf)
    	} else if len(buf) > 8 {
    		cycleInfo.next = binary.LittleEndian.Uint64(buf[:8])
    		buf = buf[8:]
    		_, err := cycleInfo.UnmarshalMsg(buf)
    		bugLogIf(ctx, err)
    	}
    
    	scannerTimer := time.NewTimer(scannerCycle.Load())
    	defer scannerTimer.Stop()
    	defer globalScannerMetrics.setCycle(nil)
    
    	for {
    		select {
    		case <-ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  8. cmd/xl-storage.go

    		return nil
    	}
    	if len(b) == 0 {
    		internalLogIf(GlobalContext, fmt.Errorf("%s is empty", healingFile))
    		// 'healing.bin' might be truncated
    		return nil
    	}
    	h := newHealingTracker()
    	_, err = h.UnmarshalMsg(b)
    	internalLogIf(GlobalContext, err)
    	return h
    }
    
    // checkODirectDiskSupport asks the disk to write some data
    // with O_DIRECT support, return an error if any and return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  9. cmd/xl-storage-format-v2.go

    	for _, version := range x.versions {
    		if version.header.Type != ObjectType || version.header.VersionID == versionID || !version.header.UsesDataDir() {
    			continue
    		}
    		_, err := decoded.UnmarshalMsg(version.meta)
    		if err != nil || decoded.ObjectV2 == nil || decoded.ObjectV2.DataDir != dataDir {
    			continue
    		}
    		sameDataDirCount++
    	}
    	return sameDataDirCount
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
Back to top