gogadmin
/
Dockers_dev


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223
							<html>

    <head>
        <title>WebSockets Load Test</title>
    </head>

    <body>

        Host: <input id='host' style='width:100'>&nbsp;
        Port: <input id='port' style='width:50'>&nbsp;
        Encrypt: <input id='encrypt' type='checkbox'>&nbsp;
        Send Delay (ms): <input id='sendDelay' style='width:50' value="100">&nbsp;
        <input id='connectButton' type='button' value='Start' style='width:100px'
            onclick="connect();">&nbsp;

        <br><br>
        <table border=1>
            <tr>
                <th align="right">Packets sent:</th>
                <td align="right"><div id='sent'>0</div></td>
            </tr><tr>
                <th align="right">Good Packets Received:</th>
                <td align="right"><div id='received'>0</div></td>
            </tr><tr>
                <th align="right">Errors (Bad Packets Received:)</th>
                <td align="right"><div id='errors'>0</div></td>
            </tr>
        </table>

        <br>
        Errors:<br>
        <textarea id="error" style="font-size: 9;" cols=80 rows=25></textarea>
    </body>


    <script>

        function error(str) {
            console.error(str);
            cell = document.getElementById('error');
            cell.innerHTML += errors + ": " + str + "\n";
            cell.scrollTop = cell.scrollHeight;
        }

        var host = null, port = null, sendDelay = 0;
        var ws = null, update_ref = null, send_ref = null;
        var sent = 0, received = 0, errors = 0;
        var max_send = 2000;
        var recv_seq = 0, send_seq = 0;

        Array.prototype.pushStr = function (str) {
            var n = str.length;
            for (var i=0; i < n; i++) {
                this.push(str.charCodeAt(i));
            }
        }


        function add (x,y) {
            return parseInt(x,10)+parseInt(y,10);
        }

        function check_respond(data) {
            //console.log(">> check_respond");
            var first, last, str, length, chksum, nums, arr;
            first = String.fromCharCode(data[0]);
            last = String.fromCharCode(data[data.length-1]);

            if (first != "^") {
                errors++;
                error("Packet missing start char '^'");
                return;
            }
            if (last != "$") {
                errors++;
                error("Packet missing end char '$'");
                return;
            }
            text = ''
            for (var i = 1; i < data.length-1; i++) {
                text += String.fromCharCode(data[i]);
            }
            arr = text.split(':');
            seq    = arr[0];
            length = arr[1];
            chksum = arr[2];
            nums   = arr[3];

            //console.log("   length:" + length + " chksum:" + chksum + " nums:" + nums);
            if (seq != recv_seq) {
                errors++;
                error("Expected seq " + recv_seq + " but got " + seq);
                recv_seq = parseInt(seq,10) + 1;   // Back on track
                return;
            }
            recv_seq++;
            if (nums.length != length) {
                errors++;
                error("Expected length " + length + " but got " + nums.length);
                return;
            }
            //real_chksum = nums.reduce(add);
            real_chksum = 0;
            for (var i=0; i < nums.length; i++) {
                real_chksum += parseInt(nums.charAt(i), 10);
            }
            if (real_chksum != chksum) {
                errors++
                error("Expected chksum " + chksum + " but real chksum is " + real_chksum);
                return;
            }
            received++;
            //console.log("   Packet checks out: length:" + length + " chksum:" + chksum);
            //console.log("<< check_respond");
        }

        function send() {
            var length = Math.floor(Math.random()*(max_send-9)) + 10; // 10 - max_send
            var numlist = [], arr = [];
            for (var i=0; i < length; i++) {
                numlist.push( Math.floor(Math.random()*10) );
            }
            //chksum = numlist.reduce(add);
            chksum = 0;
            for (var i=0; i < numlist.length; i++) {
                chksum += parseInt(numlist[i], 10);
            }
            var nums = numlist.join('');
            arr.pushStr("^" + send_seq + ":" + length + ":" + chksum + ":" + nums + "$")
            send_seq ++;
            ws.send(new Uint8Array(arr));
            sent++;
        }

        function update_stats() {
            document.getElementById('sent').innerHTML = sent;
            document.getElementById('received').innerHTML = received;
            document.getElementById('errors').innerHTML = errors;
        }

        function init_ws() {
            console.log(">> init_ws");
            var scheme = "ws://";
            if (document.getElementById('encrypt').checked) {
                scheme = "wss://";
            }
            var uri = scheme + host + ":" + port;
            console.log("connecting to " + uri);
            ws = new WebSocket(uri);
            ws.binaryType = 'arraybuffer';

            ws.addEventListener('message', function(e) {
                //console.log(">> WebSockets.onmessage");
                arr = new Uint8Array(e.data);
                check_respond(arr);
                //console.log("<< WebSockets.onmessage");
            });
            ws.addEventListener('open', function() {
                console.log(">> WebSockets.onopen");
                send_ref = setInterval(send, sendDelay);
                console.log("<< WebSockets.onopen");
            });
            ws.addEventListener('close', function(e) {
                console.log(">> WebSockets.onclose");
                clearInterval(send_ref);
                console.log("<< WebSockets.onclose");
            });
            ws.addEventListener('error', function(e) {
                console.log(">> WebSockets.onerror");
                console.log("   " + e);
                console.log("<< WebSockets.onerror");
            });

            console.log("<< init_ws");
        }

        function connect() {
            console.log(">> connect");
            host = document.getElementById('host').value;
            port = document.getElementById('port').value;
            sendDelay = parseInt(document.getElementById('sendDelay').value, 10);
            if ((!host) || (!port)) {
                console.log("must set host and port");
                return;
            }

            if (ws) {
                ws.close();
            }
            init_ws();
            update_ref = setInterval(update_stats, 1);

            document.getElementById('connectButton').value = "Stop";
            document.getElementById('connectButton').onclick = disconnect;
            console.log("<< connect");
        }

        function disconnect() {
            console.log(">> disconnect");
            if (ws) {
                ws.close();
            }

            clearInterval(update_ref);
            update_stats(); // Final numbers
            recv_seq = 0;
            send_seq = 0;

            document.getElementById('connectButton').value = "Start";
            document.getElementById('connectButton').onclick = connect;
            console.log("<< disconnect");
        }

        window.onload = function() {
            console.log("onload");
            var url = document.location.href;
            document.getElementById('host').value = (url.match(/host=([^&#]*)/) || ['',window.location.hostname])[1];
            document.getElementById('port').value = (url.match(/port=([^&#]*)/) || ['',window.location.port])[1];
        }
    </script>

</html>