diff --git a/rtpconn/webclient.go b/rtpconn/webclient.go index 5f4b8af..d81462c 100644 --- a/rtpconn/webclient.go +++ b/rtpconn/webclient.go @@ -832,11 +832,14 @@ func readMessage(conn *websocket.Conn, m *clientMessage) error { return conn.ReadJSON(&m) } +const maxWSMessageSize = 1024 * 1024 const protocolVersion = "2" func StartClient(conn *websocket.Conn, addr net.Addr) (err error) { var m clientMessage + conn.SetReadLimit(maxWSMessageSize) + err = readMessage(conn, &m) if err != nil { conn.Close()