add some

include/observer_backend.hrl

@@ -16,27 +16,27 @@
 %%     $Id$
 %%
 
--record(etop_info, 
-	{now = {0, 0, 0},
-	 n_procs = 0,
-	 wall_clock = {0, 0},
-	 runtime = {0, 0},
-	 run_queue = 0,
-	 alloc_areas = [],
-	 memi = [{total, 0},
-		 {processes, 0}, 
-		 {ets, 0},
-		 {atom, 0},
-		 {code, 0},
-		 {binary, 0}],
-	 procinfo = []
-	}).
+-record(etop_info, {
+          now = {0, 0, 0},
+          n_procs = 0,
+          wall_clock = {0, 0},
+          runtime = {0, 0},
+          run_queue = 0,
+          alloc_areas = [],
+          memi = [{total, 0},
+                  {processes, 0}, 
+                  {ets, 0},
+                  {atom, 0},
+                  {code, 0},
+                  {binary, 0}],
+          procinfo = []
+         }).
 
--record(etop_proc_info,
-	{pid,
-	 mem=0,
-	 reds=0,
-	 name,
-	 runtime=0,
-	 cf,
-	 mq=0}).
+-record(etop_proc_info, {
+          pid,
+          mem=0,
+          reds=0,
+          name,
+          runtime=0,
+          cf,
+          mq=0}).

priv/html/index.html

@@ -17,6 +17,10 @@ <h1>BigWig</h1>
         <li><a class="tool" href="reports">Reports</a></li>
         <li><a class="tool" href="etop">Processes</a></li>
         <li><a class="tool" href="appmon">Applications</a></li>
+        <li><a class="tool" href="lager">Lager Logging</a></li>
+        <li><a class="tool" href="entop">Entop</a></li>
+        <li><a class="tool" href="md">Md</a></li>
+        <li>
       </ul>
 
       <div id="nodestats">
@@ -71,15 +75,15 @@ <h1>BigWig</h1>
         <strong>System Info</strong>
         <dl>
           <dt>Process Limit</dt>
-          <dd class="process_limit"></dd>
+          <dd id="glob_limit" class="process_limit"></dd>
           <dt>Kernel Poll</dt>
-          <dd class="kernel_poll"></dd>
+          <dd id="glob_poll" class="kernel_poll"></dd>
           <dt>Logical Processors</dt>
-          <dd class="logical_processors"></dd>
+          <dd id="glob_processors" class="logical_processors"></dd>
           <dt>OTP Release</dt>
-          <dd class="otp_release"></dd>
+          <dd id="glob_release" class="otp_release"></dd>
           <dt>Architecture</dt>
-          <dd class="system_architecture"></dd>
+          <dd id="glob_architecture" class="system_architecture"></dd>
         </dl>
       </div>
     </div>
@@ -132,7 +136,53 @@ <h1>BigWig</h1>
           </tbody>
         </table>
       </div>
-
+      <div id="entop" class="tool">
+        <div>
+            <input type="text" name="node" id="node" size="40"></input>
+            <button id="start_node">Start</button>          
+        </div>
+        <table class="display" id="entop_table">
+          <thead>
+            <tr>
+              <th>Pid</th>
+              <th>Registered Name</th>
+              <th>Reductions</th>
+              <th>MQueue</th>
+              <th>HSize</th>
+              <th>SSize</th>
+              <th>HTot</th>
+            </tr>
+          </thead>
+          <tbody>
+          </tbody>
+        </table>
+      </div>
+      <div id="md" class="tool">
+        <div id="md_title"></div>
+        <div id="md_statistic"></div>
+        <div id="counter"><input type="hidden" name="counter-value" value="0" /></div>
+        <div id="charts" style="width:80%; height:400px;"></div>
+        <div id="bandwidth" style="width:80%; height:400px;"></div>
+      </div>
+      <div id="lager" class="tool">
+        <div>
+            Tracer: <input type="text" name="tracer" id="tracer" size="80"></input>
+            <button id="start_trace">Trace</button>
+            <button id="del_trace">Stop</button>
+            <button id="clear_all_traces">Clear</button>
+        </div>
+        <div id="lager_status"></div>
+        <table class="display" id="log_table">
+          <div id ="trace_log"></div>
+          <thead>
+            <tr>
+              <th>trace</th>
+            </tr>
+          </thead>
+          <tbody>
+          </tbody>
+        </table>
+      </div>
       <div id="reports" class="tool">
         <ul class="menu">
           <li><a class="filter current" href="/rb">all</a></li>
@@ -166,14 +216,16 @@ <h1>BigWig</h1>
         </ul>
       </div>
     </div>
