()
| 202 | } |
| 203 | |
| 204 | func (c *Conn) readOK() (*Result, error) { |
| 205 | data, err := c.ReadPacket() |
| 206 | if err != nil { |
| 207 | return nil, errors.Trace(err) |
| 208 | } |
| 209 | |
| 210 | if data[0] == OK_HEADER { |
| 211 | return c.handleOKPacket(data) |
| 212 | } else if data[0] == ERR_HEADER { |
| 213 | return nil, c.handleErrorPacket(data) |
| 214 | } else { |
| 215 | return nil, errors.New("invalid ok packet") |
| 216 | } |
| 217 | } |
| 218 | |
| 219 | func (c *Conn) readResult(binary bool) (*Result, error) { |
| 220 | firstPkgBuf, err := c.ReadPacketReuseMem(utils.ByteSliceGet(16)[:0]) |
no test coverage detected