From 33a6737df3781d352692b2dccf48896d62cedff7 Mon Sep 17 00:00:00 2001
From: Igor Sfiligoi <isfiligoi@ucsd.edu>
Date: Wed, 6 Nov 2013 19:48:34 +0000
Subject: Add rrdFlotSumAsync; similar to rrdFlotAsync, but will use RRDFileSum
 of the data loaded from the url_list

---
 src/lib/rrdFlotAsync.js | 82 +++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 80 insertions(+), 2 deletions(-)

diff --git a/src/lib/rrdFlotAsync.js b/src/lib/rrdFlotAsync.js
index b631cbb..654514f 100644
--- a/src/lib/rrdFlotAsync.js
+++ b/src/lib/rrdFlotAsync.js
@@ -12,7 +12,7 @@
 /*
  * Local dependencies:
  *  binaryXHR.js
- *  rrdFile.js
+ *  rrdFile.js and/or rrdMultiFile.js
  *  rrdFlot.js
  *
  * Those modules may have other requirements.
@@ -27,7 +27,7 @@ function rrdFlotAsyncCallback(bf,obj) {
     return 1;
   }
   try {
-    var i_rrd_data=new RRDFile(bf);            
+    i_rrd_data=new RRDFile(bf);            
   } catch(err) {
     alert("File "+obj.url+" is not a valid RRD archive!\n"+err);
   }
@@ -73,3 +73,81 @@ rrdFlotAsync.prototype.callback = function() {
   this.rrd_flot_obj=new rrdFlot(this.html_id, this.rrd_data, this.graph_options, this.ds_graph_options, this.rrdflot_defaults);
 };
 
+
+// ================================================================================================================
+
+/* Internal helper function */
+function rrdFlotSumAsyncCallback(bf,arr) {
+  var obj=arr[0];
+  var idx=arr[1];
+
+  obj.files_loaded++; // increase this even if it fails later on, else we will never finish
+
+  var i_rrd_data=undefined;
+  if (bf.getLength()<1) {
+    alert("File "+obj.url_list[idx]+" is empty (possibly loading failed)! You may get a parial result in the graph.");
+  } else {
+    try {
+      i_rrd_data=new RRDFile(bf);
+    } catch(err) {
+      alert("File "+obj.url_list[idx]+" is not a valid RRD archive! You may get a partial result in the graph.\n"+err);
+    }
+  }
+  if (i_rrd_data!=undefined) {
+    obj.loaded_data[idx]=i_rrd_data;
+  }
+
+  if (obj.files_loaded==obj.files_needed) {
+    obj.callback();
+  }
+}
+
+/*
+ * For further documentation about the arguments
+ * see rrdFlot.js
+ */
+
+/* Use url_list==null if you do not know the urls yet */
+function rrdFlotSumAsync(html_id, url_list, graph_options, ds_graph_options, rrdflot_defaults) {
+  this.html_id=html_id;
+  this.url_list=url_list;
+  this.graph_options=graph_options;
+  this.ds_graph_options=ds_graph_options;
+  this.rrdflot_defaults=rrdflot_defaults;
+
+  this.rrd_flot_obj=null;
+  this.loaded_data=null;
+
+  if (url_list!=null) {
+    this.reload(url_list);
+  }
+}
+
+rrdFlotSumAsync.prototype.reload = function(url_list) {
+  this.files_needed=url_list.length;
+  this.url_list=url_list;
+  delete this.loaded_data;
+  this.loaded_data=[];
+  this.files_loaded=0;
+  for (i in url_list) {
+    try {
+      FetchBinaryURLAsync(url_list[i],rrdFlotSumAsyncCallback,[this,i]);
+    } catch (err) {
+      alert("Failed loading "+url_list[i]+". You may get a partial result in the graph.\n"+err);
+      this.files_needed--;
+    }
+  }
+};
+
+rrdFlotSumAsync.prototype.callback = function() {
+  if (this.rrd_flot_obj!=null) delete this.rrd_flot_obj;
+  var real_data_arr=new Array();
+  for (i in this.loaded_data) {
+    // account for failed loaded urls
+    var el=this.loaded_data[i];
+    if (el!=undefined) real_data_arr.push(el);
+  }
+  var rrd_sum=new RRDFileSum(real_data_arr);
+  this.rrd_flot_obj=new rrdFlot(this.html_id, rrd_sum, this.graph_options, this.ds_graph_options, this.rrdflot_defaults);
+};
+
-- 
cgit v1.1-4-g5e80