From 662bab1374c80b6d81cc89f18acb712b488482f9 Mon Sep 17 00:00:00 2001
From: Frank Wuerthwein <fkw@ucsd.edu>
Date: Sun, 10 May 2009 00:24:53 +0000
Subject: Add rrdRRAMultiStackFlotObj

---
 src/lib/rrdFlotSupport.js | 99 ++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 98 insertions(+), 1 deletion(-)

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
 // =======================================================
-- 
cgit v1.1-4-g5e80