Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 51 - 60 of 99 for Msgsize (0.26 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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 uint8
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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()
    		}
    	}
    	return
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top