- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for MarshalMsg (0.19 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)