Remove unnecessary read

pgx-vs-pq
Jack Christensen 2014-04-25 12:47:24 -06:00
parent a0bfe4eab8
commit 4829cd4ebc
1 changed files with 2 additions and 7 deletions

View File

@ -848,16 +848,11 @@ func (c *Connection) rxMsgHeader() (t byte, bodySize int32, err error) {
}
}()
buf := c.getBuf()
if _, err = io.CopyN(buf, c.reader, 5); err != nil {
return 0, 0, err
}
t, err = buf.ReadByte()
t, err = c.reader.ReadByte()
if err != nil {
return
}
err = binary.Read(buf, binary.BigEndian, &bodySize)
err = binary.Read(c.reader, binary.BigEndian, &bodySize)
bodySize -= 4 // remove self from size
return
}