package json import ( "unsafe" ) type mapDecoder struct { mapType *rtype keyDecoder decoder valueDecoder decoder } func newMapDecoder(mapType *rtype, keyDec decoder, valueDec decoder) *mapDecoder { return &mapDecoder{ mapType: mapType, keyDecoder: keyDec, valueDecoder: valueDec, } } //go:linkname makemap reflect.makemap func makemap(*rtype, int) unsafe.Pointer //go:linkname mapassign reflect.mapassign //go:noescape func mapassign(t *rtype, m unsafe.Pointer, key, val unsafe.Pointer) func (d *mapDecoder) setKey(buf []byte, cursor int64, key interface{}) (int64, error) { header := (*interfaceHeader)(unsafe.Pointer(&key)) return d.keyDecoder.decode(buf, cursor, uintptr(header.ptr)) } func (d *mapDecoder) setValue(buf []byte, cursor int64, key interface{}) (int64, error) { header := (*interfaceHeader)(unsafe.Pointer(&key)) return d.valueDecoder.decode(buf, cursor, uintptr(header.ptr)) } func (d *mapDecoder) setKeyStream(s *stream, key interface{}) error { header := (*interfaceHeader)(unsafe.Pointer(&key)) return d.keyDecoder.decodeStream(s, uintptr(header.ptr)) } func (d *mapDecoder) setValueStream(s *stream, key interface{}) error { header := (*interfaceHeader)(unsafe.Pointer(&key)) return d.valueDecoder.decodeStream(s, uintptr(header.ptr)) } func (d *mapDecoder) decodeStream(s *stream, p uintptr) error { s.skipWhiteSpace() if s.char() != '{' { return errExpected("{ character for map value", s.totalOffset()) } mapValue := makemap(d.mapType, 0) for { s.cursor++ var key interface{} if err := d.setKeyStream(s, &key); err != nil { return err } s.skipWhiteSpace() if s.char() == nul { s.read() } if s.char() != ':' { return errExpected("colon after object key", s.totalOffset()) } s.cursor++ if s.end() { return errUnexpectedEndOfJSON("map", s.totalOffset()) } var value interface{} if err := d.setValueStream(s, &value); err != nil { return err } mapassign(d.mapType, mapValue, unsafe.Pointer(&key), unsafe.Pointer(&value)) s.skipWhiteSpace() if s.char() == nul { s.read() } if s.char() == '}' { *(*unsafe.Pointer)(unsafe.Pointer(p)) = mapValue return nil } if s.char() != ',' { return errExpected("semicolon after object value", s.totalOffset()) } } return nil } func (d *mapDecoder) decode(buf []byte, cursor int64, p uintptr) (int64, error) { cursor = skipWhiteSpace(buf, cursor) buflen := int64(len(buf)) if buflen < 2 { return 0, errExpected("{} for map", cursor) } if buf[cursor] != '{' { return 0, errExpected("{ character for map value", cursor) } cursor++ mapValue := makemap(d.mapType, 0) for ; cursor < buflen; cursor++ { var key interface{} keyCursor, err := d.setKey(buf, cursor, &key) if err != nil { return 0, err } cursor = keyCursor cursor = skipWhiteSpace(buf, cursor) if buf[cursor] != ':' { return 0, errExpected("colon after object key", cursor) } cursor++ if cursor >= buflen { return 0, errUnexpectedEndOfJSON("map", cursor) } var value interface{} valueCursor, err := d.setValue(buf, cursor, &value) if err != nil { return 0, err } cursor = valueCursor mapassign(d.mapType, mapValue, unsafe.Pointer(&key), unsafe.Pointer(&value)) cursor = skipWhiteSpace(buf, valueCursor) if buf[cursor] == '}' { *(*unsafe.Pointer)(unsafe.Pointer(p)) = mapValue return cursor, nil } if buf[cursor] != ',' { return 0, errExpected("semicolon after object value", cursor) } } return cursor, nil }