Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for MarshalMsg (0.19 sec)

  1. cmd/data-usage-cache_gen.go

    			return
    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z *dataUsageCache) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	// map header, size 2
    	// string "Info"
    	o = append(o, 0x82, 0xa4, 0x49, 0x6e, 0x66, 0x6f)
    	o, err = z.Info.MarshalMsg(o)
    	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)
  2. cmd/storage-datatypes_gen.go

    	for za0003 := range z.Parts {
    		o, err = z.Parts[za0003].MarshalMsg(o)
    		if err != nil {
    			err = msgp.WrapError(err, "Parts", za0003)
    			return
    		}
    	}
    	o, err = z.Erasure.MarshalMsg(o)
    	if err != nil {
    		err = msgp.WrapError(err, "Erasure")
    		return
    	}
    	o = msgp.AppendBool(o, z.MarkDeleted)
    	o, err = z.ReplicationState.MarshalMsg(o)
    	if err != nil {
    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) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint(uint(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    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
    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) EncodeMsg(en *msgp.Writer) (err error) {
    	err = en.WriteUint8(uint8(z))
    	if err != nil {
    		err = msgp.WrapError(err)
    		return
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    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
    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.go

    	// Shallow copy
    	c := *m
    	// Zero unimportant fields
    	c.Erasure.Index = 0
    	c.Minio.Release = ""
    	crc := hashDeterministicString(c.Meta)
    	c.Meta = nil
    
    	if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil {
    		crc ^= xxhash.Sum64(bts)
    		metaDataPoolPut(bts)
    	}
    
    	// Combine upper and lower part
    	var tmp [4]byte
    	binary.LittleEndian.PutUint32(tmp[:], uint32(crc^(crc>>32)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  6. cmd/xl-storage-format-v2.go

    func (j *xlMetaV2DeleteMarker) Signature() [4]byte {
    	// Shallow copy
    	c := *j
    
    	// Marshal metadata
    	crc := hashDeterministicBytes(c.MetaSys)
    	c.MetaSys = nil
    	if bts, err := c.MarshalMsg(metaDataPoolGet()); err == nil {
    		crc ^= xxhash.Sum64(bts)
    		metaDataPoolPut(bts)
    	}
    
    	// Combine upper and lower part
    	var tmp [4]byte
    	binary.LittleEndian.PutUint32(tmp[:], uint32(crc^(crc>>32)))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  7. cmd/data-usage-cache.go

    	for zb0004 := range z {
    		err = en.WriteString(zb0004)
    		if err != nil {
    			err = msgp.WrapError(err, zb0004)
    			return
    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    func (z dataUsageHashMap) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendArrayHeader(o, uint32(len(z)))
    	for zb0004 := range z {
    		o = msgp.AppendString(o, zb0004)
    	}
    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/background-newdisks-heal-ops.go

    			if ep, ok := api.(*erasureServerPools); ok {
    				h.PoolIndex, h.SetIndex, h.DiskIndex, _ = ep.getPoolAndSet(h.ID)
    			}
    		}
    	}
    	h.LastUpdate = time.Now().UTC()
    	htrackerBytes, err := h.MarshalMsg(nil)
    	h.mu.Unlock()
    	if err != nil {
    		return err
    	}
    	globalBackgroundHealState.updateHealStatus(h)
    	return h.disk.WriteAll(ctx, minioMetaBucket,
    		pathJoin(bucketMetaPrefix, healingTrackerFilename),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  9. cmd/data-scanner.go

    				}
    				globalScannerMetrics.setCycle(&cycleInfo)
    				tmp := make([]byte, 8, 8+cycleInfo.Msgsize())
    				// Cycle for backward compat.
    				binary.LittleEndian.PutUint64(tmp, cycleInfo.next)
    				tmp, _ = cycleInfo.MarshalMsg(tmp)
    				err = saveConfig(ctx, objAPI, dataUsageBloomNamePath, tmp)
    				if err != nil {
    					scannerLogIf(ctx, fmt.Errorf("%w, Object %s", err, dataUsageBloomNamePath))
    				}
    			}
    		}
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
Back to top