We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 447c64a commit 5e8c201Copy full SHA for 5e8c201
packets.go
@@ -34,10 +34,7 @@ func (mc *mysqlConn) readPacket() (data []byte, err error) {
34
}
35
36
// Packet Length
37
- var pktLen uint32
38
- pktLen |= uint32(data[0])
39
- pktLen |= uint32(data[1]) << 8
40
- pktLen |= uint32(data[2]) << 16
+ pktLen := uint32(data[0]) | uint32(data[1])<<8 | uint32(data[2])<<16
41
42
if pktLen == 0 {
43
errLog.Print(errMalformPkt.Error())
@@ -69,7 +66,7 @@ func (mc *mysqlConn) readPacket() (data []byte, err error) {
69
66
func (mc *mysqlConn) writePacket(data []byte) error {
70
67
// Write packet
71
68
n, err := mc.netConn.Write(data)
72
- if err == nil || n == len(data) {
+ if err == nil && n == len(data) {
73
mc.sequence++
74
return nil
75
0 commit comments