summaryrefslogtreecommitdiffstats
path: root/qx08/source/class/tr/ui/TraceTable.js
diff options
context:
space:
mode:
Diffstat (limited to 'qx08/source/class/tr/ui/TraceTable.js')
-rw-r--r--qx08/source/class/tr/ui/TraceTable.js214
1 files changed, 214 insertions, 0 deletions
diff --git a/qx08/source/class/tr/ui/TraceTable.js b/qx08/source/class/tr/ui/TraceTable.js
new file mode 100644
index 0000000..446cbad
--- /dev/null
+++ b/qx08/source/class/tr/ui/TraceTable.js
@@ -0,0 +1,214 @@
+/* ************************************************************************
+#module(Tr)
+************************************************************************ */
+
+/**
+ * a widget showing the Tr target tree
+ */
+
+qx.Class.define('Tr.ui.TraceTable',
+{
+ extend: qx.ui.table.Table,
+
+ /*
+ *****************************************************************************
+ CONSTRUCTOR
+ *****************************************************************************
+ */
+
+
+ construct: function () {
+
+ var tableModel = new qx.ui.table.model.Simple();
+ this.__tableModel = tableModel;
+ tableModel.setColumns([ this.tr("Hop"), this.tr("Host"),this.tr("Ip"),
+ this.tr("Loss [%]"), this.tr("Sent"), this.tr("Last [ms]"), //"; help syntax highliter
+ this.tr("Avg [ms]"), this.tr("Best [ms]"), this.tr("Worst [ms]"), this.tr("StDev [ms]") ]);
+ var custom = {
+ tableColumnModel: function(obj) {
+ return new qx.ui.table.columnmodel.Resize(obj);
+ }
+ };
+ with(this){
+ base(arguments,tableModel,custom);
+ set({
+ width: '100%',
+ height: '1*',
+ border: 'dark-shadow',
+ showCellFocusIndicator: false,
+ statusBarVisible: false
+ });
+ };
+ var tcm = this.getTableColumnModel();
+ this.__tcm = tcm;
+
+ tcm.setDataCellRenderer(0, new Tr.ui.Cellrenderer(1));
+ tcm.setDataCellRenderer(3, new Tr.ui.Cellrenderer(0,' %'));
+ tcm.setDataCellRenderer(4, new Tr.ui.Cellrenderer(0));
+
+ var render_ms = new Tr.ui.Cellrenderer(1);
+
+ for (var i=5;i<10;i++){
+ tcm.setDataCellRenderer(i, render_ms);
+ }
+
+
+ // Obtain the behavior object to manipulate
+ var resizeBehavior = tcm.getBehavior();
+ // This uses the set() method to set all attriutes at once; uses flex
+ resizeBehavior.set(0, { width:"2*"});
+ resizeBehavior.set(1, { width:"9*"});
+ resizeBehavior.set(2, { width:"5*"});
+
+ for (var i=3;i<10;i++){
+ resizeBehavior.set(i, { width:"3*"});
+ }
+ qx.event.message.Bus.subscribe('tr.cmd',this.__handle_tr,this);
+ },
+
+ /*
+ *****************************************************************************
+ Statics
+ *****************************************************************************
+ */
+ members: {
+ __make_empty_row: function (){
+ return ([undefined,undefined,undefined,0,0,undefined,undefined,undefined,undefined,undefined,0,0,0]);
+ },
+ __stop_table: function (){
+ var tableModel = this.__tableModel;
+ for (var i=0;i<10;i++){
+ tableModel.setColumnSortable(i,true);
+ }
+ qx.event.message.Bus.dispatch('tr.status','stopped');
+ this.__handle = undefined;
+ },
+ __handle_tr: function(m){
+ var self = this;
+ var f_hop = 0,f_host=1,f_ip=2,f_loss=3,f_snt=4,f_last=5,f_avg=6,f_best=7,f_worst=8,f_stdev=9,f_cnt=10,f_sum=11,f_sqsum=12;
+ var fill_table;
+ fill_table = function(retval,exc,id){
+ if (exc == null){
+ if ( self.__handle == undefined ) {
+ qx.event.message.Bus.dispatch('tr.status','started');
+ }
+ self.__handle = retval['handle'];
+ var tableModel = self.__tableModel;
+ var lines = retval['output'].length;
+ var data = self.__data;
+ var sleep = 0;
+ for(var i=0;i<lines;i++){
+ sleep = 0;
+ var hop = retval['output'][i][0];
+ if (hop == 'SLEEP'){
+ sleep = retval['output'][i][1];
+ continue;
+ }
+ else if (hop == 'INFO'){
+ qx.event.message.Bus.dispatch('tr.info',retval['output'][i][1]);
+ continue;
+ }
+ var host = retval['output'][i][1];
+ var ip = retval['output'][i][2];
+ var value = retval['output'][i][3];
+ var ii = 0;
+ var max = data.length;
+ while (true){
+ if ( ii == max ) break;
+ if ( Math.floor(data[ii][0]) > hop) break;
+ if ( Math.floor(data[ii][0]) == hop ){
+ if ( ip == undefined ) break;
+ if ( ip == data[ii][2] ) break;
+ }
+ ii++;
+ }
+ if (ii == max || Math.floor(data[ii][0]) > hop ){
+ if (ii > 0 && Math.floor(data[ii-1][0]) == hop ){
+ hop = data[ii-1][0] + 0.1;
+ }
+ data.splice(ii,0,self.__make_empty_row());
+ data[ii][0] = hop;
+ }
+
+ var drow = data[ii];
+ if (drow[f_host] == undefined && host != undefined){
+ drow[f_host] = host;
+ }
+ if (drow[f_ip] == undefined && ip != undefined){
+ drow[f_ip] = ip;
+ }
+ drow[f_snt]++;
+ drow[f_last] = value;
+
+
+ if (value != undefined){
+ var best = drow[f_best];
+ if (best == undefined || best > value){
+ drow[f_best] = value;
+ }
+ var worst = drow[f_worst];
+ if (worst == undefined || worst < value){
+ drow[f_worst] = value;
+ }
+ drow[f_sum] += value;
+ var sum = drow[f_sum];
+ drow[f_cnt] ++;
+ var cnt = drow[f_cnt];
+ var sqsum = drow[f_sqsum]+value*value;
+ drow[f_sqsum] = sqsum;
+ drow[f_avg] = drow[f_sum]/drow[f_cnt];
+ drow[f_stdev] = Math.sqrt((cnt*sqsum-sum*sum)/(cnt*(cnt-1)))
+ }
+ drow[f_loss] = ((drow[f_snt]-drow[f_cnt])/drow[f_snt])*100;
+ }
+
+ tableModel.setData(data);
+ if (retval['again']){
+ var next_round = function (){Tr.Server.getInstance().callAsync(
+ fill_table,'run_tr',{ handle: retval['handle'],
+ point: retval['point']})};
+ qx.client.Timer.once(next_round,self,sleep*1000);
+ }
+ else {
+ self.__stop_table();
+ }
+ }
+ else {
+ alert(exc);
+ self.__stop_table();
+ }
+ };
+
+ var stop_handler = function (data,exc,id){
+ if (exc == null){
+ qx.event.message.Bus.dispatch('tr.status','stopped');
+ }
+ else {
+ alert(exc);
+ }
+ };
+
+ var cmd = m.getData();
+ switch(cmd['action']){
+ case 'stop':
+ qx.event.message.Bus.dispatch('tr.status','stopping');
+ Tr.Server.getInstance().callAsync(stop_handler,'stop_tr',this.__handle);
+ break;
+ case 'go':
+ this.__data = [];
+ this.__tableModel.setData(this.__data);
+ this.__delay = cmd['delay'];
+ for (var i=0;i<10;i++){
+ this.__tableModel.setColumnSortable(i,false);
+ }
+ qx.event.message.Bus.dispatch('tr.status','starting');
+ Tr.Server.getInstance().callAsync(fill_table,'run_tr',{host: cmd['host'], rounds: cmd['rounds'], delay: cmd['delay']});
+ break;
+ default:
+ alert('Unknown Command '+cmd['action']);
+ }
+ }
+ }
+});
+
+