javascript/container/rpctest_perf.js

   1 var perfStats = null;
   2 var currentRun = {};
   3
   4 function perfService(message) {
   5   if (perfStats.numResults++ === 0) {
   6     perfStats.firstMsg = message; // stored since it has "real" start time
   7   }
   8   perfStats.bytesReceived += message.length;
   9 };
  10
  11 function clearPerfStats(inOrOut) {
  12   perfStats = {
  13     numResults: 0,
  14     bytesReceived: 0,
  15     firstMsg: null
  16   };
  17
  18   document.getElementById("in_or_out").innerHTML = inOrOut;
  19
  20   // hide results fields
  21   document.getElementById("results").style.display = "none";
  22 };
  23
  24 function completePerfStats() {
  25   perfStats.timeEnded = new Date().getTime();
  26
  27   // get time started from the first sent message
  28   perfStats.timeStarted = perfStats.firstMsg.substr(0, perfStats.firstMsg.indexOf(':'));
  29
  30   var timeUsedMs = perfStats.timeEnded - perfStats.timeStarted;
  31
  32   // fill in fields
  33   document.getElementById("results_num_received").innerHTML = perfStats.numResults;
  34   document.getElementById("results_bytes_received").innerHTML = perfStats.bytesReceived;
  35   document.getElementById("results_time_used").innerHTML = timeUsedMs + "ms";
  36   document.getElementById("results_msgs_per_sec").innerHTML = (perfStats.numResults / (timeUsedMs / 1000));
  37   document.getElementById("results_bytes_per_sec").innerHTML = (perfStats.bytesReceived / (timeUsedMs / 1000));
  38   document.getElementById("test_running").style.display = "none";
  39   document.getElementById("results").style.display = "";
  40 };
  41
  42 function initPerfTest() {
  43   clearPerfStats();
  44   gadgets.rpc.register("perf_service", perfService);
  45   gadgets.rpc.register("clear_perf_stats", clearPerfStats);
  46   gadgets.rpc.register("complete_perf_stats", completePerfStats);
  47 };
  48
  49 var alphabet = "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789 _-*&(){}'";
  50
  51 function sendPerfMessage() {
  52   var msgToSend = currentRun.msg;
  53   if (currentRun.curMsgId++ <= 1) {
  54     var nowString = new Date().getTime() + ':';
  55     msgToSend = nowString + currentRun.msg.substring(nowString.length);
  56   }
  57
  58   gadgets.rpc.call(currentRun.targetId, "perf_service", null, msgToSend);
  59   if (currentRun.curMsgId < currentRun.endMsgId) {
  60     // loop, giving up execution in case rpc technique demands it
  61     window.setTimeout(sendPerfMessage, 0);
  62   } else {
  63     // send finisher
  64     window.setTimeout(function() { gadgets.rpc.call(currentRun.targetId, "complete_perf_stats", null); }, 0);
  65   }
  66 };
  67
  68 function runPerfTest(targetId) {
  69   document.getElementById("test_running").style.display = "";
  70
  71   // initialize the current run
  72   var num_msgs = document.getElementById("num_msgs").value;
  73   var msg_size = document.getElementById("msg_size").value;
  74
  75   currentRun.targetId = targetId;
  76   currentRun.curMsgId = 0;
  77   currentRun.endMsgId = num_msgs;
  78
  79   var msg = [];
  80   for (var i = 0; i < msg_size; ++i) {
  81     msg[i] = alphabet.charAt(Math.round(Math.random(alphabet.length)));
  82   }
  83   currentRun.msg = msg.join('');
  84
  85   // clear local perf stats
  86   clearPerfStats("(outbound)");
  87
  88   // clear target perf stats
  89   gadgets.rpc.call(targetId, "clear_perf_stats", null, "(inbound)");
  90
  91   // kick off the send loop
  92   sendPerfMessage();
  93 };