Function customEncodeFuncOf

proto/custom.go:33–62

(t reflect.Type)

}

func customEncodeFuncOf(t reflect.Type) encodeFunc {
	return func(b []byte, p unsafe.Pointer, flags flags) (int, error) {
		if p != nil {
			if m := reflect.NewAt(t, p).Interface().(customMessage); m != nil {
				size := m.Size()

				if flags.has(toplevel) {
					if len(b) < size {
						return 0, io.ErrShortBuffer
					}
					return m.MarshalTo(b)
				}

				vlen := sizeOfVarlen(size)
				if len(b) < vlen {
					return 0, io.ErrShortBuffer
				}

				n1, err := encodeVarint(b, uint64(size))
				if err != nil {
					return n1, err
				}

				n2, err := m.MarshalTo(b[n1:])
				return n1 + n2, err
			}
		}
		return 0, nil
	}
}

func customDecodeFuncOf(t reflect.Type) decodeFunc {
	return func(b []byte, p unsafe.Pointer, flags flags) (int, error) {