diff --git a/network/tcp_msg.go b/network/tcp_msg.go index a9f9361..cd42234 100644 --- a/network/tcp_msg.go +++ b/network/tcp_msg.go @@ -97,8 +97,7 @@ func (p *MsgParser) Read(conn *TCPConn) ([]byte, error) { } else if msgLen < p.minMsgLen { return nil, errors.New("message too short") } - - msgLen -= 2 + // data msgData := make([]byte, msgLen) if _, err := io.ReadFull(conn, msgData); err != nil {