From 8364e6bbedf919008da50cc1b54dbb8a49dee88d Mon Sep 17 00:00:00 2001 From: Tobi Oetiker Date: Wed, 4 Jun 2008 21:33:02 +0000 Subject: alter name to Tr since we do not use mtr anmore --- qooxdoo/source/class/Tr/Application.js | 89 +++++++++++++ qooxdoo/source/class/Tr/Server.js | 74 +++++++++++ qooxdoo/source/class/Tr/ui/ActionButton.js | 164 +++++++++++++++++++++++ qooxdoo/source/class/Tr/ui/Cellrenderer.js | 46 +++++++ qooxdoo/source/class/Tr/ui/TraceTable.js | 200 +++++++++++++++++++++++++++++ 5 files changed, 573 insertions(+) create mode 100644 qooxdoo/source/class/Tr/Application.js create mode 100644 qooxdoo/source/class/Tr/Server.js create mode 100644 qooxdoo/source/class/Tr/ui/ActionButton.js create mode 100644 qooxdoo/source/class/Tr/ui/Cellrenderer.js create mode 100644 qooxdoo/source/class/Tr/ui/TraceTable.js (limited to 'qooxdoo/source/class/Tr') diff --git a/qooxdoo/source/class/Tr/Application.js b/qooxdoo/source/class/Tr/Application.js new file mode 100644 index 0000000..9e07dbe --- /dev/null +++ b/qooxdoo/source/class/Tr/Application.js @@ -0,0 +1,89 @@ +/* ************************************************************************ + +#module(Tr) +#resource(Tr.image:image) +#embed(Tr.image/*) + +************************************************************************ */ + +qx.Class.define('Tr.Application', +{ + extend: qx.application.Gui, + + members: + { + main: function() + { + var self=this; + this.base(arguments); + + qx.io.Alias.getInstance().add( + 'MT', qx.core.Setting.get('Tr.resourceUri') + ); + + // if we run with a file:// url make sure + // the app finds the Tr service (Tr.cgi) + + Tr.Server.getInstance().setLocalUrl( + 'http://johan.oetiker.ch/~oetiker/tr/' + ); + + var base_layout = new qx.ui.layout.VerticalBoxLayout(); + with(base_layout){ + setPadding(8); + setLocation(0,0); + setWidth('100%'); + setHeight('100%'); + setSpacing(10); + setBackgroundColor('white'); + }; + base_layout.addToDocument(); + var top = new qx.ui.layout.HorizontalBoxLayout(); + top.set({ + height: 'auto' + }); + var title = new qx.ui.basic.Atom(this.tr("Smokeping Traceroute Frontend")); + with(title){ + setTextColor('#b0b0b0'); + setFont(qx.ui.core.Font.fromString('20px bold sans-serif')); + } + top.add(title); + top.add(new qx.ui.basic.HorizontalSpacer()); + top.add(new Tr.ui.ActionButton()); + base_layout.add(top); + var trace = new Tr.ui.TraceTable(); + base_layout.add(trace); + }, + + close : function(e) + { + this.base(arguments); + // return "Tr Web UI: " + // + "Do you really want to close the application?"; + }, + + + terminate : function(e) { + this.base(arguments); + } + + /******************************************************************** + * Functional Block Methods + ********************************************************************/ + + }, + + + + + /* + ***************************************************************************** + SETTINGS + ***************************************************************************** + */ + + settings : { + 'Tr.resourceUri' : './resource' + } +}); + diff --git a/qooxdoo/source/class/Tr/Server.js b/qooxdoo/source/class/Tr/Server.js new file mode 100644 index 0000000..f17e54b --- /dev/null +++ b/qooxdoo/source/class/Tr/Server.js @@ -0,0 +1,74 @@ +/* ************************************************************************ +#module(Tr) +************************************************************************ */ + +/** + * A Tr specific rpc call which works + */ + +qx.Class.define('Tr.Server', { + extend: qx.io.remote.Rpc, + type: "singleton", + + /* + ***************************************************************************** + CONSTRUCTOR + ***************************************************************************** + */ + + /** + * @param local_url {String} When running the application in file:// mode. + * where will we find our RPC server. + */ + construct: function (local_url) { + + with(this){ + base(arguments); + setTimeout(7000000); + setUrl('tr.cgi'); + setServiceName('Tr'); + setCrossDomain(true); + } + + return this; + }, + + /* + ***************************************************************************** + MEMBERS + ***************************************************************************** + */ + + members : + { + + /* + --------------------------------------------------------------------------- + CORE METHODS + --------------------------------------------------------------------------- + */ + + /** + * Tell about the BaseUrl we found. + * + * @type member + * + * @param {void} + * + * @return BaseUrl {Strings} + */ + + getBaseUrl: function(){ + return this.__base_url; + }, + + setLocalUrl: function(local_url){ + if ( document.location.host === '' ) { + with(this){ + setUrl(local_url+'tr.cgi'); + } + } + } + + } +}); diff --git a/qooxdoo/source/class/Tr/ui/ActionButton.js b/qooxdoo/source/class/Tr/ui/ActionButton.js new file mode 100644 index 0000000..a9c60b3 --- /dev/null +++ b/qooxdoo/source/class/Tr/ui/ActionButton.js @@ -0,0 +1,164 @@ +/* ************************************************************************ +#module(Tr) +************************************************************************ */ + +/** + * a widget showing the Tr graph overview + */ + +qx.Class.define('Tr.ui.ActionButton', +{ + extend: qx.ui.layout.HorizontalBoxLayout, + + /* + ***************************************************************************** + CONSTRUCTOR + ***************************************************************************** + */ + + construct: function () { + this.base(arguments); + + this.set({ + height: 'auto', + width: 'auto', + verticalChildrenAlign: 'middle' + }); + var lab1 = new qx.ui.basic.Label(this.tr("Host")); + lab1.set({ + paddingRight: 6 + }); + this.add(lab1); + var host = new qx.ui.form.TextField(); + host.set({ + width: 200, + height: 'auto', + border: 'dark-shadow', + padding: 1 + }); + this.add(host); + this.__host = host; + var lab2 = new qx.ui.basic.Label(this.tr("Delay")); + lab2.set({ + paddingRight: 6, + paddingLeft: 12 + }); + this.add(lab2); + var delay = new qx.ui.form.Spinner(1,5,60); + delay.set({ + border: 'dark-shadow' + }); + this.add(delay); + this.__delay = delay; + + var lab3 = new qx.ui.basic.Label(this.tr("Rounds")); + lab3.set({ + paddingRight: 6, + paddingLeft: 12 + }); + this.add(lab3); + var rounds = new qx.ui.form.Spinner(1,20,200); + rounds.set({ + border: 'dark-shadow' + }); + this.add(rounds); + this.__rounds = rounds; + + var button = new qx.ui.form.Button(''); + this.__button = button; + button.set({ + marginLeft: 10, + width: 50, + height: 'auto', + border: 'dark-shadow', + padding: 2 + }); + this.add(button); + + qx.event.message.Bus.subscribe('tr.status',this.__set_status,this); + qx.event.message.Bus.dispatch('tr.status','stopped'); + + var start_trace = function(event) { + qx.event.message.Bus.dispatch('tr.cmd',{ + action: button.getUserData('action'), + host: host.getValue(), + delay: delay.getValue(), + rounds: rounds.getValue() + }); + }; + + host.addEventListener('keyup',function(e){if(e.keyCode = 13){start_trace()}}); + button.addEventListener('execute', start_trace ); + + var history = qx.client.History.getInstance(); + var history_action = function(event){ + var targ = event.getData(); + host.setValue(targ); + history.addToHistory(targ,'Smokeping Tracerout to '+targ); + start_trace(); + } + history.addEventListener('request', history_action); + + // if we got called with a host on the commandline + var initial_host = qx.client.History.getInstance().getState(); + if (initial_host){ + host.setValue(initial_host); + history.addToHistory(initial_host,'Smokeping Tracerout to '+initial_host); + // dispatch this task once all the initializations are done + qx.client.Timer.once(start_trace,this,0); + } + }, + + members: { + __set_status: function(m){ + var host = this.__host; + var rounds = this.__rounds; + var delay = this.__delay; + with(this.__button){ + // this.debug(m.getData()); + switch(m.getData()){ + case 'starting': + if (getUserData('action') == 'go') { + setLabel(this.tr("Starting")); + setEnabled(false); + host.setEnabled(false); + rounds.setEnabled(false); + delay.setEnabled(false); + } + break; + case 'stopping': + if (getUserData('action') == 'stop') { + setLabel(this.tr("Stopping")); + setEnabled(false); + host.setEnabled(false); + rounds.setEnabled(false); + delay.setEnabled(false); + } + break; + case 'stopped': + setUserData('action','go'); + setLabel(this.tr("Go")); + setEnabled(true); + host.setEnabled(true); + rounds.setEnabled(true); + delay.setEnabled(true); + break; + case 'started': + setUserData('action','stop'); + setLabel(this.tr("Stop")); + setEnabled(true); + host.setEnabled(false); + rounds.setEnabled(false); + delay.setEnabled(false); + break; + default: + alert('Unknown Status Message: '+m.getData()); + } + } + } + } + + +}); + + diff --git a/qooxdoo/source/class/Tr/ui/Cellrenderer.js b/qooxdoo/source/class/Tr/ui/Cellrenderer.js new file mode 100644 index 0000000..f18672d --- /dev/null +++ b/qooxdoo/source/class/Tr/ui/Cellrenderer.js @@ -0,0 +1,46 @@ +/* ************************************************************************ + + Tr Frontend + + Author: + * Tobias Oetiker + +************************************************************************ */ +/* ************************************************************************ +#module(Tr) +************************************************************************ */ + +/** + * A configurable cell renderre + */ + +qx.Class.define('Tr.ui.Cellrenderer', +{ + extend: qx.ui.table.cellrenderer.Number, + /** + * Format a number with a configurable number of fraction digits + * and add optional pre and postfix. + * @param digits {Integer} how many digits should there be. Default is 0. + * @param prefix {String} optional prefix. + * @param postfix {String} optional postfix. + */ + + construct: function (digits,postfix,prefix) { + if (digits == undefined){ + digits = 0; + } + this.base(arguments) + var format = new qx.util.format.NumberFormat(); + format.set({ + maximumFractionDigits: digits, + minimumFractionDigits: digits + }); + if (postfix != undefined){ + format.setPostfix(postfix); + } + if (prefix != undefined){ + format.setPrefix(prefix); + } + this.setNumberFormat(format); + } +}); diff --git a/qooxdoo/source/class/Tr/ui/TraceTable.js b/qooxdoo/source/class/Tr/ui/TraceTable.js new file mode 100644 index 0000000..c25a82e --- /dev/null +++ b/qooxdoo/source/class/Tr/ui/TraceTable.js @@ -0,0 +1,200 @@ +/* ************************************************************************ +#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 [ms]"), 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(); + + tcm.setDataCellRenderer(0, new Tr.ui.Cellrenderer(2)); + 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:"10*"}); + resizeBehavior.set(2, { width:"6*"}); + + for (var i=3;i<10;i++){ + resizeBehavior.set(i, { width:"2*"}); + } + 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]); + }, + __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; + for(var i=0;i value){ + drow[f_best] = value; + } + var worst = drow[f_worst]; + if (worst == undefined || worst < value){ + drow[f_worst] = value; + } + + + if (value != undefined){ + 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,0); + } else + { + for (var i=0;i<10;i++){ + tableModel.setColumnSortable(i,true); + } + qx.event.message.Bus.dispatch('tr.status','stopped'); + self.__handle = undefined; + } + } + else { + alert(exc); + if (self.__handle){ + self.__handle = undefined; + } + for (var i=0;i<10;i++){ + self.__tableModel.setColumnSortable(i,true); + } + qx.event.message.Bus.dispatch('tr.status','stopped'); + } + }; + + var handle_returns = function (data,exc,id){ + if (exc != null){ + alert(exc); + } + }; + + var cmd = m.getData(); + switch(cmd['action']){ + case 'stop': + qx.event.message.Bus.dispatch('tr.status','stopping'); + Tr.Server.getInstance().callAsync(handle_returns,'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']); + } + } + } +}); + + -- cgit v1.2.3-24-g4f1b