- Sort Score
- Num 10 results
- Language All
Results 51 - 60 of 99 for Msgsize (0.06 seconds)
-
internal/grid/connection.go
if payload != nil { if sz := payload.Msgsize(); cap(msg.Payload) < sz { PutByteBuffer(msg.Payload) msg.Payload = GetByteBufferCap(sz) } var err error msg.Payload, err = payload.MarshalMsg(msg.Payload[:0]) msg.Op = payload.Op() if err != nil { return err } } defer PutByteBuffer(msg.Payload) dst := GetByteBufferCap(msg.Msgsize()) dst, err := msg.MarshalMsg(dst) if err != nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
cmd/bucket-replication-metrics_gen_test.go
b.Fatal(err) } } } func TestEncodeDecodeActiveWorkerStat(t *testing.T) { v := ActiveWorkerStat{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodeActiveWorkerStat Msgsize() is inaccurate") } vn := ActiveWorkerStat{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.4K bytes - Click Count (0) -
cmd/local-locker_gen.go
} o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z localLockMap) Msgsize() (s int) { s = msgp.MapHeaderSize if z != nil { for zb0006, zb0007 := range z { _ = zb0007 s += msgp.StringPrefixSize + len(zb0006) + msgp.ArrayHeaderSize for zb0008 := range zb0007 { s += zb0007[zb0008].Msgsize() } } } return }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 16.6K bytes - Click Count (0) -
internal/grid/msg_gen.go
if err != nil { err = msgp.WrapError(err) return } (*z) = Flags(zb0001) } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z Flags) Msgsize() (s int) { s = msgp.Uint8Size return } // DecodeMsg implements msgp.Decodable func (z *HandlerID) DecodeMsg(dc *msgp.Reader) (err error) { { var zb0001 uint8Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 22.4K bytes - Click Count (0) -
cmd/xl-storage-format-v2_gen_test.go
} } } func TestEncodeDecodexlMetaDataDirDecoder(t *testing.T) { v := xlMetaDataDirDecoder{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecodexlMetaDataDirDecoder Msgsize() is inaccurate") } vn := xlMetaDataDirDecoder{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11.5K bytes - Click Count (0) -
cmd/last-minute_gen.go
bts, err = msgp.Skip(bts) if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z AccElem) Msgsize() (s int) { s = 1 + 6 + msgp.Int64Size + 5 + msgp.Int64Size + 2 + msgp.Int64Size return } // DecodeMsg implements msgp.Decodable
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 17.2K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance_gen_test.go
b.Fatal(err) } } } func TestEncodeDecoderebalanceInfo(t *testing.T) { v := rebalanceInfo{} var buf bytes.Buffer msgp.Encode(&buf, &v) m := v.Msgsize() if buf.Len() > m { t.Log("WARNING: TestEncodeDecoderebalanceInfo Msgsize() is inaccurate") } vn := rebalanceInfo{} err := msgp.Decode(&buf, &vn) if err != nil { t.Error(err) } buf.Reset() msgp.Encode(&buf, &v)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 11K bytes - Click Count (0) -
cmd/erasure-server-pool-rebalance_gen.go
return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z rstats) Msgsize() (s int) { s = msgp.ArrayHeaderSize for zb0003 := range z { if z[zb0003] == nil { s += msgp.NilSize } else { s += z[zb0003].Msgsize() } } returnCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 26.8K bytes - Click Count (0) -
cmd/batch-handlers_gen.go
} } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z *BatchJobRequest) Msgsize() (s int) { s = 1 + 3 + msgp.StringPrefixSize + len(z.ID) + 5 + msgp.StringPrefixSize + len(z.User) + 8 + msgp.TimeSize + 10 if z.Replicate == nil { s += msgp.NilSize } else { s += z.Replicate.Msgsize() } s += 10 if z.KeyRotate == nil {Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 20.4K bytes - Click Count (0) -
cmd/batch-replicate_gen.go
} } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z *BatchJobReplicateV1) Msgsize() (s int) { s = 1 + 11 + msgp.StringPrefixSize + len(z.APIVersion) + 6 + 1 + 7 + z.Flags.Filter.Msgsize() + 7 + z.Flags.Notify.Msgsize() + 6 + z.Flags.Retry.Msgsize() + 7 + z.Target.Msgsize() + 7 + z.Source.Msgsize() return }Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 40.7K bytes - Click Count (0)