fix bug when deal invalid package

capture/network.go

@@ -119,7 +119,7 @@ func (nc *networkCard) listenNormal() {
 				time.Sleep(time.Second*3)
 				continue
 			}
-			
+
 			// capture packets according to a certain probability
 			tcpCapturePacketRate := communicator.GetTCPCapturePacketRate()
 			if tcpCapturePacketRate <= 0 {

session-dealer/mysql/session.go

@@ -149,6 +149,11 @@ func (ms *MysqlSession) readFromClient(seqID int64, bytes []byte) {
 			return
 		}
 
+		// ignore invalid head package
+		if len(bytes) <= 4{
+			return
+		}
+
 		contents := bytes[4:]
 		// add prepare info
 		if contents[0] == ComStmtPrepare {