-
     <script type="text/javascript" src="/static/js/jquery-1.6.2.min.js"></script>
     <script type="text/javascript" src="/static/js/jquery.sparkline.min.js"></script>
     <script type="text/javascript" src="/static/js/jquery.dataTables.min.js"></script>
     <script type="text/javascript" src="/static/js/jquery.dataTables.extra.js"></script>
     <script type="text/javascript" src="/static/js/jquery.timers-1.2.js"></script>
     <script type="text/javascript" src="/static/js/jquery-ui.min.js"></script>
     <script type="text/javascript" src="/static/js/jit-2.0.1.min.js"></script>
+    <script type="text/javascript" src="/static/js/jquery.easing.1.3.js"></script>
+    <script type="text/javascript" src="/static/js/jquery.flipCounter.1.2.js"></script>
+    <script type="text/javascript" src="/static/js/highcharts.js"></script>
     <script type="text/javascript" src="/static/js/date.js"></script>
     <script type="text/javascript" src="/static/js/tpl.js"></script>
     <script type="text/javascript" src="/static/js/renderer.js"></script>
@@ -182,6 +234,6 @@ <h1>BigWig</h1>
     <script type="text/javascript" src="/static/js/stats.js"></script>
     <script type="text/javascript" src="/static/js/appmon.js"></script>
     <script type="text/javascript" src="/static/js/bigwig.js"></script>
-
+    <script type="text/javascript" src="/static/js/md_stat.js"></script>
   </body>
 </html>

priv/js/bigwig.js

@@ -32,4 +32,142 @@ $(function() {
         $('#dashboard').append($('<h1>Dashboard dump</h1>'));
         $('#dashboard').append($('<pre class="dbdump">' + JSON.stringify(json, null, 4) + '</pre>'));
     });
+    uStatus();
+    $('#start_trace').bind('click', function(event) {
+      var trace=$('#tracer').val();
+      var x = trace.split(":");
+      var tracer = '';
+      for(var i=0; i< x.length; ++i)
+      {
+        tracer = tracer + x[i] + ',';
+      }
+      tracer = tracer.substring(0,tracer.length-1);
+
+      var url = '/lager/tracer/'+tracer;
+
+      $.ajax({
+              url:url,
+              type:'PUT',
+              success: function(resp){
+                  alert('Add tracer success');
+                  uStatus();
+              }
+            })  
+    });
+    $('#del_trace').bind('click', function(event) {
+      var trace=$('#tracer').val();
+      var x = trace.split(":");
+      var tracer = '';
+      for(var i=0; i< x.length; ++i)
+      {
+        tracer = tracer + x[i] + ',';
+      }
+      tracer = tracer.substring(0,tracer.length-1);
+
+      var url = '/lager/tracer/'+tracer;
+
+      $.ajax({
+              url:url,
+              type:'DELETE',
+              success: function(resp){
+                  alert('Stop tracer success');
+                  uStatus();
+              }
+            })  
+    });
+    $('#clear_all_traces').bind('click', function(event) {
+      var url = '/lager/tracer/all';
+      $.ajax({
+              url:url,
+              type:'DELETE',
+              success: function(resp){
+                  alert('Clear all traces success');
+                  uStatus();
+              }
+            })  
+    });
+    connect("/lager/stream");
 });
