diff options
| author | Igor Sfiligoi <isfiligoi@ucsd.edu> | 2010-01-26 20:20:38 +0000 |
|---|---|---|
| committer | Igor Sfiligoi <isfiligoi@ucsd.edu> | 2010-01-26 20:20:38 +0000 |
| commit | b1197b7e0526b8510f49731e5e19ed64425ac9ef (patch) | |
| tree | ce533245703fcee57c0217e3ba761cf95c58a618 | |
| parent | 31115d730181cf3b37d4874c5c9c8162658aed0d (diff) | |
Rist attempt at RRDFileSum
| -rw-r--r-- | src/lib/rrdMultiFile.js | 154 |
1 files changed, 154 insertions, 0 deletions
diff --git a/src/lib/rrdMultiFile.js b/src/lib/rrdMultiFile.js new file mode 100644 index 0000000..1ac4b16 --- /dev/null +++ b/src/lib/rrdMultiFile.js @@ -0,0 +1,154 @@ +/*
+ * Combine multiple rrdFiles into one object
+ * It implements the same interface, but changing the content
+ *
+ * Part of the javascriptRRD package
+ * Copyright (c) 2010 Igor Sfiligoi, isfiligoi@ucsd.edu
+ *
+ * Original repository: http://javascriptrrd.sourceforge.net/
+ *
+ * MIT License [http://www.opensource.org/licenses/mit-license.php]
+ *
+ */
+
+// ============================================================
+// RRD RRA handling class
+function RRDRRASum(rra_list,offset_list,treat_undefined_as_zero) {
+ this.rra_list=rra_list;
+ this.offset_list=offset_list;
+ this.treat_undefined_as_zero=treat_undefined_as_zero;
+ this.row_cnt= this.rra_list[0].getNrRows();
+}
+
+RRDRRA.prototype.getIdx = function() {
+ return this.rra_list[0].getIdx();
+}
+
+// Get number of rows/columns
+RRDRRA.prototype.getNrRows = function() {
+ return this.row_cnt;
+}
+RRDRRA.prototype.getNrDSs = function() {
+ return this.rra_list[0].getNrDSs();
+}
+
+// Get RRA step (expressed in seconds)
+RRDRRA.prototype.getStep = function() {
+ return this.rra_list[0].getStep();
+}
+
+// Get consolidation function name
+RRDRRA.prototype.getCFName = function() {
+ return this.rra_list[0].getCFName();
+}
+
+RRDRRASum.prototype.getEl = function(row_idx,ds_idx) {
+ var outSum=0.0;
+ for (var i in this.rra_list) {
+ var offset=this.offset_list[i];
+ if ((row_id+offset)<this.row_cnt) {
+ var rra=this.rra_list[i];
+ val=rra.getEl(row_idx+offset,ds_idx);
+ } else {
+ /* out of row range -> undefined*/
+ val=undefined;
+ }
+ /* treat all undefines as 0 for now */
+ if (val==undefined) {
+ if (this.treat_undefined_as_zero) {
+ val=0;
+ } else {
+ /* if even one element is undefined, the whole sum is undefined */
+ outSum=undefined;
+ break;
+ }
+ outSum+=val;
+ }
+ return outSum;
+}
+
+// Low precision version of getEl
+// Uses getFastDoubleAt
+RRDRRASum.prototype.getElFast = function(row_idx,ds_idx) {
+ outSum=0.0;
+ for (rra in this.rra_list) {
+ outSum+=rra.getElFast(row_idx,ds_idx);
+ }
+ return outSum;
+}
+
+/*** INTERNAL ** sort by lastupdate, descending ***/
+
+function rrdFileSort(f1, f2) {
+ return f2.getLastUpdate()-f1.getLastUpdate();
+}
+
+/*
+ * Sum several RRDfiles together
+ * They must all have the same DSes and the same RRAs
+ */
+
+function RRDFileSum(file_list,treat_undefined_as_zero) {
+ if (treat_undefined_as_zero==undefined) {
+ this.treat_undefined_as_zero=true;
+ } else {
+ this.treat_undefined_as_zero=treat_undefined_as_zero;
+ }
+ this.file_list=file_list;
+ this.file_list.sort();
+
+ // ===================================
+ // Start of user functions
+
+ this.getMinStep = function() {
+ return this.file_list[0].getMinStep();
+ }
+ this.getLastUpdate = function() {
+ return this.file_list[0].getLastUpdate();
+ }
+
+ this.getNrDSs = function() {
+ return this.file_list[0].getNrDSs();
+ }
+
+ this.getDSNames = function() {
+ return this.file_list[0].getDSNames();
+ }
+
+ this.getDS = function(id) {
+ return this.file_list[0].getDS(id);
+ }
+
+ this.getNrRRAs = function() {
+ return this.file_list[0].getNrRRAs();
+ }
+
+ this.getRRAInfo = function(idx) {
+ return this.file_list[0].getRRAInfo(idx);
+ }
+
+ this.getRRA = function(idx) {
+ var rra_info=this.getRRAInfo(idx);
+ var rra_step=rra_info.getStep();
+ var realLastUpdate=undefined;
+
+ var rra_list=new Array();
+ var offset_list=new Array();
+ for (var i in self.file_list) {
+ file=file_list[i];
+ fileLastUpdate=file.getLastUpdate();
+ if (realLastUpdate!=undefined) {
+ fileSkrew=Math.floor((realLastUpdate-fileLastUpdate)/rra_step);
+ } else {
+ fileSkrew=0;
+ firstLastUpdate=fileLastUpdate;
+ }
+ offset_list.push(fileSkrew);
+ fileRRA=file.getRRA(idx);
+ rra_list.push(fileRRA);
+ }
+
+ return new RRDRRASum(rra_list,offset_list,this.treat_undefined_as_zero);
+ }
+
+}
|