Add rrdRRAMultiStackFlotObj

1 files changed, 98 insertions, 1 deletions

diff --git a/src/lib/rrdFlotSupport.js b/src/lib/rrdFlotSupport.js
index 3110eda..499aca1 100644
--- a/src/lib/rrdFlotSupport.js
+++ b/src/lib/rrdFlotSupport.js
@@ -95,7 +95,7 @@ function rrdRRA2FlotObj(rrd_file,rra_idx,ds_list,want_ds_labels,want_rounding) {
 // return an object with an array containing Flot elements

 //  have a positive and a negative stack of DSes, plus DSes with no stacking

 // min and max are also returned

-// If one_undefined_enough==true, a whole stack is invalidated is a single element

+// If one_undefined_enough==true, a whole stack is invalidated if a single element

 //  of the stack is invalid

 function rrdRRAStackFlotObj(rrd_file,rra_idx,

 			    ds_positive_stack_list,ds_negative_stack_list,ds_single_list,

@@ -206,6 +206,103 @@ function rrdRRAStackFlotObj(rrd_file,rra_idx,
   return out_el;

 }

 

+// return an object with an array containing Flot elements, one per RRD

+// min and max are also returned

+function rrdRRAMultiStackFlotObj(rrd_files, // a list of [rrd_id,rrd_file] pairs, all rrds must have the same step

+				 rra_idx,ds_id,

+				 want_rrd_labels,want_rounding,

+				 one_undefined_enough) { // If true, a whole stack is invalidated if a single element of the stack is invalid

+

+  var reference_rra=rrd_files[0][1].getRRA(rra_idx); // get the first one, all should be the same

+  var rows=reference_rra.getNrRows();

+  var step=reference_rra.getStep();

+  var ds_idx=rrd_files[0][1].getDS(ds_id).getIdx(); // this can be expensive, do once (all the same)

+

+  // rrds can be slightly shifted, calculate range

+  var max_ts=null;

+  var min_ts=null;

+

+  // initialize list of rrd data elements

+  var tmp_flot_els=[];

+  var tmp_rras=[];

+  var tmp_last_updates=[];

+  var tmp_nr_ids=rrd_files.length;

+  for (var id=0; id<tmp_nr_ids; id++) {

+    var rrd_file=rrd_files[id][1];

+    var rrd_rra=rrd_file.getRRA(rra_idx);

+

+    var rrd_last_update=rrd_file.getLastUpdate();

+    if (want_rounding!=false) {

+      // round last_update to step

+      // so that all elements are sync

+      rrd_last_update-=(rrd_last_update%step); 

+    }

+    tmp_last_updates.push(rrd_last_update);

+

+    var rrd_min_ts=rrd_last_update-(rows-1)*step;

+    if ((max_ts==null) || (rrd_last_update>max_ts)) {

+      max_ts=rrd_last_update;

+    }

+    if ((min_ts==null) || (rrd_min_ts<min_ts)) {

+      min_ts=rrd_min_ts;

+    }

+    

+    tmp_rras.push(rrd_rra);

+      

+    // initialize

+    var flot_el={data:[]}

+    if (want_rrd_labels!=false) {

+	var rrd_name=rrd_files[id][0];

+	flot_el.label= rrd_name;

+    }

+    tmp_flot_els.push(flot_el);

+  }

+

+  var out_el={data:[], min:min_ts*1000.0, max:max_ts*1000.0};

+

+  for (var ts=min_ts;ts<=max_ts;ts+=step) {

+      var rrd_vals=[];

+      var all_undef=true;

+      var all_def=true;

+      for (var id=0; id<tmp_nr_ids; id++) {

+        var rrd_rra=tmp_rras[id];

+        var rrd_last_update=tmp_last_updates[id];

+	var row_delta=Math.round((rrd_last_update-ts)/step);

+	var el=undefined; // if out of range

+        if ((row_delta>=0) && (row_delta<rows)) {

+          el=rrd_rra.getEl(rows-row_delta-1,ds_idx);

+        }

+	if (el!=undefined) {

+	  all_undef=false;

+	  rrd_vals.push(el);

+	} else {

+	  all_def=false;

+	  rrd_vals.push(0);

+	}

+      } // end for id

+      if (!all_undef) { // if all undefined, skip

+	if (all_def || (!one_undefined_enough)) {

+	  // this is a valid column, do the math

+	  for (var id=1; id<tmp_nr_ids; id++) {

+	    rrd_vals[id]+=rrd_vals[id-1]; 

+	  }

+	  // fill the flot data

+	  for (var id=0; id<tmp_nr_ids; id++) {

+	    tmp_flot_els[id].data.push([ts*1000.0,rrd_vals[id]]);

+	  }

+	}

+      } // end if

+  } // end for ts

+    

+  // put flot data in output object

+  // reverse order so higher numbers are behind

+  for (var id=0; id<tmp_nr_ids; id++) {

+    out_el.data.push(tmp_flot_els[tmp_nr_ids-id-1]);

+  }

+  

+  return out_el;

+}

+

 // ======================================

 // Helper class for handling selections

 // =======================================================