diff options
Diffstat (limited to 'vendor/github.com/vmihailenco/msgpack/v5/decode_string.go')
-rw-r--r-- | vendor/github.com/vmihailenco/msgpack/v5/decode_string.go | 192 |
1 files changed, 0 insertions, 192 deletions
diff --git a/vendor/github.com/vmihailenco/msgpack/v5/decode_string.go b/vendor/github.com/vmihailenco/msgpack/v5/decode_string.go deleted file mode 100644 index e837e08bf..000000000 --- a/vendor/github.com/vmihailenco/msgpack/v5/decode_string.go +++ /dev/null @@ -1,192 +0,0 @@ -package msgpack - -import ( - "fmt" - "reflect" - - "github.com/vmihailenco/msgpack/v5/msgpcode" -) - -func (d *Decoder) bytesLen(c byte) (int, error) { - if c == msgpcode.Nil { - return -1, nil - } - - if msgpcode.IsFixedString(c) { - return int(c & msgpcode.FixedStrMask), nil - } - - switch c { - case msgpcode.Str8, msgpcode.Bin8: - n, err := d.uint8() - return int(n), err - case msgpcode.Str16, msgpcode.Bin16: - n, err := d.uint16() - return int(n), err - case msgpcode.Str32, msgpcode.Bin32: - n, err := d.uint32() - return int(n), err - } - - return 0, fmt.Errorf("msgpack: invalid code=%x decoding string/bytes length", c) -} - -func (d *Decoder) DecodeString() (string, error) { - if intern := d.flags&useInternedStringsFlag != 0; intern || len(d.dict) > 0 { - return d.decodeInternedString(intern) - } - - c, err := d.readCode() - if err != nil { - return "", err - } - return d.string(c) -} - -func (d *Decoder) string(c byte) (string, error) { - n, err := d.bytesLen(c) - if err != nil { - return "", err - } - return d.stringWithLen(n) -} - -func (d *Decoder) stringWithLen(n int) (string, error) { - if n <= 0 { - return "", nil - } - b, err := d.readN(n) - return string(b), err -} - -func decodeStringValue(d *Decoder, v reflect.Value) error { - s, err := d.DecodeString() - if err != nil { - return err - } - v.SetString(s) - return nil -} - -func (d *Decoder) DecodeBytesLen() (int, error) { - c, err := d.readCode() - if err != nil { - return 0, err - } - return d.bytesLen(c) -} - -func (d *Decoder) DecodeBytes() ([]byte, error) { - c, err := d.readCode() - if err != nil { - return nil, err - } - return d.bytes(c, nil) -} - -func (d *Decoder) bytes(c byte, b []byte) ([]byte, error) { - n, err := d.bytesLen(c) - if err != nil { - return nil, err - } - if n == -1 { - return nil, nil - } - return readN(d.r, b, n) -} - -func (d *Decoder) decodeStringTemp() (string, error) { - if intern := d.flags&useInternedStringsFlag != 0; intern || len(d.dict) > 0 { - return d.decodeInternedString(intern) - } - - c, err := d.readCode() - if err != nil { - return "", err - } - - n, err := d.bytesLen(c) - if err != nil { - return "", err - } - if n == -1 { - return "", nil - } - - b, err := d.readN(n) - if err != nil { - return "", err - } - - return bytesToString(b), nil -} - -func (d *Decoder) decodeBytesPtr(ptr *[]byte) error { - c, err := d.readCode() - if err != nil { - return err - } - return d.bytesPtr(c, ptr) -} - -func (d *Decoder) bytesPtr(c byte, ptr *[]byte) error { - n, err := d.bytesLen(c) - if err != nil { - return err - } - if n == -1 { - *ptr = nil - return nil - } - - *ptr, err = readN(d.r, *ptr, n) - return err -} - -func (d *Decoder) skipBytes(c byte) error { - n, err := d.bytesLen(c) - if err != nil { - return err - } - if n <= 0 { - return nil - } - return d.skipN(n) -} - -func decodeBytesValue(d *Decoder, v reflect.Value) error { - c, err := d.readCode() - if err != nil { - return err - } - - b, err := d.bytes(c, v.Bytes()) - if err != nil { - return err - } - - v.SetBytes(b) - - return nil -} - -func decodeByteArrayValue(d *Decoder, v reflect.Value) error { - c, err := d.readCode() - if err != nil { - return err - } - - n, err := d.bytesLen(c) - if err != nil { - return err - } - if n == -1 { - return nil - } - if n > v.Len() { - return fmt.Errorf("%s len is %d, but msgpack has %d elements", v.Type(), v.Len(), n) - } - - b := v.Slice(0, n).Bytes() - return d.readFull(b) -} |