MCPcopy
hub / github.com/CodisLabs/codis / decodeTextBytes

Method decodeTextBytes

pkg/proxy/redis/decoder.go:138–148  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

136}
137
138func (d *Decoder) decodeTextBytes() ([]byte, error) {
139 b, err := d.br.ReadBytes('\n')
140 if err != nil {
141 return nil, errors.Trace(err)
142 }
143 if n := len(b) - 2; n < 0 || b[n] != '\r' {
144 return nil, errors.Trace(ErrBadCRLFEnd)
145 } else {
146 return b[:n], nil
147 }
148}
149
150func (d *Decoder) decodeInt() (int64, error) {
151 b, err := d.br.ReadSlice('\n')

Callers 2

decodeRespMethod · 0.95

Calls 1

ReadBytesMethod · 0.80

Tested by

no test coverage detected