1
0
mirror of https://github.com/json-iterator/go.git synced 2025-01-23 18:54:21 +02:00
json-iterator/feature_reflect_native.go

765 lines
19 KiB
Go
Raw Normal View History

2017-01-06 20:17:47 +08:00
package jsoniter
2017-01-25 22:43:57 +08:00
import (
2017-06-29 20:40:25 +08:00
"encoding"
2017-06-06 09:44:56 +08:00
"encoding/base64"
2017-06-06 23:27:00 +08:00
"encoding/json"
2017-09-09 08:45:57 +08:00
"reflect"
"unsafe"
2017-01-25 22:43:57 +08:00
)
2017-01-06 20:17:47 +08:00
2017-01-09 17:47:21 +08:00
type stringCodec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *stringCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-01-06 20:17:47 +08:00
*((*string)(ptr)) = iter.ReadString()
}
2017-06-20 15:11:01 +08:00
func (codec *stringCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
str := *((*string)(ptr))
stream.WriteString(str)
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *stringCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-06-20 17:43:47 +08:00
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *stringCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*string)(ptr)) == ""
}
2017-01-09 17:47:21 +08:00
type intCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *intCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*int)(ptr)) = iter.ReadInt()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *intCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 17:47:21 +08:00
stream.WriteInt(*((*int)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *intCodec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *intCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*int)(ptr)) == 0
}
2017-07-02 11:03:13 +08:00
type uintptrCodec struct {
}
func (codec *uintptrCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uintptr)(ptr)) = uintptr(iter.ReadUint64())
2017-09-05 13:00:03 +08:00
}
2017-07-02 11:03:13 +08:00
}
func (codec *uintptrCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
stream.WriteUint64(uint64(*((*uintptr)(ptr))))
}
2017-07-09 15:11:24 +08:00
func (codec *uintptrCodec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-07-02 11:03:13 +08:00
}
func (codec *uintptrCodec) IsEmpty(ptr unsafe.Pointer) bool {
return *((*uintptr)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type int8Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int8Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*int8)(ptr)) = iter.ReadInt8()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int8Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteInt8(*((*int8)(ptr)))
2017-01-06 20:17:47 +08:00
}
2017-07-09 15:11:24 +08:00
func (codec *int8Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int8Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*int8)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type int16Codec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *int16Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*int16)(ptr)) = iter.ReadInt16()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int16Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteInt16(*((*int16)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *int16Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int16Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*int16)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type int32Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int32Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*int32)(ptr)) = iter.ReadInt32()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int32Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteInt32(*((*int32)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *int32Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int32Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*int32)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type int64Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int64Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*int64)(ptr)) = iter.ReadInt64()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int64Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteInt64(*((*int64)(ptr)))
2017-01-06 20:17:47 +08:00
}
2017-07-09 15:11:24 +08:00
func (codec *int64Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *int64Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*int64)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type uintCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *uintCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uint)(ptr)) = iter.ReadUint()
2017-09-05 13:00:03 +08:00
return
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uintCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteUint(*((*uint)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *uintCodec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uintCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*uint)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type uint8Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint8Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uint8)(ptr)) = iter.ReadUint8()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint8Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteUint8(*((*uint8)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *uint8Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint8Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*uint8)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type uint16Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-07-09 15:11:24 +08:00
func (codec *uint16Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uint16)(ptr)) = iter.ReadUint16()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint16Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteUint16(*((*uint16)(ptr)))
2017-01-06 20:17:47 +08:00
}
2017-07-09 15:11:24 +08:00
func (codec *uint16Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint16Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*uint16)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type uint32Codec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *uint32Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uint32)(ptr)) = iter.ReadUint32()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint32Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteUint32(*((*uint32)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *uint32Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint32Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*uint32)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type uint64Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint64Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*uint64)(ptr)) = iter.ReadUint64()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint64Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteUint64(*((*uint64)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *uint64Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *uint64Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*uint64)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type float32Codec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *float32Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*float32)(ptr)) = iter.ReadFloat32()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *float32Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteFloat32(*((*float32)(ptr)))
2017-01-06 20:17:47 +08:00
}
2017-07-09 15:11:24 +08:00
func (codec *float32Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *float32Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*float32)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type float64Codec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *float64Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*float64)(ptr)) = iter.ReadFloat64()
2017-09-05 13:00:03 +08:00
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *float64Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteFloat64(*((*float64)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *float64Codec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *float64Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return *((*float64)(ptr)) == 0
}
2017-01-09 19:19:48 +08:00
type boolCodec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *boolCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
if !iter.ReadNil() {
*((*bool)(ptr)) = iter.ReadBool()
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *boolCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 19:19:48 +08:00
stream.WriteBool(*((*bool)(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *boolCodec) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, codec)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *boolCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return !(*((*bool)(ptr)))
}
2017-05-27 00:36:21 +08:00
type emptyInterfaceCodec struct {
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *emptyInterfaceCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
existing := *((*interface{})(ptr))
// Checking for both typed and untyped nil pointers.
if existing != nil &&
reflect.TypeOf(existing).Kind() == reflect.Ptr &&
!reflect.ValueOf(existing).IsNil() {
var ptrToExisting interface{}
for {
elem := reflect.ValueOf(existing).Elem()
if elem.Kind() != reflect.Ptr || elem.IsNil() {
break
}
ptrToExisting = existing
existing = elem.Interface()
}
if iter.ReadNil() {
if ptrToExisting != nil {
nilPtr := reflect.Zero(reflect.TypeOf(ptrToExisting).Elem())
reflect.ValueOf(ptrToExisting).Elem().Set(nilPtr)
} else {
*((*interface{})(ptr)) = nil
}
} else {
iter.ReadVal(existing)
}
return
}
if iter.ReadNil() {
*((*interface{})(ptr)) = nil
2017-09-09 08:45:57 +08:00
} else {
*((*interface{})(ptr)) = iter.Read()
}
2017-01-06 20:17:47 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *emptyInterfaceCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-09 21:00:01 +08:00
stream.WriteVal(*((*interface{})(ptr)))
}
2017-07-09 15:11:24 +08:00
func (codec *emptyInterfaceCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-02-03 18:44:54 +08:00
stream.WriteVal(val)
2017-01-26 00:25:17 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *emptyInterfaceCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-09-14 21:32:42 -07:00
emptyInterface := (*emptyInterface)(ptr)
return emptyInterface.typ == nil
2017-03-08 07:38:25 -08:00
}
2017-05-27 00:36:21 +08:00
type nonEmptyInterfaceCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *nonEmptyInterfaceCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-05-27 00:36:21 +08:00
nonEmptyInterface := (*nonEmptyInterface)(ptr)
if nonEmptyInterface.itab == nil {
2017-06-20 15:11:01 +08:00
iter.ReportError("read non-empty interface", "do not know which concrete type to decode to")
return
}
2017-05-27 00:36:21 +08:00
var i interface{}
e := (*emptyInterface)(unsafe.Pointer(&i))
e.typ = nonEmptyInterface.itab.typ
e.word = nonEmptyInterface.word
iter.ReadVal(&i)
if e.word == nil {
nonEmptyInterface.itab = nil
}
2017-05-27 00:36:21 +08:00
nonEmptyInterface.word = e.word
}
2017-06-20 15:11:01 +08:00
func (codec *nonEmptyInterfaceCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-05-27 00:36:21 +08:00
nonEmptyInterface := (*nonEmptyInterface)(ptr)
var i interface{}
if nonEmptyInterface.itab != nil {
e := (*emptyInterface)(unsafe.Pointer(&i))
e.typ = nonEmptyInterface.itab.typ
e.word = nonEmptyInterface.word
}
2017-05-27 00:36:21 +08:00
stream.WriteVal(i)
}
2017-07-09 15:11:24 +08:00
func (codec *nonEmptyInterfaceCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-05-27 00:36:21 +08:00
stream.WriteVal(val)
}
2017-06-20 15:11:01 +08:00
func (codec *nonEmptyInterfaceCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-05-27 00:36:21 +08:00
nonEmptyInterface := (*nonEmptyInterface)(ptr)
return nonEmptyInterface.word == nil
}
2017-01-26 00:25:17 +08:00
type anyCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *anyCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-01-26 00:25:17 +08:00
*((*Any)(ptr)) = iter.ReadAny()
}
2017-06-20 15:11:01 +08:00
func (codec *anyCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-01-26 00:25:17 +08:00
(*((*Any)(ptr))).WriteTo(stream)
}
2017-07-09 15:11:24 +08:00
func (codec *anyCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-01-26 00:25:17 +08:00
(val.(Any)).WriteTo(stream)
}
2017-07-09 15:11:24 +08:00
func (codec *anyCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-03-08 07:38:25 -08:00
return (*((*Any)(ptr))).Size() == 0
}
2017-06-02 10:21:43 +08:00
type jsonNumberCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *jsonNumberCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-10-07 09:29:32 +08:00
switch iter.WhatIsNext() {
case StringValue:
*((*json.Number)(ptr)) = json.Number(iter.ReadString())
2017-10-07 09:29:32 +08:00
case NilValue:
iter.skipFourBytes('n', 'u', 'l', 'l')
*((*json.Number)(ptr)) = ""
default:
*((*json.Number)(ptr)) = json.Number([]byte(iter.readNumberAsString()))
}
2017-06-02 10:21:43 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *jsonNumberCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-06-02 10:21:43 +08:00
stream.WriteRaw(string(*((*json.Number)(ptr))))
}
2017-07-09 15:11:24 +08:00
func (codec *jsonNumberCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-06-02 10:21:43 +08:00
stream.WriteRaw(string(val.(json.Number)))
}
2017-07-09 15:11:24 +08:00
func (codec *jsonNumberCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-06-02 10:21:43 +08:00
return len(*((*json.Number)(ptr))) == 0
}
type jsoniterNumberCodec struct {
}
func (codec *jsoniterNumberCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-10-07 09:29:32 +08:00
switch iter.WhatIsNext() {
case StringValue:
*((*Number)(ptr)) = Number(iter.ReadString())
2017-10-07 09:29:32 +08:00
case NilValue:
iter.skipFourBytes('n', 'u', 'l', 'l')
*((*Number)(ptr)) = ""
default:
*((*Number)(ptr)) = Number([]byte(iter.readNumberAsString()))
}
}
func (codec *jsoniterNumberCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
stream.WriteRaw(string(*((*Number)(ptr))))
}
func (codec *jsoniterNumberCodec) EncodeInterface(val interface{}, stream *Stream) {
stream.WriteRaw(string(val.(Number)))
}
func (codec *jsoniterNumberCodec) IsEmpty(ptr unsafe.Pointer) bool {
return len(*((*Number)(ptr))) == 0
}
2017-06-02 10:50:23 +08:00
type jsonRawMessageCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *jsonRawMessageCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-06-02 10:50:23 +08:00
*((*json.RawMessage)(ptr)) = json.RawMessage(iter.SkipAndReturnBytes())
}
2017-06-20 15:11:01 +08:00
func (codec *jsonRawMessageCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-06-02 10:50:23 +08:00
stream.WriteRaw(string(*((*json.RawMessage)(ptr))))
}
2017-07-09 15:11:24 +08:00
func (codec *jsonRawMessageCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-06-02 10:50:23 +08:00
stream.WriteRaw(string(val.(json.RawMessage)))
}
2017-07-09 15:11:24 +08:00
func (codec *jsonRawMessageCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-06-02 10:50:23 +08:00
return len(*((*json.RawMessage)(ptr))) == 0
}
2017-06-19 23:10:20 +08:00
type jsoniterRawMessageCodec struct {
}
2017-06-20 15:11:01 +08:00
func (codec *jsoniterRawMessageCodec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-06-19 23:10:20 +08:00
*((*RawMessage)(ptr)) = RawMessage(iter.SkipAndReturnBytes())
}
2017-06-20 15:11:01 +08:00
func (codec *jsoniterRawMessageCodec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-06-19 23:10:20 +08:00
stream.WriteRaw(string(*((*RawMessage)(ptr))))
}
2017-07-09 15:11:24 +08:00
func (codec *jsoniterRawMessageCodec) EncodeInterface(val interface{}, stream *Stream) {
2017-06-19 23:10:20 +08:00
stream.WriteRaw(string(val.(RawMessage)))
}
2017-07-09 15:11:24 +08:00
func (codec *jsoniterRawMessageCodec) IsEmpty(ptr unsafe.Pointer) bool {
2017-06-19 23:10:20 +08:00
return len(*((*RawMessage)(ptr))) == 0
}
2017-06-06 09:44:56 +08:00
type base64Codec struct {
2017-07-19 12:04:22 +08:00
sliceDecoder ValDecoder
2017-06-06 09:44:56 +08:00
}
2017-06-20 15:11:01 +08:00
func (codec *base64Codec) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-06-26 14:25:56 +08:00
if iter.ReadNil() {
ptrSlice := (*sliceHeader)(ptr)
ptrSlice.Len = 0
ptrSlice.Cap = 0
ptrSlice.Data = nil
return
}
2017-07-19 12:04:22 +08:00
switch iter.WhatIsNext() {
case StringValue:
2017-07-19 12:04:22 +08:00
encoding := base64.StdEncoding
src := iter.SkipAndReturnBytes()
src = src[1 : len(src)-1]
decodedLen := encoding.DecodedLen(len(src))
dst := make([]byte, decodedLen)
len, err := encoding.Decode(dst, src)
if err != nil {
iter.ReportError("decode base64", err.Error())
} else {
dst = dst[:len]
dstSlice := (*sliceHeader)(unsafe.Pointer(&dst))
ptrSlice := (*sliceHeader)(ptr)
ptrSlice.Data = dstSlice.Data
ptrSlice.Cap = dstSlice.Cap
ptrSlice.Len = dstSlice.Len
}
case ArrayValue:
2017-07-19 12:04:22 +08:00
codec.sliceDecoder.Decode(ptr, iter)
default:
iter.ReportError("base64Codec", "invalid input")
2017-06-06 09:44:56 +08:00
}
}
2017-06-20 15:11:01 +08:00
func (codec *base64Codec) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-06-26 14:25:56 +08:00
src := *((*[]byte)(ptr))
if len(src) == 0 {
stream.WriteNil()
return
}
2017-06-06 09:44:56 +08:00
encoding := base64.StdEncoding
stream.writeByte('"')
toGrow := encoding.EncodedLen(len(src))
stream.ensure(toGrow)
encoding.Encode(stream.buf[stream.n:], src)
stream.n += toGrow
stream.writeByte('"')
}
2017-07-09 15:11:24 +08:00
func (codec *base64Codec) EncodeInterface(val interface{}, stream *Stream) {
2017-06-26 14:25:56 +08:00
ptr := extractInterface(val).word
src := *((*[]byte)(ptr))
if len(src) == 0 {
stream.WriteNil()
return
}
2017-06-06 09:44:56 +08:00
encoding := base64.StdEncoding
stream.writeByte('"')
toGrow := encoding.EncodedLen(len(src))
stream.ensure(toGrow)
encoding.Encode(stream.buf[stream.n:], src)
stream.n += toGrow
stream.writeByte('"')
}
2017-07-09 15:11:24 +08:00
func (codec *base64Codec) IsEmpty(ptr unsafe.Pointer) bool {
2017-06-06 09:44:56 +08:00
return len(*((*[]byte)(ptr))) == 0
}
2017-06-28 23:37:10 +08:00
type stringModeNumberDecoder struct {
elemDecoder ValDecoder
2017-01-06 20:17:47 +08:00
}
2017-06-28 23:37:10 +08:00
func (decoder *stringModeNumberDecoder) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-01-06 20:17:47 +08:00
c := iter.nextToken()
if c != '"' {
2017-10-10 08:57:02 +08:00
iter.ReportError("stringModeNumberDecoder", `expect ", but found `+string([]byte{c}))
2017-01-06 20:17:47 +08:00
return
}
2017-06-20 15:11:01 +08:00
decoder.elemDecoder.Decode(ptr, iter)
2017-01-06 20:17:47 +08:00
if iter.Error != nil {
return
}
c = iter.readByte()
if c != '"' {
2017-10-10 08:57:02 +08:00
iter.ReportError("stringModeNumberDecoder", `expect ", but found `+string([]byte{c}))
2017-01-06 20:17:47 +08:00
return
}
2017-05-24 14:34:00 +08:00
}
2017-06-28 23:37:10 +08:00
type stringModeStringDecoder struct {
elemDecoder ValDecoder
2017-06-29 20:40:25 +08:00
cfg *frozenConfig
2017-06-28 23:37:10 +08:00
}
func (decoder *stringModeStringDecoder) Decode(ptr unsafe.Pointer, iter *Iterator) {
decoder.elemDecoder.Decode(ptr, iter)
str := *((*string)(ptr))
tempIter := decoder.cfg.BorrowIterator([]byte(str))
defer decoder.cfg.ReturnIterator(tempIter)
*((*string)(ptr)) = tempIter.ReadString()
}
type stringModeNumberEncoder struct {
elemEncoder ValEncoder
}
2017-06-28 23:37:10 +08:00
func (encoder *stringModeNumberEncoder) Encode(ptr unsafe.Pointer, stream *Stream) {
stream.writeByte('"')
2017-06-20 15:11:01 +08:00
encoder.elemEncoder.Encode(ptr, stream)
stream.writeByte('"')
}
2017-06-28 23:37:10 +08:00
func (encoder *stringModeNumberEncoder) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, encoder)
}
func (encoder *stringModeNumberEncoder) IsEmpty(ptr unsafe.Pointer) bool {
return encoder.elemEncoder.IsEmpty(ptr)
}
type stringModeStringEncoder struct {
elemEncoder ValEncoder
2017-06-29 20:40:25 +08:00
cfg *frozenConfig
2017-06-28 23:37:10 +08:00
}
func (encoder *stringModeStringEncoder) Encode(ptr unsafe.Pointer, stream *Stream) {
tempStream := encoder.cfg.BorrowStream(nil)
defer encoder.cfg.ReturnStream(tempStream)
encoder.elemEncoder.Encode(ptr, tempStream)
stream.WriteString(string(tempStream.Buffer()))
}
func (encoder *stringModeStringEncoder) EncodeInterface(val interface{}, stream *Stream) {
2017-06-20 17:43:47 +08:00
WriteToStream(val, stream, encoder)
}
2017-06-28 23:37:10 +08:00
func (encoder *stringModeStringEncoder) IsEmpty(ptr unsafe.Pointer) bool {
2017-06-20 15:11:01 +08:00
return encoder.elemEncoder.IsEmpty(ptr)
}
2017-05-24 14:34:00 +08:00
type marshalerEncoder struct {
templateInterface emptyInterface
checkIsEmpty checkIsEmpty
2017-05-24 14:34:00 +08:00
}
2017-06-20 15:11:01 +08:00
func (encoder *marshalerEncoder) Encode(ptr unsafe.Pointer, stream *Stream) {
2017-05-24 14:34:00 +08:00
templateInterface := encoder.templateInterface
templateInterface.word = ptr
realInterface := (*interface{})(unsafe.Pointer(&templateInterface))
marshaler, ok := (*realInterface).(json.Marshaler)
if !ok {
stream.WriteVal(nil)
return
}
2017-05-24 14:34:00 +08:00
bytes, err := marshaler.MarshalJSON()
if err != nil {
stream.Error = err
} else {
stream.Write(bytes)
}
}
2017-06-20 15:11:01 +08:00
func (encoder *marshalerEncoder) EncodeInterface(val interface{}, stream *Stream) {
2017-06-20 17:43:47 +08:00
WriteToStream(val, stream, encoder)
2017-05-24 14:34:00 +08:00
}
2017-06-20 15:11:01 +08:00
func (encoder *marshalerEncoder) IsEmpty(ptr unsafe.Pointer) bool {
return encoder.checkIsEmpty.IsEmpty(ptr)
2017-05-24 16:04:11 +08:00
}
2017-06-29 00:14:55 +08:00
type textMarshalerEncoder struct {
templateInterface emptyInterface
2017-07-02 11:56:01 +08:00
checkIsEmpty checkIsEmpty
2017-06-29 00:14:55 +08:00
}
func (encoder *textMarshalerEncoder) Encode(ptr unsafe.Pointer, stream *Stream) {
templateInterface := encoder.templateInterface
templateInterface.word = ptr
realInterface := (*interface{})(unsafe.Pointer(&templateInterface))
marshaler := (*realInterface).(encoding.TextMarshaler)
bytes, err := marshaler.MarshalText()
if err != nil {
stream.Error = err
} else {
stream.WriteString(string(bytes))
}
}
func (encoder *textMarshalerEncoder) EncodeInterface(val interface{}, stream *Stream) {
WriteToStream(val, stream, encoder)
}
func (encoder *textMarshalerEncoder) IsEmpty(ptr unsafe.Pointer) bool {
return encoder.checkIsEmpty.IsEmpty(ptr)
2017-06-29 00:14:55 +08:00
}
2017-05-24 16:04:11 +08:00
type unmarshalerDecoder struct {
templateInterface emptyInterface
}
2017-06-20 15:11:01 +08:00
func (decoder *unmarshalerDecoder) Decode(ptr unsafe.Pointer, iter *Iterator) {
2017-05-24 16:04:11 +08:00
templateInterface := decoder.templateInterface
templateInterface.word = ptr
realInterface := (*interface{})(unsafe.Pointer(&templateInterface))
unmarshaler := (*realInterface).(json.Unmarshaler)
2017-07-01 00:33:42 +08:00
iter.nextToken()
iter.unreadByte() // skip spaces
2017-05-24 16:04:11 +08:00
bytes := iter.SkipAndReturnBytes()
err := unmarshaler.UnmarshalJSON(bytes)
if err != nil {
2017-06-29 00:14:55 +08:00
iter.ReportError("unmarshalerDecoder", err.Error())
}
}
type textUnmarshalerDecoder struct {
templateInterface emptyInterface
}
func (decoder *textUnmarshalerDecoder) Decode(ptr unsafe.Pointer, iter *Iterator) {
templateInterface := decoder.templateInterface
templateInterface.word = ptr
realInterface := (*interface{})(unsafe.Pointer(&templateInterface))
unmarshaler := (*realInterface).(encoding.TextUnmarshaler)
str := iter.ReadString()
err := unmarshaler.UnmarshalText([]byte(str))
if err != nil {
iter.ReportError("textUnmarshalerDecoder", err.Error())
2017-05-24 16:04:11 +08:00
}
2017-06-06 09:44:56 +08:00
}