From 8ea83b0bc5ce2a2d58c8836cc7f293dc3744b3f0 Mon Sep 17 00:00:00 2001
From: Vincent Brillault
Date: Mon, 16 Dec 2013 21:51:41 +0100
Subject: jsrrdgraph: RrdGraph.js: Add RrdGraph.prototype.graph_paint_async
 method

---
 js/RrdGraph.js | 93 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 93 insertions(+)

(limited to 'js')

diff --git a/js/RrdGraph.js b/js/RrdGraph.js
index 235b35f..8794888 100644
--- a/js/RrdGraph.js
+++ b/js/RrdGraph.js
@@ -705,6 +705,7 @@ var RrdGraph = function (gfx, data)
 {
 	this.gfx = gfx; /* graphics object */
 	this.data = data; /* fetch data object */
+	this.data_need_fetch = [] /* List of data that need to be fetched */
 
 	this.minval = Number.NaN; /* extreme values in the data */
 	this.maxval = Number.NaN;
@@ -1318,6 +1319,92 @@ RrdGraph.prototype.reduce_data = function(gdes, cur_step)
 	}
 };
 
+RrdGraph.prototype.data_fetch_async_callback = function (args, ft_step)
+{
+	var j, that;
+
+	j = args.j;
+	that = args.this;
+
+	if (ft_step < 0)
+		return -1;
+	that.gdes[j].data_first = 1;
+//	that.gdes[j].step = Math.max(that.gdes[j].step, that.step); // FIXME
+	if (ft_step < that.gdes[j].step) {
+		that.reduce_data(that.gdes[j], ft_step);
+	} else {
+		that.gdes[j].step = ft_step;
+	}
+	that.data_need_fetch[j] = 1;
+
+	for (var i = 0, gdes_c = that.gdes.length; i < gdes_c; i++) {
+		if (that.data_need_fetch[i] == j + 2) {
+			that.gdes[i].start = that.gdes[j].start;
+			that.gdes[i].end = that.gdes[j].end;
+			that.gdes[i].step = that.gdes[j].step;
+			that.gdes[i].ds_cnt = that.gdes[j].ds_cnt;
+			that.gdes[i].ds_namv = that.gdes[j].ds_namv;
+			that.gdes[i].data = that.gdes[j].data;
+			that.gdes[i].data_first = 0;
+			that.data_need_fetch[i] = 1;
+		}
+	}
+
+	for (var i = 0, gdes_c = that.gdes.length; i < gdes_c; i++) {
+		if (that.data_need_fetch[i] < 0) continue;
+		if (that.data_need_fetch[i] == 1) continue;
+		return;
+	}
+
+	for (var i = 0, gdes_c = that.gdes.length; i < gdes_c; i++) {
+		if (that.gdes[i].gf != RrdGraphDesc.GF_DEF) continue;
+
+		/* lets see if the required data source is really there */
+		for (var ii = 0; ii < that.gdes[i].ds_cnt; ii++) {
+				if (that.gdes[i].ds_namv[ii] === that.gdes[i].ds_nam) {
+					that.gdes[i].ds = ii;
+					break;
+				}
+		}
+
+		if (that.gdes[i].ds === -1) {
+			alert("No DS called '"+that.gdes[i].ds_nam+"' in '"+that.gdes[i].rrd+"'");
+			return;
+		}
+	}
+	that.graph_paint_draw();
+};
+
+RrdGraph.prototype.data_fetch_async = function ()
+{
+	for (var i = 0, gdes_c = this.gdes.length; i < gdes_c; i++) {
+		if (this.gdes[i].gf != RrdGraphDesc.GF_DEF) {
+			this.data_need_fetch.push(-1);
+			continue;
+		}
+
+		for (var ii = 0; ii < i; ii++) {
+			if (this.gdes[ii].gf != RrdGraphDesc.GF_DEF) continue;
+			if ((this.gdes[i].rrd === this.gdes[ii].rrd)
+				&& (this.gdes[i].cf === this.gdes[ii].cf)
+				&& (this.gdes[i].cf_reduce === this.gdes[ii].cf_reduce)
+				&& (this.gdes[i].start_orig === this.gdes[ii].start_orig)
+				&& (this.gdes[i].end_orig === this.gdes[ii].end_orig)
+				&& (this.gdes[i].step_orig === this.gdes[ii].step_orig)) {
+					this.data_need_fetch.push(ii + 2);
+					break;
+			}
+		}
+		this.data_need_fetch.push(0);
+	 }
+
+	for (var i = 0, gdes_c = this.gdes.length; i < gdes_c; i++) {
+		if (this.data_need_fetch[i] == 0) {
+			this.data_need_fetch[i] = this.data.fetch_async(this.gdes[i], this.gdes[i].step, this.data_fetch_async_callback, {this: this, j:i});
+		}
+	}
+};
+
 RrdGraph.prototype.data_fetch = function()
 {
 	var skip;
@@ -2835,6 +2922,12 @@ RrdGraph.prototype.graph_paint = function ()
 	return this.graph_paint_draw()
 };
 
+RrdGraph.prototype.graph_paint_async = function ()
+{
+	this.graph_paint_init()
+	this.data_fetch_async()
+};
+
 RrdGraph.prototype.find_var = function(key)
 {
 	for (var ii = 0, gdes_c = this.gdes.length; ii < gdes_c; ii++) {
-- 
cgit v1.1