diff --git a/wshandler/wshandler_peer.go b/wshandler/wshandler_peer.go index 565cc25..dcaade7 100644 --- a/wshandler/wshandler_peer.go +++ b/wshandler/wshandler_peer.go @@ -73,8 +73,11 @@ func (ws *WebsocketPeerHandler) upgrade_core(conn *websocket.Conn, accid primiti r.Read(response[1:5]) var size [1]byte + r.Read(size[:]) + cmd := make([]byte, size[0]) r.Read(cmd) + result, err := ws.Call(peer, string(cmd), r) if err != nil {