- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for AppendUint32 (0.11 sec)
-
internal/grid/msg_gen.go
func (z *message) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize()) // array header, size 7 o = append(o, 0x97) o = msgp.AppendUint64(o, z.MuxID) o = msgp.AppendUint32(o, z.Seq) o = msgp.AppendUint32(o, z.DeadlineMS) o = msgp.AppendUint8(o, uint8(z.Handler)) o = msgp.AppendUint8(o, uint8(z.Op)) o = msgp.AppendUint8(o, uint8(z.Flags)) o = msgp.AppendBytes(o, z.Payload) return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jul 25 21:07:21 UTC 2024 - 22.4K bytes - Viewed (0) -
internal/grid/muxclient.go
if debugPrint { fmt.Println("Added subroute", hid.String(), "to message", msg, "len", len(dst)-before) } } if msg.Flags&FlagCRCxxh3 != 0 { h := xxh3.Hash(dst) dst = binary.LittleEndian.AppendUint32(dst, uint32(h)) } return m.parent.send(m.ctx, dst) } // RequestStateless will send a single payload request and stream back results. // req may not be read/written to after calling.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
internal/grid/connection.go
dst := GetByteBufferCap(msg.Msgsize()) dst, err := msg.MarshalMsg(dst) if err != nil { return err } if msg.Flags&FlagCRCxxh3 != 0 { h := xxh3.Hash(dst) dst = binary.LittleEndian.AppendUint32(dst, uint32(h)) } return c.send(c.ctx, dst) } // sendMsg will send func (c *Connection) sendMsg(conn net.Conn, msg message, payload msgp.MarshalSizer) error { if payload != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
cmd/xl-storage-format-v1_gen.go
o = msgp.AppendString(o, z.Name) // string "Dir" o = append(o, 0xa3, 0x44, 0x69, 0x72) o = msgp.AppendBool(o, z.Dir) // string "Mode" o = append(o, 0xa4, 0x4d, 0x6f, 0x64, 0x65) o = msgp.AppendUint32(o, z.Mode) return } // UnmarshalMsg implements msgp.Unmarshaler func (z *StatInfo) UnmarshalMsg(bts []byte) (o []byte, err error) { var field []byte _ = field var zb0001 uint32
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/storage-datatypes_gen.go
o = msgp.AppendUint64(o, z.Total) o = msgp.AppendUint64(o, z.Free) o = msgp.AppendUint64(o, z.Used) o = msgp.AppendUint64(o, z.UsedInodes) o = msgp.AppendUint64(o, z.FreeInodes) o = msgp.AppendUint32(o, z.Major) o = msgp.AppendUint32(o, z.Minor) o = msgp.AppendUint64(o, z.NRRequests) o = msgp.AppendString(o, z.FSType) o = msgp.AppendBool(o, z.RootDisk) o = msgp.AppendBool(o, z.Healing)
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/data-usage-cache_gen.go
// string "Name" o = append(o, 0x84, 0xa4, 0x4e, 0x61, 0x6d, 0x65) o = msgp.AppendString(o, z.Name) // string "NextCycle" o = append(o, 0xa9, 0x4e, 0x65, 0x78, 0x74, 0x43, 0x79, 0x63, 0x6c, 0x65) o = msgp.AppendUint32(o, z.NextCycle) // string "LastUpdate" o = append(o, 0xaa, 0x4c, 0x61, 0x73, 0x74, 0x55, 0x70, 0x64, 0x61, 0x74, 0x65) o = msgp.AppendTime(o, z.LastUpdate) // string "SkipHealing"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 75K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
o = msgp.AppendString(o, z.EventType) // string "RetryCount" o = append(o, 0xaa, 0x52, 0x65, 0x74, 0x72, 0x79, 0x43, 0x6f, 0x75, 0x6e, 0x74) o = msgp.AppendUint32(o, z.RetryCount) // string "ResetID" o = append(o, 0xa7, 0x52, 0x65, 0x73, 0x65, 0x74, 0x49, 0x44) o = msgp.AppendString(o, z.ResetID) // string "Dsc" o = append(o, 0xa3, 0x44, 0x73, 0x63)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 70.1K bytes - Viewed (0)