+function uStatus()
+{
+      $.getJSON('/lager/status', function(json) {
+        $('#lager_status').html($('<h2>Lager Status</h2>'));
+        for(var i=0; i<json.ActiveTraces.length; ++i)
+         {
+          json.ActiveTraces[i]=($('<a class="tracer" href="#">' + json.ActiveTraces[i] + '</a>'))[0].outerHTML;
+         }
+         var jsonText=JSON.stringify(json, null, 4);
+         var result=jsonText.replace(/\\"/g,"\"");
+         var result1=result.replace(/  /g,"");
+        $('#lager_status').append($('<pre class="dbdump">' + result1 + '</pre>'));
+    });
+};
+function connect(to)
+{
+       var host = document.location.host;
+       websocket = new WebSocket("ws://"+host+to);
+       websocket.onopen = function(evt) { onOpen(evt) }; 
+       websocket.onclose = function(evt) { onClose(evt) }; 
+       websocket.onmessage = function(evt) { onMessage(evt) }; 
+};  
+
+function onOpen(evt) { 
+};  
+function onClose(evt) { 
+};  
+function onMessage(evt) { 
+    var x = (evt.data).split(":\"");
+    var x1 = x[1].split(" ");
+    var x2 = "";
+    for(var i=4; i < x1.length; ++i)
+    {
+       x2 = x2+ x1[i];
+    }
+    $('#trace_dialog').append(   $('<tr></tr>')
+                        .append('<td>'+x1[0]+','+x1[1]+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+x1[2]+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+x1[3]+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+x2+'</td>')
+                        );                      
+};
+function sendTxt(txt) {
+    websocket.send(txt);
+    $('<div id="trace_dialog" class="trace_dialog"></div>')
+    .append(   $('<tr></tr>')
+                        .append('<td>'+"Time"+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+"Node"+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+"Level"+'</td>')
+                        .append('<td> </td>')
+                        .append('<td>'+"Message"+'</td>')
+                        )
+    .dialog({
+      width: 750,
+      height: 500,
+      title: 'routingkey(' + txt + ') &nbsp; ',
+      close: function(event, ui) {
+        closeSubscribe();
+        //$(this).remove();
+        //window.location.reload();
+       // window.location.href="lager";
+      },
+      buttons: {
+        "Close": function() { $(this).dialog("close"); },
+        "Stop Trace": function() {}
+      },
+      })
+};
+function closeSubscribe(){
+  websocket.send('unsubscribe');
+};
+$("body").delegate("a.tracer", "click", function(e){
+     var x1 = $(this).text().split("<<");
+     var x2 =x1[1].split(">>");
+     var x3 = x2[0].replace(/\"/g, "");
+     sendTxt(x3);
+     e.preventDefault();
+});

priv/js/et.js

@@ -12,11 +12,26 @@ $(document).ready(function() {
                         // Use our RENDERER to format everything
                         for(var i=0; i<json.aaData.length; ++i)
                         {
-                            json.aaData[i][0] = RENDERER.render_json_val(json.aaData[i][0])[0].outerHTML;
-                            json.aaData[i][1] = RENDERER.render_json_val(json.aaData[i][1])[0].outerHTML;
-                            json.aaData[i][6] = RENDERER.render_json_val(json.aaData[i][6])[0].outerHTML;
+                            //json.aaData[i][0] = RENDERER.render_json_val(json.aaData[i][0])[0].outerHTML;
+                            //var Pid = (json.aaData[i][0]).data.replace(/[<>]/g, '');
+                            //json.aaData[i][0] = ($('<a class="_pid" href="#">&lt;'+Pid+'&gt;</a>'))[0].outerHTML;
+                            var Pid = json.aaData[i][0];
+                            var Mfa = $('<a class="mfa" href="#">' + json.aaData[i][6] + '</a>');
+                            var Name = $('<a class="mfa" href="#">' + json.aaData[i][1] + '</a>');
+
+                            json.aaData[i][0]= ($('<a class="_pid" href="#">'+Pid+'</a>'))[0].outerHTML;
+                            var Str = json.aaData[i][1];
+                            if( Str.indexOf(":") == -1) {
+                                json.aaData[i][1] = RENDERER.render_json_val(json.aaData[i][1])[0].outerHTML;
+                              }
+                            else {
+                                json.aaData[i][1] = (Name)[0].outerHTML;  
+                            }
+
+                            json.aaData[i][6] = (Mfa)[0].outerHTML;
                         }
-                        var gs = ['node','clock','cpu','tot','bin','nprocs','procs','code','runqueue','atom','ets'];
+                        var gs = ['node','clock','cpu','tot','bin','nprocs','procs','code','runqueue','atom','ets',
+                        'limit','poll','processors','release','architecture'];
                         for (i = 0; i < gs.length; i++) {
                           var g = gs[i];
                           if (g in header) {
@@ -42,3 +57,29 @@ $(document).ready(function() {
     }
   });
 });
+
+$(document).ready(function() {
+  var oTable = $('#entop_table').dataTable({
+    "bProcessing": false,
+    "iDisplayLength": 25,
+    "sAjaxSource": '/entop',
+    "aaSorting": [[5, "desc"]],
+    // Get data piggy-backed on the main table and update the page
+    "fnServerData": function(sSource, aaData, fnCallback) {
+                      $.getJSON( sSource, aaData, function(json) {
+                        // Use our RENDERER to format everything
+                        for(var i=0; i<json.aaData.length; ++i)
+                        {
+                            //json.aaData[i][0] = RENDERER.render_json_val(json.aaData[i][0])[0].outerHTML;
+                            //var Pid = (json.aaData[i][0]).data.replace(/[<>]/g, '');
+                            //json.aaData[i][0] = ($('<a class="_pid" href="#">&lt;'+Pid+'&gt;</a>'))[0].outerHTML;
+                            var Pid = json.aaData[i][0];
+                            json.aaData[i][0]= ($('<a class="_pid" href="#">'+Pid+'</a>'))[0].outerHTML;
+                            json.aaData[i][1] = RENDERER.render_json_val(json.aaData[i][1])[0].outerHTML;
+                        }
+                        fnCallback(json);
+                      });
+                    }
+  });
+  $(document).everyTime(2000, "poll_etop", function() {oTable.fnReloadAjax();});
+});