Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • opentrafficshaper/opentrafficshaper
  • eezysol/opentrafficshaper
  • sudesh/opentrafficshaper
  • Yuriy/opentrafficshaper
  • nkukard/opentrafficshaper
  • fcardoso/opentrafficshaper
6 results
Show changes
Hide whitespace changes
Inline Side-by-side
Showing
with 2049 additions and 897 deletions
opentrafficshaper/plugins/webserver/pages/static/flot/jquery.flot.selection.min.js
View file @ efc9ebe1
/* Flot plugin for selecting regions of a plot.
Copyright (c) 2007-2013 IOLA and Ole Laursen.
Licensed under the MIT license.
The plugin supports these options:
selection: {
mode: null or "x" or "y" or "xy",
color: color,
shape: "round" or "miter" or "bevel",
minSize: number of pixels
}
Selection support is enabled by setting the mode to one of "x", "y" or "xy".
In "x" mode, the user will only be able to specify the x range, similarly for
"y" mode. For "xy", the selection becomes a rectangle where both ranges can be
specified. "color" is color of the selection (if you need to change the color
later on, you can get to it with plot.getOptions().selection.color). "shape"
is the shape of the corners of the selection.
"minSize" is the minimum size a selection can be in pixels. This value can
be customized to determine the smallest size a selection can be and still
have the selection rectangle be displayed. When customizing this value, the
fact that it refers to pixels, not axis units must be taken into account.
Thus, for example, if there is a bar graph in time mode with BarWidth set to 1
minute, setting "minSize" to 1 will not make the minimum selection size 1
minute, but rather 1 pixel. Note also that setting "minSize" to 0 will prevent
"plotunselected" events from being fired when the user clicks the mouse without
dragging.
When selection support is enabled, a "plotselected" event will be emitted on
the DOM element you passed into the plot function. The event handler gets a
parameter with the ranges selected on the axes, like this:
placeholder.bind( "plotselected", function( event, ranges ) {
alert("You selected " + ranges.xaxis.from + " to " + ranges.xaxis.to)
// similar for yaxis - with multiple axes, the extra ones are in
// x2axis, x3axis, ...
});
The "plotselected" event is only fired when the user has finished making the
selection. A "plotselecting" event is fired during the process with the same
parameters as the "plotselected" event, in case you want to know what's
happening while it's happening,
A "plotunselected" event with no arguments is emitted when the user clicks the
mouse to remove the selection. As stated above, setting "minSize" to 0 will
destroy this behavior.
The plugin allso adds the following methods to the plot object:
- setSelection( ranges, preventEvent )
Set the selection rectangle. The passed in ranges is on the same form as
returned in the "plotselected" event. If the selection mode is "x", you
should put in either an xaxis range, if the mode is "y" you need to put in
an yaxis range and both xaxis and yaxis if the selection mode is "xy", like
this:
setSelection({ xaxis: { from: 0, to: 10 }, yaxis: { from: 40, to: 60 } });
setSelection will trigger the "plotselected" event when called. If you don't
want that to happen, e.g. if you're inside a "plotselected" handler, pass
true as the second parameter. If you are using multiple axes, you can
specify the ranges on any of those, e.g. as x2axis/x3axis/... instead of
xaxis, the plugin picks the first one it sees.
- clearSelection( preventEvent )
Clear the selection rectangle. Pass in true to avoid getting a
"plotunselected" event.
- getSelection()
Returns the current selection in the same format as the "plotselected"
event. If there's currently no selection, the function returns null.
*/(function(e){function t(t){function s(e){n.active&&(h(e),t.getPlaceholder().trigger("plotselecting",[a()]))}function o(t){if(t.which!=1)return;document.body.focus(),document.onselectstart!==undefined&&r.onselectstart==null&&(r.onselectstart=document.onselectstart,document.onselectstart=function(){return!1}),document.ondrag!==undefined&&r.ondrag==null&&(r.ondrag=document.ondrag,document.ondrag=function(){return!1}),c(n.first,t),n.active=!0,i=function(e){u(e)},e(document).one("mouseup",i)}function u(e){return i=null,document.onselectstart!==undefined&&(document.onselectstart=r.onselectstart),document.ondrag!==undefined&&(document.ondrag=r.ondrag),n.active=!1,h(e),m()?f():(t.getPlaceholder().trigger("plotunselected",[]),t.getPlaceholder().trigger("plotselecting",[null])),!1}function a(){if(!m())return null;if(!n.show)return null;var r={},i=n.first,s=n.second;return e.each(t.getAxes(),function(e,t){if(t.used){var n=t.c2p(i[t.direction]),o=t.c2p(s[t.direction]);r[e]={from:Math.min(n,o),to:Math.max(n,o)}}}),r}function f(){var e=a();t.getPlaceholder().trigger("plotselected",[e]),e.xaxis&&e.yaxis&&t.getPlaceholder().trigger("selected",[{x1:e.xaxis.from,y1:e.yaxis.from,x2:e.xaxis.to,y2:e.yaxis.to}])}function l(e,t,n){return t<e?e:t>n?n:t}function c(e,r){var i=t.getOptions(),s=t.getPlaceholder().offset(),o=t.getPlotOffset();e.x=l(0,r.pageX-s.left-o.left,t.width()),e.y=l(0,r.pageY-s.top-o.top,t.height()),i.selection.mode=="y"&&(e.x=e==n.first?0:t.width()),i.selection.mode=="x"&&(e.y=e==n.first?0:t.height())}function h(e){if(e.pageX==null)return;c(n.second,e),m()?(n.show=!0,t.triggerRedrawOverlay()):p(!0)}function p(e){n.show&&(n.show=!1,t.triggerRedrawOverlay(),e||t.getPlaceholder().trigger("plotunselected",[]))}function d(e,n){var r,i,s,o,u=t.getAxes();for(var a in u){r=u[a];if(r.direction==n){o=n+r.n+"axis",!e[o]&&r.n==1&&(o=n+"axis");if(e[o]){i=e[o].from,s=e[o].to;break}}}e[o]||(r=n=="x"?t.getXAxes()[0]:t.getYAxes()[0],i=e[n+"1"],s=e[n+"2"]);if(i!=null&&s!=null&&i>s){var f=i;i=s,s=f}return{from:i,to:s,axis:r}}function v(e,r){var i,s,o=t.getOptions();o.selection.mode=="y"?(n.first.x=0,n.second.x=t.width()):(s=d(e,"x"),n.first.x=s.axis.p2c(s.from),n.second.x=s.axis.p2c(s.to)),o.selection.mode=="x"?(n.first.y=0,n.second.y=t.height()):(s=d(e,"y"),n.first.y=s.axis.p2c(s.from),n.second.y=s.axis.p2c(s.to)),n.show=!0,t.triggerRedrawOverlay(),!r&&m()&&f()}function m(){var e=t.getOptions().selection.minSize;return Math.abs(n.second.x-n.first.x)>=e&&Math.abs(n.second.y-n.first.y)>=e}var n={first:{x:-1,y:-1},second:{x:-1,y:-1},show:!1,active:!1},r={},i=null;t.clearSelection=p,t.setSelection=v,t.getSelection=a,t.hooks.bindEvents.push(function(e,t){var n=e.getOptions();n.selection.mode!=null&&(t.mousemove(s),t.mousedown(o))}),t.hooks.drawOverlay.push(function(t,r){if(n.show&&m()){var i=t.getPlotOffset(),s=t.getOptions();r.save(),r.translate(i.left,i.top);var o=e.color.parse(s.selection.color);r.strokeStyle=o.scale("a",.8).toString(),r.lineWidth=1,r.lineJoin=s.selection.shape,r.fillStyle=o.scale("a",.4).toString();var u=Math.min(n.first.x,n.second.x)+.5,a=Math.min(n.first.y,n.second.y)+.5,f=Math.abs(n.second.x-n.first.x)-1,l=Math.abs(n.second.y-n.first.y)-1;r.fillRect(u,a,f,l),r.strokeRect(u,a,f,l),r.restore()}}),t.hooks.shutdown.push(function(t,n){n.unbind("mousemove",s),n.unbind("mousedown",o),i&&e(document).unbind("mouseup",i)})}e.plot.plugins.push({init:t,options:{selection:{mode:null,color:"#e8cfac",shape:"round",minSize:5}},name:"selection",version:"1.1"})})(jQuery);
\ No newline at end of file
(function($){function init(plot){var selection={first:{x:-1,y:-1},second:{x:-1,y:-1},show:false,active:false};var savedhandlers={};var mouseUpHandler=null;function onMouseMove(e){if(selection.active){updateSelection(e);plot.getPlaceholder().trigger("plotselecting",[getSelection()])}}function onMouseDown(e){if(e.which!=1)return;document.body.focus();if(document.onselectstart!==undefined&&savedhandlers.onselectstart==null){savedhandlers.onselectstart=document.onselectstart;document.onselectstart=function(){return false}}if(document.ondrag!==undefined&&savedhandlers.ondrag==null){savedhandlers.ondrag=document.ondrag;document.ondrag=function(){return false}}setSelectionPos(selection.first,e);selection.active=true;mouseUpHandler=function(e){onMouseUp(e)};$(document).one("mouseup",mouseUpHandler)}function onMouseUp(e){mouseUpHandler=null;if(document.onselectstart!==undefined)document.onselectstart=savedhandlers.onselectstart;if(document.ondrag!==undefined)document.ondrag=savedhandlers.ondrag;selection.active=false;updateSelection(e);if(selectionIsSane())triggerSelectedEvent();else{plot.getPlaceholder().trigger("plotunselected",[]);plot.getPlaceholder().trigger("plotselecting",[null])}return false}function getSelection(){if(!selectionIsSane())return null;if(!selection.show)return null;var r={},c1=selection.first,c2=selection.second;$.each(plot.getAxes(),function(name,axis){if(axis.used){var p1=axis.c2p(c1[axis.direction]),p2=axis.c2p(c2[axis.direction]);r[name]={from:Math.min(p1,p2),to:Math.max(p1,p2)}}});return r}function triggerSelectedEvent(){var r=getSelection();plot.getPlaceholder().trigger("plotselected",[r]);if(r.xaxis&&r.yaxis)plot.getPlaceholder().trigger("selected",[{x1:r.xaxis.from,y1:r.yaxis.from,x2:r.xaxis.to,y2:r.yaxis.to}])}function clamp(min,value,max){return value<min?min:value>max?max:value}function setSelectionPos(pos,e){var o=plot.getOptions();var offset=plot.getPlaceholder().offset();var plotOffset=plot.getPlotOffset();pos.x=clamp(0,e.pageX-offset.left-plotOffset.left,plot.width());pos.y=clamp(0,e.pageY-offset.top-plotOffset.top,plot.height());if(o.selection.mode=="y")pos.x=pos==selection.first?0:plot.width();if(o.selection.mode=="x")pos.y=pos==selection.first?0:plot.height()}function updateSelection(pos){if(pos.pageX==null)return;setSelectionPos(selection.second,pos);if(selectionIsSane()){selection.show=true;plot.triggerRedrawOverlay()}else clearSelection(true)}function clearSelection(preventEvent){if(selection.show){selection.show=false;plot.triggerRedrawOverlay();if(!preventEvent)plot.getPlaceholder().trigger("plotunselected",[])}}function extractRange(ranges,coord){var axis,from,to,key,axes=plot.getAxes();for(var k in axes){axis=axes[k];if(axis.direction==coord){key=coord+axis.n+"axis";if(!ranges[key]&&axis.n==1)key=coord+"axis";if(ranges[key]){from=ranges[key].from;to=ranges[key].to;break}}}if(!ranges[key]){axis=coord=="x"?plot.getXAxes()[0]:plot.getYAxes()[0];from=ranges[coord+"1"];to=ranges[coord+"2"]}if(from!=null&&to!=null&&from>to){var tmp=from;from=to;to=tmp}return{from:from,to:to,axis:axis}}function setSelection(ranges,preventEvent){var axis,range,o=plot.getOptions();if(o.selection.mode=="y"){selection.first.x=0;selection.second.x=plot.width()}else{range=extractRange(ranges,"x");selection.first.x=range.axis.p2c(range.from);selection.second.x=range.axis.p2c(range.to)}if(o.selection.mode=="x"){selection.first.y=0;selection.second.y=plot.height()}else{range=extractRange(ranges,"y");selection.first.y=range.axis.p2c(range.from);selection.second.y=range.axis.p2c(range.to)}selection.show=true;plot.triggerRedrawOverlay();if(!preventEvent&&selectionIsSane())triggerSelectedEvent()}function selectionIsSane(){var minSize=plot.getOptions().selection.minSize;return Math.abs(selection.second.x-selection.first.x)>=minSize&&Math.abs(selection.second.y-selection.first.y)>=minSize}plot.clearSelection=clearSelection;plot.setSelection=setSelection;plot.getSelection=getSelection;plot.hooks.bindEvents.push(function(plot,eventHolder){var o=plot.getOptions();if(o.selection.mode!=null){eventHolder.mousemove(onMouseMove);eventHolder.mousedown(onMouseDown)}});plot.hooks.drawOverlay.push(function(plot,ctx){if(selection.show&&selectionIsSane()){var plotOffset=plot.getPlotOffset();var o=plot.getOptions();ctx.save();ctx.translate(plotOffset.left,plotOffset.top);var c=$.color.parse(o.selection.color);ctx.strokeStyle=c.scale("a",.8).toString();ctx.lineWidth=1;ctx.lineJoin=o.selection.shape;ctx.fillStyle=c.scale("a",.4).toString();var x=Math.min(selection.first.x,selection.second.x)+.5,y=Math.min(selection.first.y,selection.second.y)+.5,w=Math.abs(selection.second.x-selection.first.x)-1,h=Math.abs(selection.second.y-selection.first.y)-1;ctx.fillRect(x,y,w,h);ctx.strokeRect(x,y,w,h);ctx.restore()}});plot.hooks.shutdown.push(function(plot,eventHolder){eventHolder.unbind("mousemove",onMouseMove);eventHolder.unbind("mousedown",onMouseDown);if(mouseUpHandler)$(document).unbind("mouseup",mouseUpHandler)})}$.plot.plugins.push({init:init,options:{selection:{mode:null,color:"#e8cfac",shape:"round",minSize:5}},name:"selection",version:"1.1"})})(jQuery);
\ No newline at end of file
opentrafficshaper/plugins/webserver/pages/static/flot/jquery.flot.stack.min.js
View file @ efc9ebe1
/* Flot plugin for stacking data sets rather than overlyaing them.
Copyright (c) 2007-2013 IOLA and Ole Laursen.
Licensed under the MIT license.
The plugin assumes the data is sorted on x (or y if stacking horizontally).
For line charts, it is assumed that if a line has an undefined gap (from a
null point), then the line above it should have the same gap - insert zeros
instead of "null" if you want another behaviour. This also holds for the start
and end of the chart. Note that stacking a mix of positive and negative values
in most instances doesn't make sense (so it looks weird).
Two or more series are stacked when their "stack" attribute is set to the same
key (which can be any number or string or just "true"). To specify the default
stack, you can set the stack option like this:
series: {
stack: null/false, true, or a key (number/string)
}
You can also specify it for a single series, like this:
$.plot( $("#placeholder"), [{
data: [ ... ],
stack: true
}])
The stacking order is determined by the order of the data series in the array
(later series end up on top of the previous).
Internally, the plugin modifies the datapoints in each series, adding an
offset to the y value. For line series, extra data points are inserted through
interpolation. If there's a second y value, it's also adjusted (e.g for bar
charts or filled areas).
*/(function(e){function n(e){function t(e,t){var n=null;for(var r=0;r<t.length;++r){if(e==t[r])break;t[r].stack==e.stack&&(n=t[r])}return n}function n(e,n,r){if(n.stack==null||n.stack===!1)return;var i=t(n,e.getData());if(!i)return;var s=r.pointsize,o=r.points,u=i.datapoints.pointsize,a=i.datapoints.points,f=[],l,c,h,p,d,v,m=n.lines.show,g=n.bars.horizontal,y=s>2&&(g?r.format[2].x:r.format[2].y),b=m&&n.lines.steps,w=!0,E=g?1:0,S=g?0:1,x=0,T=0,N,C;for(;;){if(x>=o.length)break;N=f.length;if(o[x]==null){for(C=0;C<s;++C)f.push(o[x+C]);x+=s}else if(T>=a.length){if(!m)for(C=0;C<s;++C)f.push(o[x+C]);x+=s}else if(a[T]==null){for(C=0;C<s;++C)f.push(null);w=!0,T+=u}else{l=o[x+E],c=o[x+S],p=a[T+E],d=a[T+S],v=0;if(l==p){for(C=0;C<s;++C)f.push(o[x+C]);f[N+S]+=d,v=d,x+=s,T+=u}else if(l>p){if(m&&x>0&&o[x-s]!=null){h=c+(o[x-s+S]-c)*(p-l)/(o[x-s+E]-l),f.push(p),f.push(h+d);for(C=2;C<s;++C)f.push(o[x+C]);v=d}T+=u}else{if(w&&m){x+=s;continue}for(C=0;C<s;++C)f.push(o[x+C]);m&&T>0&&a[T-u]!=null&&(v=d+(a[T-u+S]-d)*(l-p)/(a[T-u+E]-p)),f[N+S]+=v,x+=s}w=!1,N!=f.length&&y&&(f[N+2]+=v)}if(b&&N!=f.length&&N>0&&f[N]!=null&&f[N]!=f[N-s]&&f[N+1]!=f[N-s+1]){for(C=0;C<s;++C)f[N+s+C]=f[N+C];f[N+1]=f[N-s+1]}}r.points=f}e.hooks.processDatapoints.push(n)}var t={series:{stack:null}};e.plot.plugins.push({init:n,options:t,name:"stack",version:"1.2"})})(jQuery);
\ No newline at end of file
(function($){var options={series:{stack:null}};function init(plot){function findMatchingSeries(s,allseries){var res=null;for(var i=0;i<allseries.length;++i){if(s==allseries[i])break;if(allseries[i].stack==s.stack)res=allseries[i]}return res}function stackData(plot,s,datapoints){if(s.stack==null||s.stack===false)return;var other=findMatchingSeries(s,plot.getData());if(!other)return;var ps=datapoints.pointsize,points=datapoints.points,otherps=other.datapoints.pointsize,otherpoints=other.datapoints.points,newpoints=[],px,py,intery,qx,qy,bottom,withlines=s.lines.show,horizontal=s.bars.horizontal,withbottom=ps>2&&(horizontal?datapoints.format[2].x:datapoints.format[2].y),withsteps=withlines&&s.lines.steps,fromgap=true,keyOffset=horizontal?1:0,accumulateOffset=horizontal?0:1,i=0,j=0,l,m;while(true){if(i>=points.length)break;l=newpoints.length;if(points[i]==null){for(m=0;m<ps;++m)newpoints.push(points[i+m]);i+=ps}else if(j>=otherpoints.length){if(!withlines){for(m=0;m<ps;++m)newpoints.push(points[i+m])}i+=ps}else if(otherpoints[j]==null){for(m=0;m<ps;++m)newpoints.push(null);fromgap=true;j+=otherps}else{px=points[i+keyOffset];py=points[i+accumulateOffset];qx=otherpoints[j+keyOffset];qy=otherpoints[j+accumulateOffset];bottom=0;if(px==qx){for(m=0;m<ps;++m)newpoints.push(points[i+m]);newpoints[l+accumulateOffset]+=qy;bottom=qy;i+=ps;j+=otherps}else if(px>qx){if(withlines&&i>0&&points[i-ps]!=null){intery=py+(points[i-ps+accumulateOffset]-py)*(qx-px)/(points[i-ps+keyOffset]-px);newpoints.push(qx);newpoints.push(intery+qy);for(m=2;m<ps;++m)newpoints.push(points[i+m]);bottom=qy}j+=otherps}else{if(fromgap&&withlines){i+=ps;continue}for(m=0;m<ps;++m)newpoints.push(points[i+m]);if(withlines&&j>0&&otherpoints[j-otherps]!=null)bottom=qy+(otherpoints[j-otherps+accumulateOffset]-qy)*(px-qx)/(otherpoints[j-otherps+keyOffset]-qx);newpoints[l+accumulateOffset]+=bottom;i+=ps}fromgap=false;if(l!=newpoints.length&&withbottom)newpoints[l+2]+=bottom}if(withsteps&&l!=newpoints.length&&l>0&&newpoints[l]!=null&&newpoints[l]!=newpoints[l-ps]&&newpoints[l+1]!=newpoints[l-ps+1]){for(m=0;m<ps;++m)newpoints[l+ps+m]=newpoints[l+m];newpoints[l+1]=newpoints[l-ps+1]}}datapoints.points=newpoints}plot.hooks.processDatapoints.push(stackData)}$.plot.plugins.push({init:init,options:options,name:"stack",version:"1.2"})})(jQuery);
\ No newline at end of file
opentrafficshaper/plugins/webserver/pages/static/flot/jquery.flot.symbol.min.js
View file @ efc9ebe1
/* Flot plugin that adds some extra symbols for plotting points.
Copyright (c) 2007-2013 IOLA and Ole Laursen.
Licensed under the MIT license.
The symbols are accessed as strings through the standard symbol options:
series: {
points: {
symbol: "square" // or "diamond", "triangle", "cross"
}
}
*/(function(e){function t(e,t,n){var r={square:function(e,t,n,r,i){var s=r*Math.sqrt(Math.PI)/2;e.rect(t-s,n-s,s+s,s+s)},diamond:function(e,t,n,r,i){var s=r*Math.sqrt(Math.PI/2);e.moveTo(t-s,n),e.lineTo(t,n-s),e.lineTo(t+s,n),e.lineTo(t,n+s),e.lineTo(t-s,n)},triangle:function(e,t,n,r,i){var s=r*Math.sqrt(2*Math.PI/Math.sin(Math.PI/3)),o=s*Math.sin(Math.PI/3);e.moveTo(t-s/2,n+o/2),e.lineTo(t+s/2,n+o/2),i||(e.lineTo(t,n-o/2),e.lineTo(t-s/2,n+o/2))},cross:function(e,t,n,r,i){var s=r*Math.sqrt(Math.PI)/2;e.moveTo(t-s,n-s),e.lineTo(t+s,n+s),e.moveTo(t-s,n+s),e.lineTo(t+s,n-s)}},i=t.points.symbol;r[i]&&(t.points.symbol=r[i])}function n(e){e.hooks.processDatapoints.push(t)}e.plot.plugins.push({init:n,name:"symbols",version:"1.0"})})(jQuery);
\ No newline at end of file
(function($){function processRawData(plot,series,datapoints){var handlers={square:function(ctx,x,y,radius,shadow){var size=radius*Math.sqrt(Math.PI)/2;ctx.rect(x-size,y-size,size+size,size+size)},diamond:function(ctx,x,y,radius,shadow){var size=radius*Math.sqrt(Math.PI/2);ctx.moveTo(x-size,y);ctx.lineTo(x,y-size);ctx.lineTo(x+size,y);ctx.lineTo(x,y+size);ctx.lineTo(x-size,y)},triangle:function(ctx,x,y,radius,shadow){var size=radius*Math.sqrt(2*Math.PI/Math.sin(Math.PI/3));var height=size*Math.sin(Math.PI/3);ctx.moveTo(x-size/2,y+height/2);ctx.lineTo(x+size/2,y+height/2);if(!shadow){ctx.lineTo(x,y-height/2);ctx.lineTo(x-size/2,y+height/2)}},cross:function(ctx,x,y,radius,shadow){var size=radius*Math.sqrt(Math.PI)/2;ctx.moveTo(x-size,y-size);ctx.lineTo(x+size,y+size);ctx.moveTo(x-size,y+size);ctx.lineTo(x+size,y-size)}};var s=series.points.symbol;if(handlers[s])series.points.symbol=handlers[s]}function init(plot){plot.hooks.processDatapoints.push(processRawData)}$.plot.plugins.push({init:init,name:"symbols",version:"1.0"})})(jQuery);
\ No newline at end of file
opentrafficshaper/plugins/webserver/pages/static/flot/jquery.flot.threshold.min.js
View file @ efc9ebe1
/* Flot plugin for thresholding data.
Copyright (c) 2007-2013 IOLA and Ole Laursen.
Licensed under the MIT license.
The plugin supports these options:
series: {
threshold: {
below: number
color: colorspec
}
}
It can also be applied to a single series, like this:
$.plot( $("#placeholder"), [{
data: [ ... ],
threshold: { ... }
}])
An array can be passed for multiple thresholding, like this:
threshold: [{
below: number1
color: color1
},{
below: number2
color: color2
}]
These multiple threshold objects can be passed in any order since they are
sorted by the processing function.
The data points below "below" are drawn with the specified color. This makes
it easy to mark points below 0, e.g. for budget data.
Internally, the plugin works by splitting the data into two series, above and
below the threshold. The extra series below the threshold will have its label
cleared and the special "originSeries" attribute set to the original series.
You may need to check for this in hover events.
*/(function(e){function n(t){function n(t,n,r,i,s){var o=r.pointsize,u,a,f,l,c,h=e.extend({},n);h.datapoints={points:[],pointsize:o,format:r.format},h.label=null,h.color=s,h.threshold=null,h.originSeries=n,h.data=[];var p=r.points,d=n.lines.show,v=[],m=[],g;for(u=0;u<p.length;u+=o){a=p[u],f=p[u+1],c=l,f<i?l=v:l=m;if(d&&c!=l&&a!=null&&u>0&&p[u-o]!=null){var y=a+(i-f)*(a-p[u-o])/(f-p[u-o+1]);c.push(y),c.push(i);for(g=2;g<o;++g)c.push(p[u+g]);l.push(null),l.push(null);for(g=2;g<o;++g)l.push(p[u+g]);l.push(y),l.push(i);for(g=2;g<o;++g)l.push(p[u+g])}l.push(a),l.push(f);for(g=2;g<o;++g)l.push(p[u+g])}r.points=m,h.datapoints.points=v;if(h.datapoints.points.length>0){var b=e.inArray(n,t.getData());t.getData().splice(b+1,0,h)}}function r(t,r,i){if(!r.threshold)return;r.threshold instanceof Array?(r.threshold.sort(function(e,t){return e.below-t.below}),e(r.threshold).each(function(e,o){n(t,r,i,o.below,o.color)})):n(t,r,i,r.threshold.below,r.threshold.color)}t.hooks.processDatapoints.push(r)}var t={series:{threshold:null}};e.plot.plugins.push({init:n,options:t,name:"threshold",version:"1.2"})})(jQuery);
\ No newline at end of file
(function($){var options={series:{threshold:null}};function init(plot){function thresholdData(plot,s,datapoints,below,color){var ps=datapoints.pointsize,i,x,y,p,prevp,thresholded=$.extend({},s);thresholded.datapoints={points:[],pointsize:ps,format:datapoints.format};thresholded.label=null;thresholded.color=color;thresholded.threshold=null;thresholded.originSeries=s;thresholded.data=[];var origpoints=datapoints.points,addCrossingPoints=s.lines.show;var threspoints=[];var newpoints=[];var m;for(i=0;i<origpoints.length;i+=ps){x=origpoints[i];y=origpoints[i+1];prevp=p;if(y<below)p=threspoints;else p=newpoints;if(addCrossingPoints&&prevp!=p&&x!=null&&i>0&&origpoints[i-ps]!=null){var interx=x+(below-y)*(x-origpoints[i-ps])/(y-origpoints[i-ps+1]);prevp.push(interx);prevp.push(below);for(m=2;m<ps;++m)prevp.push(origpoints[i+m]);p.push(null);p.push(null);for(m=2;m<ps;++m)p.push(origpoints[i+m]);p.push(interx);p.push(below);for(m=2;m<ps;++m)p.push(origpoints[i+m])}p.push(x);p.push(y);for(m=2;m<ps;++m)p.push(origpoints[i+m])}datapoints.points=newpoints;thresholded.datapoints.points=threspoints;if(thresholded.datapoints.points.length>0){var origIndex=$.inArray(s,plot.getData());plot.getData().splice(origIndex+1,0,thresholded)}}function processThresholds(plot,s,datapoints){if(!s.threshold)return;if(s.threshold instanceof Array){s.threshold.sort(function(a,b){return a.below-b.below});$(s.threshold).each(function(i,th){thresholdData(plot,s,datapoints,th.below,th.color)})}else{thresholdData(plot,s,datapoints,s.threshold.below,s.threshold.color)}}plot.hooks.processDatapoints.push(processThresholds)}$.plot.plugins.push({init:init,options:options,name:"threshold",version:"1.2"})})(jQuery);
\ No newline at end of file
opentrafficshaper/plugins/webserver/pages/static/flot/jquery.flot.time.min.js
View file @ efc9ebe1
/* Pretty handling of time axes.
Copyright (c) 2007-2013 IOLA and Ole Laursen.
Licensed under the MIT license.
Set axis.mode to "time" to enable. See the section "Time series data" in
API.txt for details.
*/(function(e){function n(e,t){return t*Math.floor(e/t)}function r(e,t,n,r){if(typeof e.strftime=="function")return e.strftime(t);var i=function(e,t){return e=""+e,t=""+(t==null?"0":t),e.length==1?t+e:e},s=[],o=!1,u=e.getHours(),a=u<12;n==null&&(n=["Jan","Feb","Mar","Apr","May","Jun","Jul","Aug","Sep","Oct","Nov","Dec"]),r==null&&(r=["Sun","Mon","Tue","Wed","Thu","Fri","Sat"]);var f;u>12?f=u-12:u==0?f=12:f=u;for(var l=0;l<t.length;++l){var c=t.charAt(l);if(o){switch(c){case"a":c=""+r[e.getDay()];break;case"b":c=""+n[e.getMonth()];break;case"d":c=i(e.getDate());break;case"e":c=i(e.getDate()," ");break;case"h":case"H":c=i(u);break;case"I":c=i(f);break;case"l":c=i(f," ");break;case"m":c=i(e.getMonth()+1);break;case"M":c=i(e.getMinutes());break;case"q":c=""+(Math.floor(e.getMonth()/3)+1);break;case"S":c=i(e.getSeconds());break;case"y":c=i(e.getFullYear()%100);break;case"Y":c=""+e.getFullYear();break;case"p":c=a?"am":"pm";break;case"P":c=a?"AM":"PM";break;case"w":c=""+e.getDay()}s.push(c),o=!1}else c=="%"?o=!0:s.push(c)}return s.join("")}function i(e){function t(e,t,n,r){e[t]=function(){return n[r].apply(n,arguments)}}var n={date:e};e.strftime!=undefined&&t(n,"strftime",e,"strftime"),t(n,"getTime",e,"getTime"),t(n,"setTime",e,"setTime");var r=["Date","Day","FullYear","Hours","Milliseconds","Minutes","Month","Seconds"];for(var i=0;i<r.length;i++)t(n,"get"+r[i],e,"getUTC"+r[i]),t(n,"set"+r[i],e,"setUTC"+r[i]);return n}function s(e,t){if(t.timezone=="browser")return new Date(e);if(!t.timezone||t.timezone=="utc")return i(new Date(e));if(typeof timezoneJS!="undefined"&&typeof timezoneJS.Date!="undefined"){var n=new timezoneJS.Date;return n.setTimezone(t.timezone),n.setTime(e),n}return i(new Date(e))}function l(t){t.hooks.processOptions.push(function(t,i){e.each(t.getAxes(),function(e,t){var i=t.options;i.mode=="time"&&(t.tickGenerator=function(e){var t=[],r=s(e.min,i),u=0,l=i.tickSize&&i.tickSize[1]==="quarter"||i.minTickSize&&i.minTickSize[1]==="quarter"?f:a;i.minTickSize!=null&&(typeof i.tickSize=="number"?u=i.tickSize:u=i.minTickSize[0]*o[i.minTickSize[1]]);for(var c=0;c<l.length-1;++c)if(e.delta<(l[c][0]*o[l[c][1]]+l[c+1][0]*o[l[c+1][1]])/2&&l[c][0]*o[l[c][1]]>=u)break;var h=l[c][0],p=l[c][1];if(p=="year"){if(i.minTickSize!=null&&i.minTickSize[1]=="year")h=Math.floor(i.minTickSize[0]);else{var d=Math.pow(10,Math.floor(Math.log(e.delta/o.year)/Math.LN10)),v=e.delta/o.year/d;v<1.5?h=1:v<3?h=2:v<7.5?h=5:h=10,h*=d}h<1&&(h=1)}e.tickSize=i.tickSize||[h,p];var m=e.tickSize[0];p=e.tickSize[1];var g=m*o[p];p=="second"?r.setSeconds(n(r.getSeconds(),m)):p=="minute"?r.setMinutes(n(r.getMinutes(),m)):p=="hour"?r.setHours(n(r.getHours(),m)):p=="month"?r.setMonth(n(r.getMonth(),m)):p=="quarter"?r.setMonth(3*n(r.getMonth()/3,m)):p=="year"&&r.setFullYear(n(r.getFullYear(),m)),r.setMilliseconds(0),g>=o.minute&&r.setSeconds(0),g>=o.hour&&r.setMinutes(0),g>=o.day&&r.setHours(0),g>=o.day*4&&r.setDate(1),g>=o.month*2&&r.setMonth(n(r.getMonth(),3)),g>=o.quarter*2&&r.setMonth(n(r.getMonth(),6)),g>=o.year&&r.setMonth(0);var y=0,b=Number.NaN,w;do{w=b,b=r.getTime(),t.push(b);if(p=="month"||p=="quarter")if(m<1){r.setDate(1);var E=r.getTime();r.setMonth(r.getMonth()+(p=="quarter"?3:1));var S=r.getTime();r.setTime(b+y*o.hour+(S-E)*m),y=r.getHours(),r.setHours(0)}else r.setMonth(r.getMonth()+m*(p=="quarter"?3:1));else p=="year"?r.setFullYear(r.getFullYear()+m):r.setTime(b+g)}while(b<e.max&&b!=w);return t},t.tickFormatter=function(e,t){var n=s(e,t.options);if(i.timeformat!=null)return r(n,i.timeformat,i.monthNames,i.dayNames);var u=t.options.tickSize&&t.options.tickSize[1]=="quarter"||t.options.minTickSize&&t.options.minTickSize[1]=="quarter",a=t.tickSize[0]*o[t.tickSize[1]],f=t.max-t.min,l=i.twelveHourClock?" %p":"",c=i.twelveHourClock?"%I":"%H",h;a<o.minute?h=c+":%M:%S"+l:a<o.day?f<2*o.day?h=c+":%M"+l:h="%b %d "+c+":%M"+l:a<o.month?h="%b %d":u&&a<o.quarter||!u&&a<o.year?f<o.year?h="%b":h="%b %Y":u&&a<o.year?f<o.year?h="Q%q":h="Q%q %Y":h="%Y";var p=r(n,h,i.monthNames,i.dayNames);return p})})})}var t={xaxis:{timezone:null,timeformat:null,twelveHourClock:!1,monthNames:null}},o={second:1e3,minute:6e4,hour:36e5,day:864e5,month:2592e6,quarter:7776e6,year:525949.2*60*1e3},u=[[1,"second"],[2,"second"],[5,"second"],[10,"second"],[30,"second"],[1,"minute"],[2,"minute"],[5,"minute"],[10,"minute"],[30,"minute"],[1,"hour"],[2,"hour"],[4,"hour"],[8,"hour"],[12,"hour"],[1,"day"],[2,"day"],[3,"day"],[.25,"month"],[.5,"month"],[1,"month"],[2,"month"]],a=u.concat([[3,"month"],[6,"month"],[1,"year"]]),f=u.concat([[1,"quarter"],[2,"quarter"],[1,"year"]]);e.plot.plugins.push({init:l,options:t,name:"time",version:"1.0"}),e.plot.formatDate=r})(jQuery);
\ No newline at end of file
(function($){var options={xaxis:{timezone:null,timeformat:null,twelveHourClock:false,monthNames:null}};function floorInBase(n,base){return base*Math.floor(n/base)}function formatDate(d,fmt,monthNames,dayNames){if(typeof d.strftime=="function"){return d.strftime(fmt)}var leftPad=function(n,pad){n=""+n;pad=""+(pad==null?"0":pad);return n.length==1?pad+n:n};var r=[];var escape=false;var hours=d.getHours();var isAM=hours<12;if(monthNames==null){monthNames=["Jan","Feb","Mar","Apr","May","Jun","Jul","Aug","Sep","Oct","Nov","Dec"]}if(dayNames==null){dayNames=["Sun","Mon","Tue","Wed","Thu","Fri","Sat"]}var hours12;if(hours>12){hours12=hours-12}else if(hours==0){hours12=12}else{hours12=hours}for(var i=0;i<fmt.length;++i){var c=fmt.charAt(i);if(escape){switch(c){case"a":c=""+dayNames[d.getDay()];break;case"b":c=""+monthNames[d.getMonth()];break;case"d":c=leftPad(d.getDate());break;case"e":c=leftPad(d.getDate()," ");break;case"h":case"H":c=leftPad(hours);break;case"I":c=leftPad(hours12);break;case"l":c=leftPad(hours12," ");break;case"m":c=leftPad(d.getMonth()+1);break;case"M":c=leftPad(d.getMinutes());break;case"q":c=""+(Math.floor(d.getMonth()/3)+1);break;case"S":c=leftPad(d.getSeconds());break;case"y":c=leftPad(d.getFullYear()%100);break;case"Y":c=""+d.getFullYear();break;case"p":c=isAM?""+"am":""+"pm";break;case"P":c=isAM?""+"AM":""+"PM";break;case"w":c=""+d.getDay();break}r.push(c);escape=false}else{if(c=="%"){escape=true}else{r.push(c)}}}return r.join("")}function makeUtcWrapper(d){function addProxyMethod(sourceObj,sourceMethod,targetObj,targetMethod){sourceObj[sourceMethod]=function(){return targetObj[targetMethod].apply(targetObj,arguments)}}var utc={date:d};if(d.strftime!=undefined){addProxyMethod(utc,"strftime",d,"strftime")}addProxyMethod(utc,"getTime",d,"getTime");addProxyMethod(utc,"setTime",d,"setTime");var props=["Date","Day","FullYear","Hours","Milliseconds","Minutes","Month","Seconds"];for(var p=0;p<props.length;p++){addProxyMethod(utc,"get"+props[p],d,"getUTC"+props[p]);addProxyMethod(utc,"set"+props[p],d,"setUTC"+props[p])}return utc}function dateGenerator(ts,opts){if(opts.timezone=="browser"){return new Date(ts)}else if(!opts.timezone||opts.timezone=="utc"){return makeUtcWrapper(new Date(ts))}else if(typeof timezoneJS!="undefined"&&typeof timezoneJS.Date!="undefined"){var d=new timezoneJS.Date;d.setTimezone(opts.timezone);d.setTime(ts);return d}else{return makeUtcWrapper(new Date(ts))}}var timeUnitSize={second:1e3,minute:60*1e3,hour:60*60*1e3,day:24*60*60*1e3,month:30*24*60*60*1e3,quarter:3*30*24*60*60*1e3,year:365.2425*24*60*60*1e3};var baseSpec=[[1,"second"],[2,"second"],[5,"second"],[10,"second"],[30,"second"],[1,"minute"],[2,"minute"],[5,"minute"],[10,"minute"],[30,"minute"],[1,"hour"],[2,"hour"],[4,"hour"],[8,"hour"],[12,"hour"],[1,"day"],[2,"day"],[3,"day"],[.25,"month"],[.5,"month"],[1,"month"],[2,"month"]];var specMonths=baseSpec.concat([[3,"month"],[6,"month"],[1,"year"]]);var specQuarters=baseSpec.concat([[1,"quarter"],[2,"quarter"],[1,"year"]]);function init(plot){plot.hooks.processOptions.push(function(plot,options){$.each(plot.getAxes(),function(axisName,axis){var opts=axis.options;if(opts.mode=="time"){axis.tickGenerator=function(axis){var ticks=[];var d=dateGenerator(axis.min,opts);var minSize=0;var spec=opts.tickSize&&opts.tickSize[1]==="quarter"||opts.minTickSize&&opts.minTickSize[1]==="quarter"?specQuarters:specMonths;if(opts.minTickSize!=null){if(typeof opts.tickSize=="number"){minSize=opts.tickSize}else{minSize=opts.minTickSize[0]*timeUnitSize[opts.minTickSize[1]]}}for(var i=0;i<spec.length-1;++i){if(axis.delta<(spec[i][0]*timeUnitSize[spec[i][1]]+spec[i+1][0]*timeUnitSize[spec[i+1][1]])/2&&spec[i][0]*timeUnitSize[spec[i][1]]>=minSize){break}}var size=spec[i][0];var unit=spec[i][1];if(unit=="year"){if(opts.minTickSize!=null&&opts.minTickSize[1]=="year"){size=Math.floor(opts.minTickSize[0])}else{var magn=Math.pow(10,Math.floor(Math.log(axis.delta/timeUnitSize.year)/Math.LN10));var norm=axis.delta/timeUnitSize.year/magn;if(norm<1.5){size=1}else if(norm<3){size=2}else if(norm<7.5){size=5}else{size=10}size*=magn}if(size<1){size=1}}axis.tickSize=opts.tickSize||[size,unit];var tickSize=axis.tickSize[0];unit=axis.tickSize[1];var step=tickSize*timeUnitSize[unit];if(unit=="second"){d.setSeconds(floorInBase(d.getSeconds(),tickSize))}else if(unit=="minute"){d.setMinutes(floorInBase(d.getMinutes(),tickSize))}else if(unit=="hour"){d.setHours(floorInBase(d.getHours(),tickSize))}else if(unit=="month"){d.setMonth(floorInBase(d.getMonth(),tickSize))}else if(unit=="quarter"){d.setMonth(3*floorInBase(d.getMonth()/3,tickSize))}else if(unit=="year"){d.setFullYear(floorInBase(d.getFullYear(),tickSize))}d.setMilliseconds(0);if(step>=timeUnitSize.minute){d.setSeconds(0)}if(step>=timeUnitSize.hour){d.setMinutes(0)}if(step>=timeUnitSize.day){d.setHours(0)}if(step>=timeUnitSize.day*4){d.setDate(1)}if(step>=timeUnitSize.month*2){d.setMonth(floorInBase(d.getMonth(),3))}if(step>=timeUnitSize.quarter*2){d.setMonth(floorInBase(d.getMonth(),6))}if(step>=timeUnitSize.year){d.setMonth(0)}var carry=0;var v=Number.NaN;var prev;do{prev=v;v=d.getTime();ticks.push(v);if(unit=="month"||unit=="quarter"){if(tickSize<1){d.setDate(1);var start=d.getTime();d.setMonth(d.getMonth()+(unit=="quarter"?3:1));var end=d.getTime();d.setTime(v+carry*timeUnitSize.hour+(end-start)*tickSize);carry=d.getHours();d.setHours(0)}else{d.setMonth(d.getMonth()+tickSize*(unit=="quarter"?3:1))}}else if(unit=="year"){d.setFullYear(d.getFullYear()+tickSize)}else{d.setTime(v+step)}}while(v<axis.max&&v!=prev);return ticks};axis.tickFormatter=function(v,axis){var d=dateGenerator(v,axis.options);if(opts.timeformat!=null){return formatDate(d,opts.timeformat,opts.monthNames,opts.dayNames)}var useQuarters=axis.options.tickSize&&axis.options.tickSize[1]=="quarter"||axis.options.minTickSize&&axis.options.minTickSize[1]=="quarter";var t=axis.tickSize[0]*timeUnitSize[axis.tickSize[1]];var span=axis.max-axis.min;var suffix=opts.twelveHourClock?" %p":"";var hourCode=opts.twelveHourClock?"%I":"%H";var fmt;if(t<timeUnitSize.minute){fmt=hourCode+":%M:%S"+suffix}else if(t<timeUnitSize.day){if(span<2*timeUnitSize.day){fmt=hourCode+":%M"+suffix}else{fmt="%b %d "+hourCode+":%M"+suffix}}else if(t<timeUnitSize.month){fmt="%b %d"}else if(useQuarters&&t<timeUnitSize.quarter||!useQuarters&&t<timeUnitSize.year){if(span<timeUnitSize.year){fmt="%b"}else{fmt="%b %Y"}}else if(useQuarters&&t<timeUnitSize.year){if(span<timeUnitSize.year){fmt="Q%q"}else{fmt="Q%q %Y"}}else{fmt="%Y"}var rt=formatDate(d,fmt,opts.monthNames,opts.dayNames);return rt}}})})}$.plot.plugins.push({init:init,options:options,name:"time",version:"1.0"});$.plot.formatDate=formatDate})(jQuery);
\ No newline at end of file
opentrafficshaper/plugins/webserver/pages/static/js/flot-functions.js 0 → 100644
View file @ efc9ebe1
/*
* Functions to help create flot graphs
* Copyright (c) 2013-2014, AllWorldIT
*
* Permission is hereby granted, free of charge, to any person
* obtaining a copy of this software and associated documentation
* files (the "Software"), to deal in the Software without
* restriction, including without limitation the rights to use,
* copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the
* Software is furnished to do so, subject to the following
* conditions:
*
* The above copyright notice and this permission notice shall be
* included in all copies or substantial portions of the Software.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
* OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
* NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
* HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
* OTHER DEALINGS IN THE SOFTWARE.
*
*/
// Function draw a graph
function awit_flot_draw_graph(options) {
// Setup default graph options
var defaults = {
series: {
lines: {
show: true,
lineWidth: 1,
fill: true,
fillColor: {
colors: [
{ opacity: 0.1 },
{ opacity: 0.13 }
]
}
},
points: {
show: false,
lineWidth: 2,
radius: 3
},
shadowSize: 0,
stack: true
},
grid: {
hoverable: true,
clickable: false,
tickColor: "#F9F9F9",
borderWidth: 1
},
legend: {
labelBoxBorderColor: "#AAAAAA"
},
xaxes: [
{
mode: "time",
tickLength: 10
}
],
yaxes: [
{
position: 'left',
min: 0,
tickFormatter: _flot_format_bandwidth
},
{
position: 'right',
min: 0,
tickDecimals: false
}
]
}
// Merge our options ontop of our defaults
var plotOptions = jQuery.extend({},defaults,options);
// Grab the placeholder
var placeholder = jQuery('#'+plotOptions.id);
// Plot the graph, the [] signifies an empty dataset, the data is populated by awitds
var plot = jQuery.plot(placeholder, [ ], plotOptions);
return plot;
}
// Function draw pie graph
function awit_flot_draw_pie(options) {
// Setup default graph options
var defaults = {
series: {
pie: {
show: true,
radius: 1,
label: {
show: true,
radius: 3/4,
formatter: _flot_format_pie_label,
background: {
opacity: 0.5,
color: '#000000'
}
}
}
}
}
// Merge our options ontop of our defaults
var plotOptions = jQuery.extend({},defaults,options);
// Set count to 1 and override timestamp to 1 for all identifiers
if (typeof(plotOptions.awitds) !== 'undefined') {
for (var tag in plotOptions.awitds.xaxis) {
for (var identifier in plotOptions.awitds.xaxis[tag]) {
plotOptions.awitds.xaxis[tag][identifier].maxCount = 1;
plotOptions.awitds.xaxis[tag][identifier].overrideTimestamp = 1;
}
}
}
// Grab the placeholder
var placeholder = jQuery('#'+plotOptions.id);
// Plot the graph, the [] signifies an empty dataset, the data is populated by awitds
var plot = jQuery.plot(placeholder, [ ], plotOptions);
return plot;
}
// Function to format thousands with , and add Kbps
function _flot_format_bandwidth(value, axis) {
return _flot_format_thousands(value,axis) + ' Kbps';
}
// Function to format thousands
function _flot_format_thousands(value, axis) {
// Convert number to string
value = value.toString();
// Match on 3 digits
var R = new RegExp('(-?[0-9]+)([0-9]{3})');
while(R.test(value)) {
// Replace market with ,
value = value.replace(R, '$1,$2');
}
return value;
}
function _flot_format_pie_label(label, series) {
return "<div style='font-size:8pt; text-align:center; padding:2px; color:white;'>" + label + "<br/>" + Math.round(series.percent) + "%</div>";
}
// vim: ts=4
opentrafficshaper/plugins/webserver/pages/statistics.pm
View file @ efc9ebe1
# OpenTrafficShaper webserver module: users page
# Copyright (C) 2007-2013, AllWorldIT
# OpenTrafficShaper webserver module: statistics page
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
......@@ -32,455 +32,1282 @@ our (@ISA,@EXPORT,@EXPORT_OK);
use DateTime;
use HTML::Entities;
use HTTP::Status qw( :constants );
use HTTP::Status qw(
:constants
);
use JSON;
use URI;
use URI::Escape qw(
uri_escape
);
use awitpt::util qw(
parseURIQuery
isNumber
);
use opentrafficshaper::logger;
use opentrafficshaper::plugins;
use opentrafficshaper::utils qw( parseURIQuery );
use opentrafficshaper::plugins::configmanager qw(
getPoolByName
getInterfaceGroup
getInterfaceGroups
getInterface
use opentrafficshaper::plugins::configmanager qw( getLimit getInterface isTrafficClassValid getTrafficClassName );
getTrafficClass
getAllTrafficClasses
isTrafficClassIDValid
);
use opentrafficshaper::plugins::statistics::statistics;
# Graphs to display on pools stat page
sub POOL_GRAPHS {
{
3600 => 'Last Hour',
86400 => 'Last 24 Hours',
604800 => 'Last 7 Days',
2419200 => 'Last Month'
}
};
# Graphs by limit
sub bylimit
# Graphs by pool
sub byPool
{
my ($kernel,$globals,$client_session_id,$request) = @_;
my ($kernel,$system,$client_session_id,$request) = @_;
# Header
my $content = <<EOF;
<div id="header">
<h2>Limit Stats View</h2>
</div>
my $content = "";
# Check request
if ($request->method ne "GET") {
$content .=<<EOF;
<p class="info text-center">Invalid Method</p>
EOF
goto END;
}
my $limit;
# Parse GET data
my $queryParams = $request->uri->query_form_hash;
# We need our PID
if (!defined($queryParams->{'pool'})) {
$content .=<<EOF;
<p class="info text-center">No "pool" in Query String</p>
EOF
goto END;
}
# Check request
if ($request->method eq "GET") {
# Parse GET data
my $queryParams = parseURIQuery($request);
# We need our LID
if (!defined($queryParams->{'lid'})) {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No LID in Query String</p></td>
</tr>
# Check we have an interface group ID and pool name
my ($interfaceGroupID,$poolName) = split(/:/,$queryParams->{'pool'});
if (!defined($interfaceGroupID) || !defined($poolName)) {
$content .=<<EOF;
<p class="info text-center">Format of "pool" option is invalid, use InterfaceGroupID:PoolName</p>
EOF
goto END;
}
# Check if we get some data back when pulling the limit from the backend
if (!defined($limit = getLimit($queryParams->{'lid'}->{'value'}))) {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No Results</p></td>
</tr>
}
# Check if we get some data back when pulling in the pool from the backend
my $pool;
if (!defined($pool = getPoolByName($interfaceGroupID,$poolName))) {
$content .=<<EOF;
<p class="info text-center">Pool Not Found</p>
EOF
goto END;
}
}
my $name = (defined($limit->{'FriendlyName'}) && $limit->{'FriendlyName'} ne "") ? $limit->{'FriendlyName'} : $limit->{'Username'};
my $usernameEncoded = encode_entities($name);
# Header for the page
$content .= <<EOF;
<legend>
<a href="/limits/pool-list"><span class="glyphicon glyphicon-circle-arrow-left"></span></a>
Pool Stats View
</legend>
EOF
my $timespan = 900;
my $now = time();
my $startTimestamp = $now - $timespan;
# Menu setup
my $menu = [
{
'name' => 'Graphs',
'items' => [
{
'name' => 'Live',
'link' => sprintf("by-pool?pool=%s",uri_escape("$interfaceGroupID:$poolName"))
},
{
'name' => 'Historical',
'link' => sprintf("by-pool?pool=%s&static=1",uri_escape("$interfaceGroupID:$poolName"))
}
]
}
];
my $name = (defined($pool->{'FriendlyName'}) && $pool->{'FriendlyName'} ne "") ? $pool->{'FriendlyName'} :
$pool->{'Name'};
my $nameEncoded = encode_entities($name);
# Build content
$content = <<EOF;
<div id="content" style="float:left">
$content .= <<EOF;
EOF
# Graphs to display
my @graphs = ();
<div style="position: relative; top: 50px;">
<h4 style="color:#8f8f8f;">Latest Data For: $usernameEncoded</h4>
<br/>
# Check if we doing a static display or not
if (defined($queryParams->{'static'}) && $queryParams->{'static'}) {
# Loop with periods to display on this page
foreach my $period (sort { $a <=> $b } keys %{POOL_GRAPHS()}) {
my $canvasName = "flotCanvas$period";
my $graphName = POOL_GRAPHS()->{$period};
<div id="ajaxData" class="ajaxData" style="float:left; width:1024px; height: 610px"></div>
</div>
my $now = time();
my $startTimestamp = $now - $period;
</div>
$content .= <<EOF;
<h4 style="color: #8F8F8F;">Statistics: $nameEncoded - $graphName</h4>
<div id="$canvasName" class="flotCanvas poolCanvas" style="width: 800px; height: 240px" ></div>
EOF
#$content .= statistics::do_test();
# $content .= opentrafficshaper::plugins::statistics::do_test();
# Static graphs
push(@graphs,{
'Type' => 'graph',
'Tag' => $canvasName,
'Title' => sprintf("Pool: %s",$pool->{'Name'}),
'Datasources' => [
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'pool',
'Data' => sprintf('%s:%s',$pool->{'InterfaceGroupID'},$pool->{'Name'}),
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.cir', 'Label' => "TX Cir", 'Timespan' => $period },
{ 'Name' => 'tx.limit', 'Label' => "TX Limit", 'Timespan' => $period },
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => $period },
{ 'Name' => 'rx.cir', 'Label' => "RX Cir", 'Timespan' => $period },
{ 'Name' => 'rx.limit', 'Label' => "RX Limit", 'Timespan' => $period },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => $period }
]
});
}
# Files loaded at end of HTML document
my @javascripts = (
'/static/awit-flot/jquery.flot.min.js',
'/static/awit-flot/jquery.flot.time.min.js',
# '/static/awit-flot/jquery.flot.websockets.js'
);
# Display live graph
} else {
my $canvasName = "flotCanvas";
# Build our data path using the URI module to make sure its nice and clean
my $dataPath = URI->new('/statistics/data-by-limit');
# Pass it the original query, just incase we had extra params we can use
$dataPath->query_form( $request->uri->query_form() );
my $dataPathStr = $dataPath->as_string();
$content .= <<EOF;
<h4 style="color: #8F8F8F;">Live Statistics: $nameEncoded</h4>
<div id="$canvasName" class="flotCanvas poolCanvas" style="width: 1000px; height: 400px" />
EOF
# Live graph
push(@graphs,{
'Type' => 'graph',
'Tag' => $canvasName,
'Title' => sprintf("Pool: %s",$pool->{'Name'}),
'Datasources' => [
{
'Type' => 'websocket',
'Subscriptions' => [
sprintf('pool=%s:%s',$pool->{'InterfaceGroupID'},$pool->{'Name'})
]
},
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'pool',
'Data' => sprintf('%s:%s',$pool->{'InterfaceGroupID'},$pool->{'Name'}),
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.cir', 'Label' => "TX Cir", 'Timespan' => $timespan },
{ 'Name' => 'tx.limit', 'Label' => "TX Limit", 'Timespan' => $timespan },
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => $timespan },
{ 'Name' => 'rx.cir', 'Label' => "RX Cir", 'Timespan' => $timespan },
{ 'Name' => 'rx.limit', 'Label' => "RX Limit", 'Timespan' => $timespan },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => $timespan }
]
});
}
# String put in <script> </script> tags after the above files are loaded
my $javascript = _getJavascript($dataPathStr);
# Build graphs
my $javascript = _buildGraphJavascript(\@graphs);
END:
# Files loaded at end of HTML document
my @javascripts = (
'/static/flot/jquery.flot.min.js',
'/static/flot/jquery.flot.time.min.js',
'/static/flot/jquery.flot.pie.min.js',
'/static/flot/jquery.flot.resize.min.js',
'/static/js/flot-functions.js',
'/static/awit-flot-toolkit/js/jquery.flot.awitds.js',
'/static/awit-flot-toolkit/js/resize.js'
);
my @stylesheets = (
'/static/awit-flot-toolkit/css/awit-flot-toolkit.css'
);
return (HTTP_OK,$content,{ 'javascripts' => \@javascripts, 'javascript' => $javascript });
END:
return (HTTP_OK,$content,{ 'menu' => $menu, 'javascripts' => \@javascripts, 'javascript' => $javascript });
}
# Return data by limit
sub databylimit
# Graphs by class
sub byClass
{
my ($kernel,$globals,$client_session_id,$request) = @_;
my ($kernel,$system,$client_session_id,$request) = @_;
# Parse GET data
my $queryParams = parseURIQuery($request);
# Header
my $content = "";
# Check if the limit ID was passed to us
if (!defined($queryParams->{'lid'})) {
return (HTTP_OK,{ 'error' => 'Invalid lid' },{ 'type' => 'json' });
# Check request
if ($request->method ne "GET") {
$content .=<<EOF;
<p class="info text-center">Invalid Method</p>
EOF
goto END;
}
my $limit;
if (!defined($limit = getLimit($queryParams->{'lid'}->{'value'}))) {
return (HTTP_OK,{ 'error' => 'Invalid limit' },{ 'type' => 'json' });
# Parse GET data
my $queryParams = $request->uri->query_form_hash;
# We need our class definition
if (!defined($queryParams->{'class'})) {
$content .=<<EOF;
<p class="info text-center">No "class" in Query String</p>
EOF
goto END;
}
# Pull in stats data
my $statsData = opentrafficshaper::plugins::statistics::getStatsByLID($queryParams->{'lid'}->{'value'});
# First stage refinement
my $rawData;
foreach my $timestamp (sort keys %{$statsData}) {
foreach my $direction (keys %{$statsData->{$timestamp}}) {
foreach my $stat ('rate','pps','cir','limit') {
push( @{$rawData->{"$direction.$stat"}->{'data'}} , [ $timestamp , $statsData->{$timestamp}->{$direction}->{$stat} ] );
}
# Check we have an interface group ID and traffic class id
my ($interfaceGroupID,$trafficClassID) = split(/:/,$queryParams->{'class'});
if (!defined($interfaceGroupID) || !defined($trafficClassID)) {
$content .=<<EOF;
<p class="info text-center">Format of "class" option is invalid, use InterfaceGroupID:ClassID</p>
EOF
goto END;
}
}
# Check if we get some data back when pulling in the interface group from the backend
my $interfaceGroup;
if (!defined($interfaceGroup = getInterfaceGroup($interfaceGroupID))) {
$content .=<<EOF;
<p class="info text-center">Interface Group Not Found</p>
EOF
goto END;
}
# Second stage - add labels
foreach my $direction ('tx','rx') {
foreach my $stat ('rate','pps','cir','limit') {
# Make it looks nice: Tx Rate
my $label = uc($direction) . " " . ucfirst($stat);
# And set it as the label
$rawData->{"$direction.$stat"}->{'label'} = $label;
}
# Check if we get some data back when pulling in the traffic class from the backend
my $trafficClass;
if (!defined($trafficClass = getTrafficClass($trafficClassID))) {
$content .=<<EOF;
<p class="info text-center">Traffic Class Not Found</p>
EOF
goto END;
}
# Final stage, chop it out how we need it
my $jsonData = [ $rawData->{'tx.limit'}, $rawData->{'rx.limit'}, $rawData->{'tx.rate'} , $rawData->{'rx.rate'} ];
# Header for the page
$content .= <<EOF;
<legend>
<a href="/statistics/igdashboard?interface-group=$interfaceGroupID">
<span class="glyphicon glyphicon-circle-arrow-left"></span>
</a>
Class Stats View
</legend>
EOF
return (HTTP_OK,$jsonData,{ 'type' => 'json' });
}
# Menu setup
my $menu = [
{
'name' => 'Graphs',
'items' => [
{
'name' => 'Live',
'link' => sprintf("by-class?class=%s","$interfaceGroupID:$trafficClassID")
},
{
'name' => 'Historical',
'link' => sprintf("by-class?class=%s&static=1","$interfaceGroupID:$trafficClassID")
}
]
}
];
# Graphs by class
sub byclass
{
my ($kernel,$globals,$client_session_id,$request) = @_;
my $nameEncoded = encode_entities($trafficClass->{'Name'});
# Header
my $content = <<EOF;
<div id="header">
<h2>Class Stats View</h2>
</div>
# Build content
$content .= <<EOF;
EOF
my $interface;
my $cid;
# Graphs to display
my @graphs = ();
# Check if its a GET request...
if ($request->method eq "GET") {
# Parse GET data
my $queryParams = parseURIQuery($request);
# Grab the interface name
if (!defined($queryParams->{'interface'})) {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No interface in Query String</p></td>
</tr>
EOF
goto END;
}
# Grab the class
if (!defined($queryParams->{'class'})) {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No class in Query String</p></td>
</tr>
EOF
goto END;
}
# Check if we get some data back when pulling the interface from the backend
if (!defined($interface = getInterface($queryParams->{'interface'}))) {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No Interface Results</p></td>
</tr>
# Check if we doing a static display or not
if (defined($queryParams->{'static'}) && $queryParams->{'static'}) {
# Loop with periods to display on this page
foreach my $period (sort { $a <=> $b } keys %{POOL_GRAPHS()}) {
my $canvasName = "flotCanvas$period";
my $graphName = POOL_GRAPHS()->{$period};
my $now = time();
my $startTimestamp = $now - $period;
$content .= <<EOF;
<h4 style="color: #8F8F8F;">Class Statistics: $nameEncoded - $graphName</h4>
<div id="$canvasName" class="flotCanvas poolCanvas" style="width: 800px; height: 240px" ></div>
EOF
goto END;
# Static graphs
push(@graphs,{
'Type' => 'graph',
'Tag' => $canvasName,
'Title' => sprintf("Class: %s",$trafficClass->{'Name'}),
'Datasources' => [
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'class',
'Data' => sprintf('%s:%s',$interfaceGroupID,$trafficClassID),
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.cir', 'Label' => "TX Cir", 'Timespan' => $period },
{ 'Name' => 'tx.limit', 'Label' => "TX Limit", 'Timespan' => $period },
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => $period },
{ 'Name' => 'rx.cir', 'Label' => "RX Cir", 'Timespan' => $period },
{ 'Name' => 'rx.limit', 'Label' => "RX Limit", 'Timespan' => $period },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => $period }
]
});
}
# Check if our traffic class is valid
if (!defined($cid = isTrafficClassValid($queryParams->{'class'})) && $queryParams->{'class'} ne "0") {
$content .=<<EOF;
<tr class="info">
<td colspan="8"><p class="text-center">No Class Results</p></td>
</tr>
# Display live graph
} else {
my $canvasName = "flotCanvas";
$content .= <<EOF;
<h4 style="color: #8F8F8F;">Live Statistics: $nameEncoded</h4>
<div id="$canvasName" class="flotCanvas poolCanvas" style="width: 1000px; height: 400px" />
EOF
goto END;
}
# Live graph
push(@graphs,{
'Type' => 'graph',
'Tag' => $canvasName,
'Title' => sprintf("Class: %s",$trafficClass->{'Name'}),
'Datasources' => [
{
'Type' => 'websocket',
'Subscriptions' => [
sprintf('class=%s:%s',$interfaceGroupID,$trafficClassID)
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.cir', 'Label' => "TX Cir", 'Timespan' => 900 },
{ 'Name' => 'tx.limit', 'Label' => "TX Limit", 'Timespan' => 900 },
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => 900 },
{ 'Name' => 'rx.cir', 'Label' => "RX Cir", 'Timespan' => 900 },
{ 'Name' => 'rx.limit', 'Label' => "RX Limit", 'Timespan' => 900 },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => 900 }
]
});
}
my $interfaceNameEncoded = encode_entities($interface->{'name'});
# Build graphs
my $javascript = _buildGraphJavascript(\@graphs);
my $classNameEncoded;
if ($cid) {
$classNameEncoded = encode_entities(getTrafficClassName($cid));
} else {
$classNameEncoded = $interfaceNameEncoded;
}
# Files loaded at end of HTML document
my @javascripts = (
'/static/flot/jquery.flot.min.js',
'/static/flot/jquery.flot.time.min.js',
'/static/flot/jquery.flot.pie.min.js',
'/static/flot/jquery.flot.resize.min.js',
'/static/js/flot-functions.js',
'/static/awit-flot-toolkit/js/jquery.flot.awitds.js',
'/static/awit-flot-toolkit/js/resize.js'
);
my @stylesheets = (
'/static/awit-flot-toolkit/css/awit-flot-toolkit.css'
);
END:
return (HTTP_OK,$content,{ 'menu' => $menu, 'javascripts' => \@javascripts, 'javascript' => $javascript });
}
# Build content
$content = <<EOF;
<div id="content" style="float:left">
<div style="position: relative; top: 50px;">
<h4 style="color:#8f8f8f;">Latest Data For: $classNameEncoded on $interfaceNameEncoded</h4>
<br/>
# Dashboard display
sub dashboard
{
my ($kernel,$system,$client_session_id,$request) = @_;
<div id="ajaxData" class="ajaxData" style="float:left; width:1024px; height: 560px"></div>
</div>
</div>
# Header
my $content = <<EOF;
<legend>
Dashboard View
</legend>
EOF
# Files loaded at end of HTML document
my @javascripts = (
'/static/awit-flot/jquery.flot.min.js',
'/static/awit-flot/jquery.flot.time.min.js',
);
# Build list of graphs for the left hand side
my @interfaceGroups = sort(getInterfaceGroups());
my @trafficClasses = sort(getAllTrafficClasses());
my $timespan = 900;
my $now = time();
my $startTimestamp = $now - $timespan;
my @graphs;
my $graphCounter = 0;
foreach my $interfaceGroupID (@interfaceGroups) {
my $interfaceGroup = getInterfaceGroup($interfaceGroupID);
push(@graphs,{
'.InterfaceGroup' => $interfaceGroup->{'ID'},
'Tag' => sprintf('tag%s',$graphCounter++),
'Type' => 'graph',
'Title' => sprintf("%s: Main",$interfaceGroup->{'Name'}),
'Datasources' => [
{
'Type' => 'websocket',
'Subscriptions' => [
sprintf('interface-group=%s',$interfaceGroupID),
]
},
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'interface-group',
'Data' => $interfaceGroupID,
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => $timespan },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => $timespan }
]
});
}
# Build our data path using the URI module to make sure its nice and clean
my $dataPath = URI->new('/statistics/data-by-class');
# Pass it the original query, just incase we had extra params we can use
$dataPath->query_form( $request->uri->query_form() );
my $dataPathStr = $dataPath->as_string();
foreach my $graph (@graphs) {
my $interfaceGroupEscaped = uri_escape($graph->{'.InterfaceGroup'});
# String put in <script> </script> tags after the above files are loaded
my $javascript = _getJavascript($dataPathStr);
$content .= <<EOF;
<div class="row">
<h4 class="text-center" style="color:#8f8f8f;">$graph->{'Title'}</h4>
<a href="/statistics/igdashboard?interface-group=$interfaceGroupEscaped">
<div id="$graph->{'Tag'}" class="flotCanvas poolCanvas"
style="width: 1000px; height: 250px; margin-left: auto; margin-right: auto;">
</div>
</a>
</div>
EOF
}
# Build graphs
my $javascript = _buildGraphJavascript(\@graphs);
END:
return (HTTP_OK,$content,{ 'javascripts' => \@javascripts, 'javascript' => $javascript });
# Files loaded at end of HTML document
my @javascripts = (
'/static/flot/jquery.flot.min.js',
'/static/flot/jquery.flot.time.min.js',
'/static/flot/jquery.flot.pie.min.js',
'/static/flot/jquery.flot.resize.min.js',
'/static/js/flot-functions.js',
'/static/awit-flot-toolkit/js/jquery.flot.awitds.js',
'/static/awit-flot-toolkit/js/resize.js'
);
my @stylesheets = (
'/static/awit-flot-toolkit/css/awit-flot-toolkit.css'
);
return (HTTP_OK,$content,{
'javascripts' => \@javascripts,
'javascript' => $javascript,
'stylesheets' => \@stylesheets
});
}
# Return data by class
sub databyclass
# Dashboard display for interface groups
sub igdashboard
{
my ($kernel,$globals,$client_session_id,$request) = @_;
my ($kernel,$system,$client_session_id,$request) = @_;
# Parse GET data
my $queryParams = parseURIQuery($request);
# Header
my $content = <<EOF;
<legend>
<a href="/statistics/dashboard"><span class="glyphicon glyphicon-circle-arrow-left"></span></a>
Interface Dashboard View
</legend>
EOF
# Check if the username was passed to us
if (!defined($queryParams->{'interface'})) {
return (HTTP_OK,{ 'error' => 'Missing interface' },{ 'type' => 'json' });
}
if (!defined($queryParams->{'class'})) {
return (HTTP_OK,{ 'error' => 'Missing class' },{ 'type' => 'json' });
# Get query params
my $queryParams = $request->uri->query_form_hash;
# We need our PID
if (!defined($queryParams->{'interface-group'})) {
$content .=<<EOF;
<p class="info text-center">No "interface-group" in Query String</p>
EOF
return (HTTP_TEMPORARY_REDIRECT,"/statistics");
}
if (!defined(my $iface = getInterface($queryParams->{'interface'}))) {
return (HTTP_OK,{ 'error' => 'Invalid interface' },{ 'type' => 'json' });
my $interfaceGroup = getInterfaceGroup($queryParams->{'interface-group'});
if (!defined($interfaceGroup)) {
$content .=<<EOF;
<p class="info text-center">Invalid "interface-group" in Query String</p>
EOF
return (HTTP_TEMPORARY_REDIRECT,"/statistics");
}
if (!defined(my $cid = isTrafficClassValid($queryParams->{'class'})) && $queryParams->{'class'} ne "0") {
return (HTTP_OK,{ 'error' => 'Invalid class' },{ 'type' => 'json' });
# Left and right graphs are added to the main graph list
my @graphs = ();
# Left and right graphs
my @leftGraphs = ();
my @rightGraphs = ();
# Build list of graphs for the left hand side
my @trafficClasses = sort(getAllTrafficClasses());
my $timespan = 900;
my $now = time();
my $startTimestamp = $now - $timespan;
foreach my $trafficClassID (@trafficClasses) {
my $trafficClass = getTrafficClass($trafficClassID);
push(@leftGraphs,{
'Type' => 'graph',
'Title' => sprintf("%s: %s",$interfaceGroup->{'Name'},$trafficClass->{'Name'}),
'.URIData' => sprintf('%s:%s',$interfaceGroup->{'ID'},$trafficClassID),
'Datasources' => [
{
'Type' => 'websocket',
'Subscriptions' => [
sprintf('class=%s:%s',$interfaceGroup->{'ID'},$trafficClassID),
sprintf('counter=configmanager.classpoolmembers.%s',$trafficClassID)
]
},
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'class',
'Data' => sprintf('%s:%s',$interfaceGroup->{'ID'},$trafficClassID),
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
},
{
'Type' => 'ajax',
'Subscriptions' => [
{
'Type' => 'counter',
'Data' => sprintf('configmanager.classpoolmembers.%s',$trafficClassID),
'StartTimestamp' => $startTimestamp,
'EndTimestamp' => $now
}
]
}
],
'XIdentifiers' => [
{ 'Name' => 'tx.cir', 'Label' => "TX Cir", 'Timespan' => $timespan },
{ 'Name' => 'tx.limit', 'Label' => "TX Limit", 'Timespan' => $timespan },
{ 'Name' => 'tx.rate', 'Label' => "TX Rate", 'Timespan' => $timespan },
{ 'Name' => 'rx.cir', 'Label' => "RX Cir", 'Timespan' => $timespan },
{ 'Name' => 'rx.limit', 'Label' => "RX Limit", 'Timespan' => $timespan },
{ 'Name' => 'rx.rate', 'Label' => "RX Rate", 'Timespan' => $timespan }
],
'YIdentifiers' => [
{
'Name' => sprintf('configmanager.classpoolmembers.%s',$trafficClassID),
'Label' => "Pool Count",
'Timespan' => $timespan
},
]
});
}
# Pull in stats data
my $statsData = opentrafficshaper::plugins::statistics::getStatsByClass($queryParams->{'interface'},$queryParams->{'class'});
# Pool distribution
my @dataSubscriptions = ();
my @xidentifiers = ();
foreach my $trafficClassID (@trafficClasses) {
my $trafficClass = getTrafficClass($trafficClassID);
push(@dataSubscriptions,sprintf('counter=configmanager.classpools.%s',$trafficClassID));
push(@xidentifiers,{
'Name' => sprintf('configmanager.classpools.%s',$trafficClassID),
'Label' => $trafficClass->{'Name'}
});
}
push(@rightGraphs,{
'Type' => 'pie',
'Title' => "Pool Distribution",
'Datasources' => [
{
'Type' => 'websocket',
'Subscriptions' => \@dataSubscriptions
}
],
'XIdentifiers' => \@xidentifiers
});
# First stage refinement
my $rawData;
foreach my $timestamp (sort keys %{$statsData}) {
foreach my $direction (keys %{$statsData->{$timestamp}}) {
foreach my $stat ('rate','pps','cir','limit') {
push( @{$rawData->{"$direction.$stat"}->{'data'}} , [ $timestamp , $statsData->{$timestamp}->{$direction}->{$stat} ] );
# Loop while we have graphs to output
my $graphCounter = 0;
while (@leftGraphs || @rightGraphs) {
# Layout Begin
$content .= <<EOF;
<div class="row">
EOF
# LHS - Begin
$content .= <<EOF;
<div class="col-md-8">
EOF
# Loop with 2 sets of normal graphs per row
for (my $row = 0; $row < 2; $row++) {
# LHS - Begin Row
$content .= <<EOF;
<div class="row">
<div class="col-xs-6">
EOF
# Graph 1
if (defined(my $graph = shift(@leftGraphs))) {
my $uriData = $graph->{'.URIData'};
# Assign this graph a tag
$graph->{'Tag'} = "tag".$graphCounter++;
$content .= <<EOF;
<h4 style="color:#8f8f8f;">$graph->{'Title'}</h4>
<a href="/statistics/by-class?class=$uriData">
<div id="$graph->{'Tag'}" class="flotCanvas dashboardCanvas"
style="width: 600px; height: 250px"></div>
</a>
EOF
push(@graphs,$graph);
}
# LHS - Spacer
$content .= <<EOF;
</div>
<div class="col-xs-6">
EOF
# Graph 2
if (defined(my $graph = shift(@leftGraphs))) {
my $uriData = $graph->{'.URIData'};
# Assign this graph a tag
$graph->{'Tag'} = "tag".$graphCounter++;
$content .= <<EOF;
<h4 style="color:#8f8f8f;">$graph->{'Title'}</h4>
<a href="/statistics/by-class?class=$uriData">
<div id="$graph->{'Tag'}" class="flotCanvas dashboardCanvas"
style="width: 600px; height: 250px"></div>
</a>
EOF
push(@graphs,$graph);
}
# LHS - End Row
$content .= <<EOF;
</div>
</div>
EOF
}
# LHS - End
$content .= <<EOF;
</div>
EOF
# RHS - Begin Row
$content .= <<EOF;
<div class="col-md-4">
EOF
# Graph
if (defined(my $graph = shift(@rightGraphs))) {
# Assign this graph a tag
$graph->{'Tag'} = "tag".$graphCounter++;
$content .= <<EOF;
<h4 style="color:#8f8f8f;">$graph->{'Title'}</h4>
<div id="$graph->{'Tag'}" class="flotCanvas dashboardCanvas" style="width: 600px; height: 340px"></div>
EOF
push(@graphs,$graph);
}
# RHS - End Row
$content .= <<EOF;
</div>
EOF
# Layout End
$content .= <<EOF;
</div>
EOF
}
my $jsonData = [ ];
# Second stage - add labels
foreach my $direction ('tx','rx') {
foreach my $stat ('rate','pps','cir','limit') {
# Make it looks nice: Tx Rate
my $label = uc($direction) . " " . ucfirst($stat);
# And set it as the label
$rawData->{"$direction.$stat"}->{'label'} = $label;
}
# Build graphs
my $javascript = _buildGraphJavascript(\@graphs);
# JSON stuff we looking for
foreach my $stat ('limit','rate') {
if (defined($rawData->{"$direction.$stat"}->{'data'})) {
push(@{$jsonData},$rawData->{"$direction.$stat"});
}
}
}
# Files loaded at end of HTML document
my @javascripts = (
'/static/flot/jquery.flot.min.js',
'/static/flot/jquery.flot.time.min.js',
'/static/flot/jquery.flot.pie.min.js',
'/static/flot/jquery.flot.resize.min.js',
'/static/js/flot-functions.js',
'/static/awit-flot-toolkit/js/jquery.flot.awitds.js',
'/static/awit-flot-toolkit/js/resize.js'
);
my @stylesheets = (
'/static/awit-flot-toolkit/css/awit-flot-toolkit.css'
);
END:
return (HTTP_OK,$jsonData,{ 'type' => 'json' });
return (HTTP_OK,$content,{
'javascripts' => \@javascripts,
'javascript' => $javascript,
'stylesheets' => \@stylesheets
});
}
# Return javascript for the graph
sub _getJavascript
# Return data in json format
#
# Supported URLs:
#
# pool=<tag>:<interface-group-id>:<pool-name>
#
# class=<tag>:<interface-group-id>:<class-id>,...
#
# interface-group=<tag>:<interface-group>,...
#
# counter=<tag>:<counter>,...
#
# max=<max number of entries to return, default 100>
#
# key=<data key to return>
sub jsondata
{
my $dataPath = shift;
my $javascript =<<EOF;
// Tooltip - Displays detailed information regarding the data point
function showTooltip(x, y, contents) {
jQuery('<div id="tooltip">' + contents + '</div>').css({
position: 'absolute',
display: 'none',
top: y - 30,
left: x - 50,
color: "#fff",
padding: '2px 5px',
'border-radius': '6px',
'background-color': '#000',
opacity: 0.80
}).appendTo("body").fadeIn(200);
}
my ($kernel,$system,$client_session_id,$request) = @_;
var previousPoint = null;
jQuery("#ajaxData").bind("plothover", function (event, pos, item) {
if (item) {
if (previousPoint != item.dataIndex) {
previousPoint = item.dataIndex;
jQuery("#tooltip").remove();
showTooltip(item.pageX, item.pageY, item.series.label);
}
} else {
jQuery("#tooltip").remove();
previousPoint = null;
# Parse GET data
my $queryParams = $request->uri->query_form_hash;
my $rawData = { };
# Check for some things that apply to all types of data
my $startTimestamp;
my $endTimestamp;
if (defined($queryParams->{'start'})) {
$startTimestamp = isNumber($queryParams->{'start'});
}
if (defined($queryParams->{'end'})) {
$endTimestamp = isNumber($queryParams->{'end'});
}
});
# Process pools
if (defined($queryParams->{'pool'})) {
# Simple de-dupication
my %poolSpecs;
foreach my $poolSpec ($request->uri->query_param('pool')) {
$poolSpecs{$poolSpec} = 1;
}
// Setting up the graph here
options = {
# Then loop through the unique keys
foreach my $poolSpec (keys %poolSpecs) {
# Check we have a tag, interface group ID and pool name
my ($tag,$rawInterfaceGroupID,$rawPoolName) = split(/:/,$poolSpec);
if (!defined($tag)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Invalid format for pool specification '%s'",
$poolSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Invalid format for pool specification '$poolSpec'"},
{ 'type' => 'json' });
}
if (!defined($rawInterfaceGroupID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid interface group ID '%s'",
$tag,
$poolSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has invalid interface group ID '$rawPoolName'"},
{ 'type' => 'json' });
}
# Check if we can grab the interface group
my $interfaceGroup = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroup)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid interface group ID '%s'",
$tag,
$rawInterfaceGroupID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid interface group ID ".
"'$rawInterfaceGroupID'"},
{ 'type' => 'json' });
}
series: {
lines: {
show: true,
lineWidth: 1,
fill: true,
fillColor: {
colors: [
{ opacity: 0.1 },
{ opacity: 0.13 }
]
if (!defined($rawPoolName)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid pool name '%s'",
$tag,
$poolSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid pool name '$rawPoolName'"},
{ 'type' => 'json' });
}
# Grab pool
my $pool = getPoolByName($rawInterfaceGroupID,$rawPoolName);
if (!defined($pool)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid pool name '%s'",
$tag,
$rawPoolName
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid pool name '$rawPoolName'"},
{ 'type' => 'json' });
}
},
points: {
show: false,
lineWidth: 2,
radius: 3
},
# Grab SID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromPID($pool->{'ID'});
if (!defined($sid)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' stats data cannot be found for pool ".
"'%s'",
$tag,
$rawPoolName
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' stats data cannot be found for pool '$rawPoolName'"},
{ 'type' => 'json' });
}
shadowSize: 0,
stack: true
},
# Pull in stats data
my $statsData = opentrafficshaper::plugins::statistics::getStatsBySID($sid,undef,$startTimestamp,$endTimestamp);
# Loop with timestamps
foreach my $timestamp (sort keys %{$statsData}) {
# Grab the stat
my $tstat = $statsData->{$timestamp};
# Loop with its keys
foreach my $item (keys %{$tstat}) {
# Add the keys to the data to return
push(@{$rawData->{$tag}->{$item}->{'data'}},[
$timestamp,
$tstat->{$item}
]);
}
}
}
}
grid: {
hoverable: true,
clickable: false,
tickColor: "#f9f9f9",
borderWidth: 0
},
# Process classes
if (defined($queryParams->{'class'})) {
# Simple de-dupication
my %trafficClassIDSpecs;
foreach my $rawClassID ($request->uri->query_param('class')) {
$trafficClassIDSpecs{$rawClassID} = 1;
}
# Then loop through the unique keys
foreach my $trafficClassIDSpec (keys %trafficClassIDSpecs) {
# Check we have a tag, interface group ID and class
my ($tag,$rawInterfaceGroupID,$rawClassID) = split(/:/,$trafficClassIDSpec);
if (!defined($tag)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Invalid format for class ID specification '%s'",
$trafficClassIDSpec
);
return (HTTP_OK,{
'status' => 'fail',
'message' => "Invalid format for class ID specification '$trafficClassIDSpec'"
},
{ 'type' => 'json' }
);
}
if (!defined($rawInterfaceGroupID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid interface group ID '%s'",
$tag,
$trafficClassIDSpec
);
return (HTTP_OK,{
'status' => 'fail',
'message' => "Tag '$tag' has an invalid interface group ID '$trafficClassIDSpec'"
},
{ 'type' => 'json' }
);
}
if (!defined($rawClassID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid class ID '%s'",
$tag,
$trafficClassIDSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid class ID '$trafficClassIDSpec'"},
{ 'type' => 'json' });
}
legend: {
labelBoxBorderColor: "#fff"
},
# Get more sane values...
my $interfaceGroup = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroup)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has a non-existent interface group ID ".
"'%s'",
$tag,
$rawInterfaceGroupID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has a non-existent interface group ID ".
"'$rawInterfaceGroupID'"},
{ 'type' => 'json' });
}
my $trafficClassID = isTrafficClassIDValid($rawClassID);
if (!defined($trafficClassID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has a non-existent class ID '%s'",
$tag,
$rawClassID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has a non-existent class ID '$rawClassID'"},
{ 'type' => 'json' });
}
xaxis: {
mode: "time",
# Grab data for each direction associated with a class ID on an inteface group
foreach my $direction ('Tx','Rx') {
# Grab stats ID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCID($interfaceGroup->{"${direction}Interface"},
$trafficClassID);
if (!defined($sid)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' stats data cannot be found for ".
"class ID '%s'",
$tag,
$trafficClassID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' stats data cannot be found for class ID "
."'$trafficClassID'"},
{ 'type' => 'json' });
}
# Pull in stats data, override direction used
my $statsData = opentrafficshaper::plugins::statistics::getStatsBySID(
$sid,
{ 'Direction' => lc($direction) },
$startTimestamp,
$endTimestamp
);
# Loop with timestamps
foreach my $timestamp (sort keys %{$statsData}) {
# Grab the stat
my $tstat = $statsData->{$timestamp};
# Loop with its keys
foreach my $item (keys %{$tstat}) {
# Add the keys to the data to return
push(@{$rawData->{$tag}->{$item}->{'data'}},[
$timestamp,
$tstat->{$item}
]);
}
}
}
}
}
tickSize: [60, "second"],
# Process interface groups
if (defined($queryParams->{'interface-group'})) {
# Simple de-dupication
my %interfaceGroupIDSpecs;
foreach my $rawInterfaceGroupID ($request->uri->query_param('interface-group')) {
$interfaceGroupIDSpecs{$rawInterfaceGroupID} = 1;
}
# Then loop through the unique keys
foreach my $interfaceGroupIDSpec (keys %interfaceGroupIDSpecs) {
# Check we have a tag, interface group ID and class
my ($tag,$rawInterfaceGroupID) = split(/:/,$interfaceGroupIDSpec);
if (!defined($tag)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Invalid format for interface group ".
"specification '%s'",
$interfaceGroupIDSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Invalid format for interface group specification ".
"'$interfaceGroupIDSpec'"},
{ 'type' => 'json' });
}
if (!defined($rawInterfaceGroupID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid interface group ID '%s'",
$tag,
$interfaceGroupIDSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid interface group ID ".
"'$interfaceGroupIDSpec'"},
{ 'type' => 'json' });
}
tickFormatter: function (v, axis) {
var date = new Date(v);
my $interfaceGroupID = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroupID)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has a non-existent interface group ID ".
"'%s'",
$tag,
$rawInterfaceGroupID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has a non-existent interface group ID ".
"'$rawInterfaceGroupID'"},
{ 'type' => 'json' });
}
if (date.getSeconds() % 5 == 0) {
var hours = date.getHours() < 10 ? "0" + date.getHours() : date.getHours();
var minutes = date.getMinutes() < 10 ? "0" + date.getMinutes() : date.getMinutes();
var seconds = date.getSeconds() < 10 ? "0" + date.getSeconds() : date.getSeconds();
# Loop with both directions
foreach my $direction ('Tx','Rx') {
# Grab stats ID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCID($interfaceGroupID->{"${direction}Interface"},0);
if (!defined($sid)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' stats data cannot be found for ".
"interface group ID '%s'",
$tag,
$rawInterfaceGroupID
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' stats data cannot be found for interface group ".
"ID '$rawInterfaceGroupID'"},
{ 'type' => 'json' });
}
# Pull in stats data, override direction used
my $statsData = opentrafficshaper::plugins::statistics::getStatsBySID(
$sid,
{ 'Direction' => lc($direction) },
$startTimestamp,
$endTimestamp
);
# Loop with timestamps
foreach my $timestamp (sort keys %{$statsData}) {
# Grab the stat
my $tstat = $statsData->{$timestamp};
# Loop with its keys
foreach my $item (keys %{$tstat}) {
# Add the keys to the data to return
push(@{$rawData->{$tag}->{$item}->{'data'}},[
$timestamp,
$tstat->{$item}
]);
}
}
}
}
}
return hours + ":" + minutes + ":" + seconds;
} else {
return "";
# If we need to return a counter, lets see what there is we can return...
if (defined($queryParams->{'counter'})) {
# Lets get unique counters as keys
my %counterSpecs;
foreach my $rawCounterSpec (@{$queryParams->{'counter'}->{'values'}}) {
$counterSpecs{$rawCounterSpec} = 1;
}
# Then loop through the unique keys
foreach my $counterSpec (keys %counterSpecs) {
# Check we have a tag and counter
my ($tag,$rawCounter) = split(/:/,$counterSpec);
if (!defined($tag)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Invalid format for counter specification '%s'",
$counterSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Invalid format for counter specification '$counterSpec'"},
{ 'type' => 'json' });
}
if (!defined($rawCounter)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has an invalid interface group ID '%s'",
$tag,
$counterSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has an invalid interface group ID ".
"'$counterSpec'"},
{ 'type' => 'json' });
}
},
},
yaxis: {
min: 0,
// max: 4000,
tickFormatter: function (v, axis) {
if (v % 10 == 0) {
res = v.toString().replace(/\\B(?=(\\d{3})+(?!\\d))/g, ",");
console.log(res);
return res + ' Kbps';
} else {
return "";
# Grab the SID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCounter($rawCounter);
if (!defined($sid)) {
$system->{'logger'}->log(LOG_INFO,"[WEBSERVER/PAGES/STATISTICS] Tag '%s' has a non-existent counter '%s'",
$tag,
$counterSpec
);
return (HTTP_OK,{'status' => 'fail', 'message' => "Tag '$tag' has a non-existent counter ".
"'$counterSpec'"},
{ 'type' => 'json' });
}
},
# Pull in stats data
my $statsData = opentrafficshaper::plugins::statistics::getStatsBasicBySID($sid,{ 'Name' => $rawCounter });
# Loop with timestamps
foreach my $timestamp (sort keys %{$statsData}) {
# Grab the stat
my $tstat = $statsData->{$timestamp};
# Loop with its keys
foreach my $item (keys %{$tstat}) {
# Add the keys to the data to return
push(@{$rawData->{$tag}->{$item}->{'data'}},[
$timestamp,
$tstat->{$item}
]);
}
}
}
}
return (HTTP_OK,{'status' => 'success', 'data' => $rawData},{ 'type' => 'json' });
}
// Load data from ajax
jQuery.ajax({
url: '$dataPath',
dataType: 'json',
success: function(statsData) {
plot = null;
// formatting time to match javascript's epoch in milliseconds
for (i = 0; (i < statsData.length); i++) {
//console.log(statsData[i].data);
for (y = 0; (y < statsData[i].data.length); y++) {
d = new Date(statsData[i].data[y][0] * 1000);
statsData[i].data[y][0] = statsData[i].data[y][0] * 1000;
# Function to build the javascript we need to display graphs in a canvas
sub _buildGraphJavascript
{
my $graphs = shift;
my $javascript = "";
foreach my $graph (@{$graphs}) {
my $encodedCanvasName = encode_entities($graph->{'Tag'});
# Items we going to need...
my @datasources = ();
my $axesIdentifiers = { 'X' => [ ], 'Y' => [ ] };
my @axesStrList;
# Loop with and build the JS for our datasources
foreach my $datasource (@{$graph->{'Datasources'}}) {
# Websocket based data
if ($datasource->{'Type'} eq "websocket") {
# Create Subscriptions
my @subscriptions;
foreach my $subscription (@{$datasource->{'Subscriptions'}}) {
my $encodedSubscription = encode_entities($subscription);
push(@subscriptions,"{ 'function': 'subscribe', args: ['$encodedCanvasName','$encodedSubscription'] }");
}
# Create subscription string
my $subscriptionStr = join(',',@subscriptions);
# Add datasource
push(@datasources,<<EOF);
{
type: 'websocket',
uri: 'ws://'+window.location.host+'/statistics/graphdata',
shared: true,
// Websocket specific
onconnect: [
$subscriptionStr
]
}
EOF
# JSON based data
} elsif ($datasource->{'Type'} eq "ajax") {
# Create Subscriptions
my @subscriptions;
foreach my $subscription (@{$datasource->{'Subscriptions'}}) {
my $encodedType = encode_entities($subscription->{'Type'});
my $encodedData = encode_entities($subscription->{'Data'});
# Data we nee dto pull
push(@subscriptions,sprintf(
"%s=%s:%s",
$encodedType,
$encodedCanvasName,
$encodedData
));
# Check if we have a start period
if (defined($subscription->{'StartTimestamp'})) {
push(@subscriptions,sprintf("start=%s",$subscription->{'StartTimestamp'}));
}
# Check if we have an end period
if (defined($subscription->{'EndTimestamp'})) {
push(@subscriptions,sprintf("end=%s",$subscription->{'EndTimestamp'}));
}
}
# Create subscription string
my $subscriptionStr = join('&',@subscriptions);
# Add datasource
push(@datasources,<<EOF);
{
type: 'ajax',
url: '///'+window.location.host+'/statistics/jsondata?$subscriptionStr'
}
EOF
}
}
if (statsData.length > 0) {
plot = jQuery.plot(jQuery("#ajaxData"), statsData, options);
# Loop with axes and build our axes structure
foreach my $axis (keys %{$axesIdentifiers}) {
foreach my $identifier (@{$graph->{"${axis}Identifiers"}}) {
# Our first identifier option is the label
my @options = (
sprintf("label: '%s'", encode_entities($identifier->{'Label'}))
);
# Set limiting factors if there are any
if (defined($identifier->{'Timespan'})) {
push(@options,sprintf("maxTimespan: %s",$identifier->{'Timespan'}));
}
if (defined($identifier->{'Count'})) {
push(@options,sprintf("maxCount: %s",$identifier->{'Count'}));
}
# Join everything up
my $optionsStr = join(' ,',@options);
# Add to axes
push(@{$axesIdentifiers->{$axis}},sprintf("'%s': { %s }",encode_entities($identifier->{'Name'}),$optionsStr));
}
push(@axesStrList,
sprintf("%saxis: { '%s': { %s } }",lc($axis),$encodedCanvasName,join(',',@{$axesIdentifiers->{$axis}}))
);
}
}
});
# Build final JS
my $datasourceStr = join(',',@datasources);
my $axesStr = join(',',@axesStrList);
$javascript .=<<EOF;
awit_flot_draw_$graph->{'Type'}({
id: '$encodedCanvasName',
awitds: {
sources: [
$datasourceStr
],
$axesStr
}
});
EOF
}
return $javascript;
}
1;
# vim: ts=4
opentrafficshaper/plugins/webserver/snapins/websockets/statistics/statistics.pm
View file @ efc9ebe1
# OpenTrafficShaper webserver module: statistics websockets
# Copyright (C) 2007-2013, AllWorldIT
#
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
......@@ -31,16 +31,24 @@ our (@ISA,@EXPORT,@EXPORT_OK);
use DateTime;
use HTML::Entities;
use HTTP::Status qw( :constants );
use JSON;
use POE;
use URI;
use awitpt::util qw(
parseKeyPairString
);
use opentrafficshaper::logger;
use opentrafficshaper::utils;
use opentrafficshaper::plugins::configmanager qw(
getPoolByName
getInterfaceGroup
isTrafficClassIDValid
);
use constant {
VERSION => '0.0.1'
VERSION => '1.0.0'
};
......@@ -48,54 +56,56 @@ use constant {
our $pluginInfo = {
Name => "Webserver/WebSockets/Statistics",
Version => VERSION,
Requires => ["webserver","statistics"],
Init => \&plugin_init,
};
# Copy of system globals
my $globals;
# Logger
my $logger;
# Stats subscriptsions
my $cSubscriptions = {}; # Clients
my $uSubscriptions = {}; # Users
my $subscribers = {}; # Connections subscribed, indexed by client_session_id then ssid
my $subscriberMap = {}; # Index of connections by ssid
# Initialize plugin
sub plugin_init
{
$globals = shift;
my $system = shift;
# Setup our environment
$logger = $globals->{'logger'};
$logger = $system->{'logger'};
$logger->log(LOG_NOTICE,"[WEBSERVER] OpenTrafficShaper Snapin [WebSockets/Statistics] Module v".VERSION." - Copyright (c) 2013, AllWorldIT");
$logger->log(LOG_NOTICE,"[WEBSERVER] OpenTrafficShaper Snapin [WebSockets/Statistics] Module v%s - Copyright (c) 2013-2014".
", AllWorldIT",
VERSION
);
# Protocol conversion
opentrafficshaper::plugins::webserver::snapin_register('HTTP=>WebSocket','statistics','graphdata', {
'requires' => [ 'statistics' ],
'on_request' => \&graphdata_http2websocket,
'on_disconnect' => \&websocket_disconnect,
}
);
# Live graphdata feed
opentrafficshaper::plugins::webserver::snapin_register('WebSocket','statistics','graphdata', {
'requires' => [ 'statistics' ],
'on_request' => \&graphdata_websocket,
'on_request' => \&graphdata_websocket_onrequest,
'on_disconnect' => \&graphdata_websocket_disconnect
}
);
# This is our session handling sending data to connections
POE::Session->create(
inline_states => {
_start => \&session_start,
_stop => \&session_stop,
_start => \&_session_start,
_stop => \&_session_stop,
'websocket.send' => \&do_send,
'websocket.send' => \&_session_websocket_send,
}
);
......@@ -104,10 +114,11 @@ sub plugin_init
# Session initialization
sub session_start
sub _session_start
{
my ($kernel,$heap) = @_[KERNEL,HEAP];
# Set our alias
$kernel->alias_set("plugin.webserver.websockets.statistics");
......@@ -116,17 +127,16 @@ sub session_start
# Session stop
sub session_stop
sub _session_stop
{
my ($kernel,$heap) = @_[KERNEL,HEAP];
# Remove our alias
$kernel->alias_remove("plugin.webserver.websockets.statistics");
# Destroy data
$globals = undef;
$cSubscriptions = {};
$uSubscriptions = {};
$subscribers = {};
$subscriberMap = {};
$logger->log(LOG_DEBUG,"[WEBSERVER] Snapin/WebSockets/Statistics - Shutdown");
......@@ -135,45 +145,63 @@ sub session_stop
# Send data to client
sub do_send
sub _session_websocket_send
{
my ($kernel,$heap,$uid,$data) = @_[KERNEL, HEAP, ARG0, ARG1];
my ($kernel,$heap,$statsData) = @_[KERNEL, HEAP, ARG0, ARG1];
# Loop through subscriptions
foreach my $client_session_id (keys %{$uSubscriptions->{$uid}}) {
my $socket = $uSubscriptions->{$uid}->{$client_session_id};
# Loop with stats data
foreach my $ssid (keys %{$statsData}) {
my $ssidStat = $statsData->{$ssid};
use Data::Dumper; print STDERR "Got request to send client '$client_session_id': ".Dumper($data);
# Check if we know about this SSID
if (!defined($subscriberMap->{$ssid})) {
$logger->log(LOG_ERR,"[WEBSERVER] Snapin/WebSockets/Statistics - Subscription inconsidency with SSID '$ssid'");
next;
}
# my $json = sprintf('{"label": "%s", data: [%s] }', );
# First stage, pull in the data items we want
my $rawData;
# Loop with timestamps
foreach my $timestamp (sort keys %{$ssidStat}) {
# Grab the stat
my $tstat = $ssidStat->{$timestamp};
# Loop with its keys
foreach my $item (keys %{$tstat}) {
# Add the keys to the data to return
push(@{$rawData->{$item}->{'data'}},[
$timestamp,
$tstat->{$item}
]);
}
}
my $socket = $subscriberMap->{$ssid}->{'Socket'};
my $tag = $subscriberMap->{$ssid}->{'Tag'};
$socket->put("hello there");
$socket->put(_json_data({ $tag => $rawData }));
}
}
}
# HTTP to WebSocket
sub websocket_disconnect
sub graphdata_websocket_disconnect
{
my ($kernel,$globals,$client_session_id) = @_;
my $logger = $globals->{'logger'};
$logger->log(LOG_INFO,"[WEBSERVER] Snapin/WebSockets/Statistics - Client '$client_session_id' disconnected");
# Loop with our UID's
foreach my $uid (keys %{$cSubscriptions->{$client_session_id}}) {
# Remove tracking info
delete($uSubscriptions->{$uid}->{$client_session_id});
delete($cSubscriptions->{$client_session_id}->{$uid});
# If there are no more clients for this uid, then unsubscribe it
if (keys %{$uSubscriptions->{$uid}} < 1) {
$kernel->post('statistics' => 'unsubscribe' => 'plugin.webserver.websockets.statistics' => 'websocket.send' => $uid);
}
# Loop with our clients' subscriber ID's
foreach my $ssid (keys %{$subscribers->{$client_session_id}}) {
# And unsubscribe them
opentrafficshaper::plugins::statistics::unsubscribe($ssid);
# Remove the ssid map
delete($subscriberMap->{$ssid});
}
# Remove the client
delete($subscribers->{$client_session_id});
}
......@@ -181,33 +209,282 @@ sub websocket_disconnect
sub graphdata_http2websocket
{
my ($kernel,$globals,$client_session_id,$request,$socket) = @_;
my $logger = $globals->{'logger'};
# Grab the query string
my %queryForm = $request->uri->query_form();
# my %queryForm = $request->uri->query_form();
# Check we have a user ID
if (!defined($queryForm{'uid'})) {
return (HTTP_BAD_REQUEST,"Request not valid","Request does not contain a 'uid' parameter");
}
my $uid = $queryForm{'uid'};
# if (!defined($queryForm{'uid'})) {
# return (HTTP_BAD_REQUEST,"Request not valid","Request does not contain a 'uid' parameter");
# }
# my $uid = $queryForm{'uid'};
$logger->log(LOG_INFO,"[WEBSERVER] Snapin/WebSockets/Statistics - Accepting upgrade of HTTP to WebSocket");
# Subscribe to the stats for this user
if (!defined($uSubscriptions->{$uid}) || !(keys %{$uSubscriptions->{$uid}})) {
$logger->log(LOG_INFO,"[WEBSERVER] Snapin/WebSockets/Statistics - Subscribing to '$uid'");
$kernel->post('statistics' => 'subscribe' => 'plugin.webserver.websockets.statistics' => 'websocket.send' => $uid);
}
# if (!defined($uSubscriptions->{$uid}) || !(keys %{$uSubscriptions->{$uid}})) {
# $logger->log(LOG_INFO,"[WEBSERVER] Snapin/WebSockets/Statistics - Subscribing to '$uid'");
# $kernel->post('statistics' => 'subscribe' => 'plugin.webserver.websockets.statistics' => 'websocket.send' => $uid);
# }
# Setup tracking of our client & user subscriptions
$cSubscriptions->{$client_session_id}->{$uid} = $socket;
$uSubscriptions->{$uid}->{$client_session_id} = $socket;
# $cSubscriptions->{$client_session_id}->{$uid} = $socket;
# $uSubscriptions->{$uid}->{$client_session_id} = $socket;
# And return...
return;
}
# Websocket data handler
sub graphdata_websocket_onrequest
{
my ($kernel,$globals,$client_session_id,$request,$socket) = @_;
my $logger = $globals->{'logger'};
# Parse the command we got...
if ($request->{'function'} eq "subscribe") {
# Grab the first parameter as our tag
my $tag = shift(@{$request->{'args'}});
if (!defined($tag) || ref($tag) ne "") {
return (
opentrafficshaper::plugins::webserver::WS_ERROR,
"The first parameter of 'subscribe' must be a text based tag"
);
}
# Pull off our datasets
my $datasets = { };
foreach my $arg (@{$request->{'args'}}) {
my ($item,$params) = split(/=/,$arg);
push(@{$datasets->{$item}},$params);
}
# Parse dataset data
my @sidList;
if (defined($datasets->{'pool'})) {
# Loop with pool specifications
foreach my $poolSpec (@{$datasets->{'pool'}}) {
# Split interface group id and pool name
my ($rawInterfaceGroupID,$rawPoolName) = split(/:/,$poolSpec);
if (!defined($rawInterfaceGroupID)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for pool has invalid format '$poolSpec'"
);
}
if (!defined($rawPoolName)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for pool has invalid format '$poolSpec'"
);
}
# Check if we can grab the interface group
my $interfaceGroup = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroup)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource has invalid interface group '$rawInterfaceGroupID'"
);
}
# Check if the pool name exists
my $pool = getPoolByName($rawInterfaceGroupID,$rawPoolName);
if (!defined($pool)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource has invalid pool '$rawPoolName'"
);
}
# Check if we have a stats ID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromPID($pool->{'ID'});
if (!defined($sid)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource stats for pool not found '$rawPoolName'"
);
}
# Add SID to SID list that we need to subscribe to
push(@sidList,{'SID' => $sid});
}
}
if (defined($datasets->{'class'})) {
# Loop with class specifications
foreach my $classIDSpec (@{$datasets->{'class'}}) {
# Check we have a tag, interface group ID and class ID
my ($rawInterfaceGroupID,$rawClassID) = split(/:/,$classIDSpec);
if (!defined($rawInterfaceGroupID)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for class has invalid format '$classIDSpec'"
);
}
if (!defined($rawClassID)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for class has invalid format '$classIDSpec'"
);
}
# Get more sane values...
my $interfaceGroup = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroup)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource has invalid interface group '$rawInterfaceGroupID'"
);
}
my $classID = isTrafficClassIDValid($rawClassID);
if (!defined($classID)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource has invalid class '$rawClassID'"
);
}
# Loop with both directions
foreach my $direction ('Tx','Rx') {
my $interfaceDevice = $interfaceGroup->{"${direction}Interface"};
# Grab stats ID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCID($interfaceDevice,$classID);
if (!defined($sid)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource stats for class '$classID' on interface '$interfaceDevice' not found"
);
}
# Add SID to SID list that we need to subscribe to
push(@sidList,{'SID' => $sid, 'Conversions' => { 'Direction' => lc($direction) }});
}
}
}
if (defined($datasets->{'interface-group'})) {
# Loop with interface-group specifications
foreach my $interfaceGroupSpec (@{$datasets->{'interface-group'}}) {
# Check we have a tag, interface group ID and class ID
my ($rawInterfaceGroupID) = split(/:/,$interfaceGroupSpec);
if (!defined($rawInterfaceGroupID)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for interface group has invalid format '$interfaceGroupSpec'"
);
}
# Get more sane values...
my $interfaceGroup = getInterfaceGroup($rawInterfaceGroupID);
if (!defined($interfaceGroup)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource has invalid interface group '$rawInterfaceGroupID'"
);
}
# Loop with both directions
foreach my $direction ('Tx','Rx') {
my $interfaceDevice = $interfaceGroup->{"${direction}Interface"};
# Grab stats ID using a small direction hack
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCID($interfaceDevice,0);
if (!defined($sid)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource stats for interface '$interfaceDevice' not found"
);
}
# Add SID to SID list that we need to subscribe to
push(@sidList,{'SID' => $sid, 'Conversions' => { 'Direction' => lc($direction) }});
}
}
}
if (defined($datasets->{'counter'})) {
# Loop with counter specifications
foreach my $counterSpec (@{$datasets->{'counter'}}) {
# Check we have a tag and counter
my ($rawCounter) = split(/:/,$counterSpec);
if (!defined($rawCounter)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource for counter has invalid format '$counterSpec'"
);
}
# Grab the SID
my $sid = opentrafficshaper::plugins::statistics::getSIDFromCounter($rawCounter);
if (!defined($sid)) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Datasource stats for counter not found '$rawCounter'"
);
}
# Add SID to SID list that we need to subscribe to
push(@sidList,{'SID' => $sid, 'Conversions' => { 'Name' => $rawCounter }});
}
}
# No datasources?
if (!@sidList) {
return (
opentrafficshaper::plugins::webserver::WS_FAIL,
"Failed to identify any subscription requests"
);
}
# Loop wiht subscription list
foreach my $item (@sidList) {
my $ssid = opentrafficshaper::plugins::statistics::subscribe(
$item->{'SID'},
$item->{'Conversions'},
'plugin.webserver.websockets.statistics',
'websocket.send'
);
# Save this client and the streaming id (ssid) we got back
$subscriberMap->{$ssid} = $subscribers->{$client_session_id}->{$ssid} = {
'Tag' => $tag,
'SID' => $item->{'SID'},
'Socket' => $socket
};
}
return (opentrafficshaper::plugins::webserver::WS_OK,"Subscribed");
# No command at all
} else {
return (opentrafficshaper::plugins::webserver::WS_ERROR,"Function '$request->{'function'}' does not exist");
}
return (opentrafficshaper::plugins::webserver::WS_OK,"Function not found");
}
#
# Internal functions
#
# Return a json dataset
sub _json_data
{
my $data = shift;
# Build the structure we're going to encode
my $res;
$res->{'status'} = "success";
$res->{'data'} = $data;
# Use ID of 0 to signify out of band data
$res->{'id'} = -1;
return encode_json($res);
}
1;
# vim: ts=4
opentrafficshaper/plugins/webserver/webserver.pm
View file @ efc9ebe1
# OpenTrafficShaper webserver module
# Copyright (C) 2007-2013, AllWorldIT
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
......@@ -21,17 +21,19 @@ package opentrafficshaper::plugins::webserver;
use strict;
use warnings;
use bytes;
use HTML::Entities;
use HTTP::Response;
use HTTP::Status qw( :constants :is );
use JSON;
use POE qw( Component::Server::TCP );
use POE::Filter::HybridHTTP;
use URI;
use opentrafficshaper::logger;
use opentrafficshaper::plugins;
use opentrafficshaper::POE::Filter::HybridHTTP;
# Pages (this is used a little below)
use opentrafficshaper::plugins::webserver::pages::static;
......@@ -51,7 +53,12 @@ our (@ISA,@EXPORT,@EXPORT_OK);
);
use constant {
VERSION => '0.0.2'
VERSION => '1.0.0',
# WebSocket return status
WS_OK => 0,
WS_ERROR => -1,
WS_FAIL => -2
};
......@@ -65,13 +72,15 @@ our $pluginInfo = {
};
# Copy of system globals
# Our globals
my $globals;
# Copy of system logger
my $logger;
# Client connections open
my $connections = { };
#
# $globals->{'Connections'}
# Web resources
my $resources = {
......@@ -84,16 +93,31 @@ my $resources = {
'_catchall' => \&opentrafficshaper::plugins::webserver::pages::static::_catchall,
},
'limits' => {
'default' => \&opentrafficshaper::plugins::webserver::pages::limits::default,
'limit-add' => \&opentrafficshaper::plugins::webserver::pages::limits::limit_addedit,
'limit-remove' => \&opentrafficshaper::plugins::webserver::pages::limits::limit_remove,
'limit-edit' => \&opentrafficshaper::plugins::webserver::pages::limits::limit_addedit,
'default' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_list,
'pool-list' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_list,
'pool-override-add' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_override_addedit,
'pool-override-list' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_override_list,
'pool-override-remove' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_override_remove,
'pool-override-edit' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_override_addedit,
'pool-add' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_addedit,
'pool-list' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_list,
'pool-remove' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_remove,
'pool-edit' => \&opentrafficshaper::plugins::webserver::pages::limits::pool_addedit,
'poolmember-add' => \&opentrafficshaper::plugins::webserver::pages::limits::poolmember_addedit,
'poolmember-list' => \&opentrafficshaper::plugins::webserver::pages::limits::poolmember_list,
'poolmember-remove' => \&opentrafficshaper::plugins::webserver::pages::limits::poolmember_remove,
'poolmember-edit' => \&opentrafficshaper::plugins::webserver::pages::limits::poolmember_addedit,
'limit-add' => \&opentrafficshaper::plugins::webserver::pages::limits::limit_add
},
'configmanager' => {
'default' => \&opentrafficshaper::plugins::webserver::pages::configmanager::default,
'override-add' => \&opentrafficshaper::plugins::webserver::pages::configmanager::override_addedit,
'override-remove' => \&opentrafficshaper::plugins::webserver::pages::configmanager::override_remove,
'override-edit' => \&opentrafficshaper::plugins::webserver::pages::configmanager::override_addedit,
'admin-config' => \&opentrafficshaper::plugins::webserver::pages::configmanager::admin_config,
},
},
};
......@@ -106,7 +130,7 @@ sub snapin_register
my ($protocol,$module,$action,$data) = @_;
$logger->log(LOG_INFO,"[WEBSERVER] Registered snapin: protocol = $protocol, module = $module, action = $action");
$logger->log(LOG_INFO,"[WEBSERVER] Registered snapin: protocol = %s, module = %s, action = %s",$protocol,$module,$action);
# Load resource
$resources->{$protocol}->{$module}->{$action} = $data;
......@@ -114,26 +138,28 @@ sub snapin_register
# Initialize plugin
sub plugin_init
{
$globals = shift;
my $system = shift;
# Setup our environment
$logger = $globals->{'logger'};
$logger = $system->{'logger'};
$logger->log(LOG_NOTICE,"[WEBSERVER] OpenTrafficShaper Webserver Module v".VERSION." - Copyright (c) 2013, AllWorldIT");
$logger->log(LOG_NOTICE,"[WEBSERVER] OpenTrafficShaper Webserver Module v%s - Copyright (c) 2007-2023, AllWorldIT",VERSION);
# Initialize
$globals->{'Connections'} = { };
# Spawn a web server on port 8088 of all interfaces.
POE::Component::Server::TCP->new(
Port => 8088,
Port => 8080,
# Handle session connections & disconnections
ClientConnected => \&server_client_connected,
ClientDisconnected => \&server_client_disconnected,
# Filter to handle HTTP
ClientFilter => 'POE::Filter::HybridHTTP',
ClientFilter => 'opentrafficshaper::POE::Filter::HybridHTTP',
# Function to handle HTTP requests (as we passing through a filter)
ClientInput => \&server_request,
# Setup the sever
......@@ -146,14 +172,19 @@ sub plugin_init
# Check if we can actually load the pages
eval("use opentrafficshaper::plugins::webserver::pages::statistics");
if ($@) {
$logger->log(LOG_INFO,"[WEBSERVER] Failed to load statistics pages: $@");
$logger->log(LOG_INFO,"[WEBSERVER] Failed to load statistics pages: %s",$@);
exit;
} else {
# Load resources
$resources->{'HTTP'}->{'statistics'} = {
'by-limit' => \&opentrafficshaper::plugins::webserver::pages::statistics::bylimit,
'data-by-limit' => \&opentrafficshaper::plugins::webserver::pages::statistics::databylimit,
'by-class' => \&opentrafficshaper::plugins::webserver::pages::statistics::byclass,
'data-by-class' => \&opentrafficshaper::plugins::webserver::pages::statistics::databyclass,
'by-pool' => \&opentrafficshaper::plugins::webserver::pages::statistics::byPool,
'by-class' => \&opentrafficshaper::plugins::webserver::pages::statistics::byClass,
'jsondata' => \&opentrafficshaper::plugins::webserver::pages::statistics::jsondata,
'dashboard' => \&opentrafficshaper::plugins::webserver::pages::statistics::dashboard,
'igdashboard' => \&opentrafficshaper::plugins::webserver::pages::statistics::igdashboard
};
$logger->log(LOG_INFO,"[WEBSERVER] Loaded statistics pages as statistics module is loaded");
}
......@@ -163,6 +194,7 @@ sub plugin_init
}
# Start the plugin
sub plugin_start
{
......@@ -180,15 +212,20 @@ sub server_session_start
}
# Server session stopped
sub server_session_stop
{
my $kernel = $_[KERNEL];
# Tear down data
$globals = undef;
$logger->log(LOG_DEBUG,"[WEBSERVER] Shutdown");
}
# Signal that the client has connected
sub server_client_connected
{
......@@ -197,40 +234,47 @@ sub server_client_connected
# Save our socket on the client
$connections->{$client_session_id}->{'socket'} = $heap->{'client'};
$connections->{$client_session_id}->{'protocol'} = 'HTTP';
$globals->{'Connections'}->{$client_session_id}->{'Socket'} = $heap->{'client'};
$globals->{'Connections'}->{$client_session_id}->{'Protocol'} = 'HTTP';
}
# Signal that the client has disconnected
sub server_client_disconnected
{
my ($kernel,$heap,$session,$request) = @_[KERNEL, HEAP, SESSION, ARG0];
my $client_session_id = $session->ID;
my $client_session_id = $session->ID;
my $client = $globals->{'Connections'}->{$client_session_id};
# Check if we have a disconnection function to call
if (
defined($connections->{$client_session_id}->{'resource'}) &&
defined($connections->{$client_session_id}->{'resource'}->{'handler'}) &&
ref($connections->{$client_session_id}->{'resource'}->{'handler'}) eq 'HASH' &&
defined($connections->{$client_session_id}->{'resource'}->{'handler'}->{'on_disconnect'})
defined($client->{'Resource'}) &&
defined($client->{'Resource'}->{'Handler'}) &&
ref($client->{'Resource'}->{'Handler'}) eq 'HASH' &&
defined($client->{'Resource'}->{'Handler'}->{'on_disconnect'})
) {
# Call disconnection function
$connections->{$client_session_id}->{'resource'}->{'handler'}->{'on_disconnect'}->($kernel,$globals,$client_session_id);
$client->{'Resource'}->{'Handler'}->{'on_disconnect'}
->($kernel,$globals,$client_session_id);
}
# Remove client session
delete($connections->{$client_session_id});
delete($globals->{'Connections'}->{$client_session_id});
}
# Handle the HTTP request
sub server_request
{
my ($kernel,$heap,$session,$request) = @_[KERNEL, HEAP, SESSION, ARG0];
my $client_session_id = $session->ID;
my $conn = $connections->{$client_session_id};
my $client = $globals->{'Connections'}->{$client_session_id};
# Our response back if one, and if we should just close the connection or not
......@@ -238,7 +282,7 @@ sub server_request
my $closeWhenDone = 0;
# Its HTTP
if ($conn->{'protocol'} eq "HTTP") {
if ($client->{'Protocol'} eq "HTTP") {
# Check the protocol we're currently handling
# We may have a response from the filter indicating an error
if (ref($request) eq "HTTP::Response") {
......@@ -250,18 +294,19 @@ sub server_request
}
# Support for HTTP/1.1 "Connection: close" header...
if ($request->header('Connection') eq "close") {
my $connection = $request->header('Connection');
if (defined($connection) && $connection eq "close") {
$closeWhenDone = 1;
}
# Its a websocket
} elsif ($conn->{'protocol'} eq "WebSocket") {
# XXX - this should call the callback
} elsif ($client->{'Protocol'} eq "WebSocket") {
$response = _server_request_websocket($kernel,$client_session_id,$request);
}
# If there is a response send it
if (defined($response)) {
$conn->{'socket'}->put($response);
$client->{'Socket'}->put($response);
}
# Check if connection must be closed
......@@ -271,6 +316,7 @@ sub server_request
}
# Display fault
sub httpDisplayFault
{
......@@ -301,6 +347,7 @@ EOF
}
# Do a redirect
sub httpRedirect
{
......@@ -310,6 +357,7 @@ sub httpRedirect
}
# Create a response object
sub httpCreateResponse
{
......@@ -330,43 +378,77 @@ sub httpCreateResponse
# Set header
$headers->content_type("text/html");
# Bootstrap stuff
my $mainCols = 12;
# Check if we have a menu structure, if we do, display the sidebar
my $styleStr = "";
my $menuStr = "";
my $stylesheetsStr = "";
my $stylesheetStr = "";
my $javascriptStr = "";
if (defined($options)) {
# Check if style snippet exists
if (defined(my $style = $options->{'style'})) {
$styleStr .= $style;
}
my $versionStr = VERSION;
if (defined($options)) {
# Check if menu exists
if (my $menu = $options->{'menu'}) {
$menuStr =<<EOF;
<ul class="nav nav-pills nav-stacked">
<div class="col-md-2">
<ul class="nav nav-pills nav-stacked">
EOF
# Loop with sub menu sections
foreach my $section (keys %{$menu}) {
$menuStr .=<<EOF;
<li class="nav-header">$section</li>
my @menuItems = ();
foreach my $section (@{$menu}) {
my $menuItem = "";
my $sectionName = encode_entities($section->{'name'});
$menuItem .=<<EOF;
<li class="active text-center"><a href="#">$sectionName</a></li>
EOF
# Loop with menu items
foreach my $item (keys %{$menu->{$section}}) {
my $link = "/" . $module . "/" . $menu->{$section}->{$item};
# Sanitize slightly
$link =~ s,/+$,,;
foreach my $item (@{$section->{'items'}}) {
my $itemName = encode_entities($item->{'name'});
# Sanitize link
my $itemLink = "/" . $module . "/" . $item->{'link'};
$itemLink =~ s,/+$,,;
# Build sections
$menuStr .=<<EOF;
<li><a href="$link">$item</a></li>
$menuItem .=<<EOF;
<li class="text-center"><a href="$itemLink">$itemName</a></li>
EOF
}
# Add menu item
push(@menuItems,$menuItem);
}
# Join menu items
$menuStr .= join(<<EOF,@menuItems);
<hr />
EOF
$menuStr .=<<EOF;
</ul>
</ul>
</div>
EOF
# Reduce number of main cols to make way for menu
$mainCols = 10;
}
# Check if we have a list of style assets
if (defined(my $stylesheets = $options->{'stylesheets'})) {
foreach my $script (@{$stylesheets}) {
$stylesheetsStr .=<<EOF;
<link href="$script" rel="stylesheet"></script>
EOF
}
}
# Check if stylesheet snippet exists
if (defined(my $stylesheet = $options->{'stylesheet'})) {
$stylesheetStr .=<<EOF;
$stylesheet
EOF
}
# Check if we have a list of javascript assets
if (defined(my $javascripts = $options->{'javascripts'})) {
foreach my $script (@{$javascripts}) {
......@@ -388,31 +470,33 @@ EOF
# Create the payload we returning
$payload = <<EOF;
<!DOCTYPE html>
<html>
<head>
<title>OpenTrafficShaper - Enterprise Traffic Shaper</title>
<!-- Meta -->
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<!-- Assets -->
<link href="/static/favicon.ico" rel="icon" />
<link href="/static/jquery-ui/css/ui-lightness/jquery-ui.min.css" rel="stylesheet">
<link href="/static/bootstrap/css/bootstrap.min.css" rel="stylesheet">
<link href="/static/jquery-ui/css/ui-lightness/jquery-ui.min.css" rel="stylesheet" />
<link href="/static/bootstrap/css/bootstrap.min.css" rel="stylesheet" />
$stylesheetsStr
<style type="text/css">
body {
padding-top: 50px;
}
.main-area {
padding-top: 15px;
padding-bottom: 15px;
}
$styleStr
$stylesheetStr
</style>
<!-- End Assets -->
</head>
<body>
<div class="navbar navbar-inverse navbar-fixed-top">
<a class="navbar-brand" href="/"><img src="/static/logo-inverted-short.png" alt="Open Traffic Shaper" width="100%" height="auto" /></a>
<a class="navbar-brand" href="/">
<img src="/static/logo-inverted-short.png" alt="Open Traffic Shaper" width="100%" height="auto" />
</a>
<div class="container">
<div class="navbar-header">
<button type="button" class="navbar-toggle" data-toggle="collapse" data-target=".navbar-collapse">
......@@ -423,7 +507,7 @@ $styleStr
</div>
<div class="collapse navbar-collapse">
<ul class="nav navbar-nav">
<li class="active"><a href="#">Home</a></li>
<li class="active"><a href="/">Home</a></li>
<li><a href="/limits">Limits</a></li>
<li><a href="/configmanager">ConfigManager</a></li>
</ul>
......@@ -431,20 +515,22 @@ $styleStr
</div>
</div>
<div class="main-area container">
<div class="col-md-2">
<div style="padding: 15px 15px">
<div class="row">
$menuStr
</div>
<div class="col-md-10">
<div class="col-md-$mainCols">
$content
</div>
</div>
<hr>
</div>
<div style="padding: 0 15px">
<hr />
<footer>
<p class="muted">v$globals->{'version'} - Copyright &copy; 2013, <a href="http://www.allworldit.com">AllWorldIT</a></p>
<p class="muted">
v$versionStr - Copyright &copy; 2007-2023, <a href="http://www.allworldit.com">AllWorldIT</a>
</p>
</footer>
</div>
</body>
......@@ -483,9 +569,10 @@ EOF
sub _server_request_http
{
my ($kernel,$client_session_id,$request) = @_;
my $conn = $connections->{$client_session_id};
my $conn = $globals->{'Connections'}->{$client_session_id};
my $protocol = "HTTP"; # By default we're HTTP
# Pull off connection attributes
......@@ -538,19 +625,23 @@ sub _server_request_http
return httpDisplayFault(HTTP_INTERNAL_SERVER_ERROR,"Internal server error","Server configuration error");
}
$logger->log(LOG_DEBUG,"[WEBSERVER] Parsed HTTP request into: module='$module', action='$action'");
$logger->log(LOG_DEBUG,"[WEBSERVER] Parsed HTTP request into: module='%s', action='%s'",$module,$action);
# Save what resource we just accessed
$connections->{$client_session_id}->{'resource'} = {
'module' => $module,
'action' => $action,
'handler' => $handler,
$globals->{'Connections'}->{$client_session_id}->{'Resource'} = {
'Module' => $module,
'Action' => $action,
'Handler' => $handler,
};
my $system = {
'logger' => $logger
};
# This is normal HTTP request
if ($protocol eq "HTTP") {
# Do the function call now
my ($res,$content,$extra) = $function->($kernel,$globals,$client_session_id,$request);
my ($res,$content,$extra) = $function->($kernel,$system,$client_session_id,$request);
# Module return undef if they don't want to handle the request
......@@ -573,29 +664,134 @@ sub _server_request_http
# Its a websocket upgrade request
} elsif ($protocol eq "HTTP=>WebSocket") {
# Do the function call now
my ($res,$ret1,$ret2) = $function->($kernel,$globals,$client_session_id,$request,$conn->{'socket'});
# Make sure we have an upgrade path to WebSocket
my ($newHandler) = _parse_http_resource($request,"WebSocket");
if (!defined($newHandler)) {
return httpDisplayFault(HTTP_INTERNAL_SERVER_ERROR,"Internal server error","Cannot upgrade to websocket");
}
# Do the function call now
my ($res,$ret1,$ret2) = $function->($kernel,$globals,$client_session_id,$request,$conn->{'Socket'});
# If we have a response defined, we rejected the upgrade
if (defined($res)) {
$response = httpDisplayFault($res,$ret1,$ret2);
} else {
# Return our upgrade response
$response = _server_request_http_wsupgrade($request,$module,$action);
# Upgrade the protocol
$connections->{$client_session_id}->{'protocol'} = 'WebSocket';
# Upgrade the protocol & handler
$globals->{'Connections'}->{$client_session_id}->{'Protocol'} = 'WebSocket';
$globals->{'Connections'}->{$client_session_id}->{'Resource'}->{'Handler'} = $newHandler;
}
}
END:
$logger->log(LOG_INFO,"[WEBSERVER] $protocol Request: ".$response->code." [$module/$action] - ".encode_entities($request->method)." ".
encode_entities($request->uri)." ".encode_entities($request->protocol));
$logger->log(LOG_INFO,"[WEBSERVER] %s Request: %s [%s/%s] - %s %s %s",
$protocol,
$response->code,
$module,
$action,
encode_entities($request->method),
encode_entities($request->uri),
encode_entities($request->protocol)
);
return $response;
}
# Handle the websocket request
sub _server_request_websocket
{
my ($kernel,$client_session_id,$rawRequest) = @_;
my $conn = $globals->{'Connections'}->{$client_session_id};
my $handler = $conn->{'Resource'}->{'Handler'};
# Function we need to call
my $function = $handler;
# Check if we're a hash... override if we are
if (ref($handler) eq "HASH") {
$function = $handler->{'on_request'};
}
# If its something else, blow up
if (ref($function) ne "CODE") {
$logger->log(LOG_ERR,"[WEBSERVER] No 'on_request' handler for websocket");
return encode_json({'status' => "error", 'message' => "Internal server error"});
}
# Safely decode JSON
my $request;
eval { $request = decode_json($rawRequest); };
if ($@) {
# FIXME: NOTICE: Failed to decode JSON request '&#3;&#xFFFD; , may be disconnect from websocket?
$logger->log(LOG_NOTICE,"[WEBSERVER] Failed to decode JSON request '%s'",encode_entities($rawRequest));
return encode_json({'status' => "error", 'message' => "Failed to decode JSON"});
}
# Save the command id
my $rCode = $request->{'id'};
# Check the function and args are present
if (!defined($request->{'function'}) || !defined($request->{'args'})) {
return encode_json({
'status' => "error",
'message' => "Invalid format for JSON request, must have 'function' and 'args' properties"
});
}
# Check function is a string
if (!(ref($request->{'function'}) eq "" && length($request->{'function'}) > 0)) {
return encode_json({
'status' => "error",
'message' => "The 'function' property must contain a function name"
});
}
# And the args is an array ref
if (!ref($request->{'args'}) eq "ARRAY") {
return encode_json({
'status' => "error",
'message' => "The 'args' property must contain an array of arguments"
});
}
# Do the function call now
my ($res,$content,$extra) = $function->($kernel,$globals,$client_session_id,$request,$conn->{'Socket'});
$logger->log(LOG_INFO,"[WEBSERVER] %s Request [%s/%s]",
$conn->{'Protocol'},
$conn->{'Resource'}->{'Module'},
$conn->{'Resource'}->{'Action'},
);
# Check if its a success or failure
my $ret;
if ($res == WS_OK) {
$ret->{'status'} = "success";
$ret->{'data'} = $content;
} elsif ($res == WS_ERROR) {
$ret->{'status'} = "error";
$ret->{'message'} = $content;
} elsif ($res == WS_FAIL) {
$ret->{'status'} = "fail";
$ret->{'message'} = $content;
} else {
$ret->{'status'} = "error";
$ret->{'message'} = "Internal server error";
}
# Add ID if we have one
if (defined($request->{'id'})) {
$ret->{'id'} = $request->{'id'};
}
return encode_json($ret);
}
# Function to parse a HTTP resource
sub _parse_http_resource
{
......@@ -646,7 +842,8 @@ sub _parse_http_resource
if (defined($handler->{'requires'})) {
foreach my $require (@{$handler->{'requires'}}) {
if (!isPluginLoaded($require)) {
return httpDisplayFault(HTTP_NOT_IMPLEMENTED,"Method Not Available","The requested method '$action' in '$module' is not currently available");
return httpDisplayFault(HTTP_NOT_IMPLEMENTED,"Method Not Available","The requested method '$action' in ".
"'$module' is not currently available");
}
}
}
......@@ -656,6 +853,7 @@ sub _parse_http_resource
}
# Handle Websocket
sub _server_request_http_wsupgrade
{
......@@ -676,8 +874,14 @@ sub _server_request_http_wsupgrade
$headers
);
$logger->log(LOG_INFO,"[WEBSERVER] WebSocket Upgrade: ".$response->code." [$module/$action] - ".encode_entities($request->method)." ".
encode_entities($request->uri)." ".encode_entities($request->protocol));
$logger->log(LOG_INFO,"[WEBSERVER] WebSocket Upgrade: %s [%s/%s] - %s %s %s",
$response->code,
$module,
$action,
encode_entities($request->method),
encode_entities($request->uri),
encode_entities($request->protocol)
);
return $response;
}
......
opentrafficshaper/util.pm 0 → 100644
View file @ efc9ebe1
# OpenTrafficShaper utility functions
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
package opentrafficshaper::util;
use strict;
use warnings;
# Exporter stuff
require Exporter;
our (@ISA,@EXPORT,@EXPORT_OK);
@ISA = qw(Exporter);
@EXPORT = qw(
isIPv46
isIPv46CIDR
);
@EXPORT_OK = qw(
);
# Check if this is a valid IPv4 or IPv6 address
sub isIPv46
{
my ($rawIP) = @_;
my $ip = NetAddr::IP->new($rawIP);
if (!defined($ip)) {
return;
}
if ($ip->version == 4) {
if ($ip->masklen != 32) {
return;
}
return $ip->addr;
} elsif ($ip->version == 6) {
if ($ip->masklen != 128) {
return;
}
return $ip->short;
}
return;
}
# Check if this is a valid IPv4 or IPv6 CIDR
sub isIPv46CIDR
{
my ($rawIP) = @_;
my $ip = NetAddr::IP->new($rawIP);
if (!defined($ip)) {
return;
}
if ($ip->version() == 4) {
return $ip->network()->addr() . "/" . $ip->masklen();
} elsif ($ip->version == 6) {
return $ip->network()->short() . "/" . $ip->masklen();
}
return;
}
1;
\ No newline at end of file
opentrafficshaper/utils.pm deleted 100644 → 0
View file @ db2fde2f
# Utility functions
# Copyright (C) 2013, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
package opentrafficshaper::utils;
use strict;
use warnings;
# Exporter stuff
require Exporter;
our (@ISA,@EXPORT,@EXPORT_OK);
@ISA = qw(Exporter);
@EXPORT = qw(
prettyUndef
toHex
isVariable
isUsername
isIP
isNumber
booleanize
);
@EXPORT_OK = qw(
parseFormContent
parseURIQuery
);
# Print a undef in a pretty fashion
sub prettyUndef
{
my $var = shift;
if (!defined($var)) {
return "-undef-";
} else {
return $var;
}
}
# Return hex representation of a decimal
sub toHex
{
my $decimal = shift;
return sprintf('%x',$decimal);
}
# Parse form post data from HTTP content
sub parseFormContent
{
my $data = shift;
my %res;
# Split information into name/value pairs
my @pairs = split(/&/, $data);
foreach my $pair (@pairs) {
my ($name, $value) = split(/=/, $pair);
$value =~ tr/+/ /;
$value =~ s/%(..)/pack("C", hex($1))/eg;
$res{$name} = $value;
}
return \%res;
}
# Parse query data
sub parseURIQuery
{
my $request = shift;
my %res;
# Grab URI components
my @components = $request->uri->query_form;
# Loop with the components in sets of name & value
while (@components) {
my ($name,$value) = (shift(@components),shift(@components));
# Store values and the last value we go
push(@{$res{$name}->{'values'}},$value);
$res{$name}->{'value'} = $value;
}
return \%res;
}
# Check if variable is normal
sub isVariable
{
my $var = shift;
# A variable cannot be undef?
if (!defined($var)) {
return undef;
}
return (ref($var) eq "");
}
# Check if variable is a username
sub isUsername
{
my $var = shift;
# Make sure we're not a ref
if (!isVariable($var)) {
return undef;
}
# Lowercase it
$var = lc($var);
# Normal username
if ($var =~ /^[a-z0-9_\-\.]+$/) {
return $var;
}
# Username with domain
if ($var =~ /^[a-z0-9_\-\.]+\@[a-z0-9\-\.]+$/) {
return $var;
}
return undef;
}
# Check if variable is an IP
sub isIP
{
my $var = shift;
# Make sure we're not a ref
if (!isVariable($var)) {
return undef;
}
# Lowercase it
$var = lc($var);
# Normal IP
if ($var =~ /^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$/) {
return $var;
}
return undef;
}
# Check if variable is a number
sub isNumber
{
my $var = shift;
# Make sure we're not a ref
if (!isVariable($var)) {
return undef;
}
# Strip leading 0's
if ($var =~ /^0*([0-9]+)$/) {
my $val = int($1);
# Check we not 0 or negative
if ($val > 0) {
return $val;
}
# Check if we allow 0's
if ($val == 0) {
return $val;
}
}
return undef;
}
# Booleanize the variable depending on its contents
sub booleanize
{
my $var = shift;
# Check if we're defined
if (!isVariable($var)) {
return undef;
}
# If we're a number
if (my $val = isNumber($var)) {
if ($val == 0) {
return 0;
} else {
return 1;
}
}
# Nuke whitespaces
$var =~ s/\s//g;
# Allow true, on, set, enabled, 1
if ($var =~ /^(?:true|on|set|enabled|1|yes)$/i) {
return 1;
}
# Invalid or unknown
return 0;
}
1;
# vim: ts=4
opentrafficshaper/version.pm
View file @ efc9ebe1
# OpenTrafficShaper version package
# Copyright (C) 2007-2013, AllWorldIT
#
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
......@@ -30,7 +30,7 @@ our (@ISA,@EXPORT,@EXPORT_OK);
use constant {
VERSION => "0.1.x",
VERSION => "2.0.4",
};
......
opentrafficshaperd
View file @ efc9ebe1
#!/usr/bin/perl
# Main OpenTrafficShaper program
# Copyright (C) 2007-2013, AllWorldIT
#
# Copyright (C) 2007-2023, AllWorldIT
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
......@@ -18,10 +18,10 @@
use strict;
use warnings;
use File::Basename qw(dirname);
# Set the dirs we look for library files in
use lib('/usr/local/lib/opentrafficshaper-1.0','/usr/lib/opentrafficshaper-1.0',
'/usr/lib64/opentrafficshaper-1.0','opentrafficshaper','awitpt', 'lib');
use lib(dirname(__FILE__),dirname(__FILE__)."/awitpt/lib");
# Enable assertions
BEGIN {
......@@ -76,7 +76,7 @@ exit;
# Function to display banner
sub displayBanner
{
$logger->log(LOG_NOTICE,"[MAIN] OpenTrafficShaper v".VERSION." - Copyright (c) 2007-2013, AllWorldIT");
$logger->log(LOG_NOTICE,"[MAIN] OpenTrafficShaper v%s - Copyright (c) 2007-2023, AllWorldIT",VERSION);
}
......@@ -89,7 +89,7 @@ sub parseCfgCmdLine
$cfg->{'config_file'} = "/etc/opentrafficshaper.conf";
$cfg->{'background'} = "yes";
$cfg->{'pid_file'} = "/var/run/opentrafficshaper/opentrafficshaperd.pid";
$cfg->{'pid_file'} = "/run/opentrafficshaper/opentrafficshaperd.pid";
$cfg->{'log_level'} = 2;
$cfg->{'log_file'} = "/var/log/opentrafficshaper/opentrafficshaperd.log";
......@@ -156,8 +156,8 @@ sub parseCfgCmdLine
if (ref($config{'plugins'}{'load'}) eq "ARRAY") {
foreach my $plugin (@{$config{'plugins'}{'load'}}) {
$plugin =~ s/\s+//g;
# Skip comments
next if ($plugin =~ /^#/);
# Skip comments
next if ($plugin =~ /^#/);
push(@{$cfg->{'plugin_list'}},$plugin);
}
} elsif (defined($config{'plugins'}{'load'})) {
......@@ -192,9 +192,9 @@ sub displayHelp {
print(STDERR<<EOF);
Usage: $0 [args]
--config=<file> Configuration file
--debug Put into debug mode
--fg Don't go into background
--config=<file> Configuration file
--debug Put into debug mode
--fg Don't go into background
EOF
}
......@@ -232,7 +232,7 @@ sub init
plugin_register($pluginName,0);
}
$logger->log(LOG_INFO,"[MAIN] Plugins initialized.");
$logger->log(LOG_INFO,"[MAIN] Plugins initialized");
}
# Function to start things up
......@@ -266,7 +266,7 @@ sub daemonize {
open STDOUT, '> /dev/null'
or die "Can't open stdout log: $!";
defined(my $pid = fork)
defined(my $pid = fork)
or die "Can't fork: $!";
exit if $pid;
......@@ -277,7 +277,7 @@ sub daemonize {
print(FH $$);
close(FH);
} else {
$logger->log(LOG_WARN,"[MAIN] Unable to write PID to '".$globals->{'config'}->{'pid_file'}."': $!");
$logger->log(LOG_WARN,"[MAIN] Unable to write PID to '%s': %s",$globals->{'config'}->{'pid_file'},$!);
}
}
......