Function parseGetResponse

memcache/memcache.go:517–548

parseGetResponse reads a GET response from r and calls cb for each read and allocated Item

(r *bufio.Reader, conn *conn, cb func(*Item))

// parseGetResponse reads a GET response from r and calls cb for each
// read and allocated Item
func parseGetResponse(r *bufio.Reader, conn *conn, cb func(*Item)) error {
	for {
		// extend deadline before each additional call, otherwise all cumulative
		// calls use the same overall deadline
		conn.extendDeadline()

		line, err := r.ReadSlice('\n')
		if err != nil {
			return err
		}
		if bytes.Equal(line, resultEnd) {
			return nil
		}
		it := new(Item)
		size, err := scanGetResponseLine(line, it)
		if err != nil {
			return err
		}
		it.Value = make([]byte, size+2)
		_, err = io.ReadFull(r, it.Value)
		if err != nil {
			it.Value = nil
			return err
		}
		if !bytes.HasSuffix(it.Value, crlf) {
			it.Value = nil
			return fmt.Errorf("memcache: corrupt get result read")
		}
		it.Value = it.Value[:size]
		cb(it)
	}
}

// scanGetResponseLine populates it and returns the declared size of the item.
// It does not read the bytes of the item.