diff --git a/network/tcp_msg.go b/network/tcp_msg.go index db06d4a..b47a451 100644 --- a/network/tcp_msg.go +++ b/network/tcp_msg.go @@ -89,7 +89,7 @@ func (p *MsgParser) Read(conn *TCPConn) ([]byte, error) { msgLen = binary.BigEndian.Uint32(bufMsgLen) } } - msgLen -= 2 + // check len if msgLen > p.maxMsgLen { @@ -97,7 +97,8 @@ 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 {