X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Frrd_update.c;h=5c42f92784c4ea0e00efb6429f6b1135e6ab54d9;hb=0a82736faf62f1667434aee71e51d876d20c6ced;hp=e8d629ea22568b972f71cb858cb06838b8d5ea14;hpb=22ecdee73cbb51ac7c3301ce39749f819ea72d0e;p=rrdtool.git

diff --git a/src/rrd_update.c b/src/rrd_update.c
index e8d629e..5c42f92 100644
--- a/src/rrd_update.c
+++ b/src/rrd_update.c
@@ -733,9 +733,14 @@ _rrd_update(char *filename, char *template, int argc, char **argv,
 
 	    for(i=0;i<rrd.stat_head->ds_cnt;i++){
 		if(isnan(pdp_new[i]))
-		    rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt += floor(interval-0.5);
-		else
-		    rrd.pdp_prep[i].scratch[PDP_val].u_val+= pdp_new[i];
+		    rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt += floor(interval+0.5);
+		else {
+		     if (isnan( rrd.pdp_prep[i].scratch[PDP_val].u_val )){
+		     	rrd.pdp_prep[i].scratch[PDP_val].u_val= pdp_new[i];
+		     } else {
+		        rrd.pdp_prep[i].scratch[PDP_val].u_val+= pdp_new[i];
+		     }
+		}
 #ifdef DEBUG
 		fprintf(stderr,
 			"NO PDP  ds[%lu]\t"
@@ -755,16 +760,25 @@ _rrd_update(char *filename, char *template, int argc, char **argv,
 	    pdp_temp[] will contain the rate for cdp */
 
 	    for(i=0;i<rrd.stat_head->ds_cnt;i++){
-		/* update pdp_prep to the current pdp_st */
+		/* update pdp_prep to the current pdp_st. */
+		
 		if(isnan(pdp_new[i]))
 		    rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt += floor(pre_int+0.5);
-		else
-		    rrd.pdp_prep[i].scratch[PDP_val].u_val += 
-			pdp_new[i]/interval*pre_int;
+		else {
+  	             if (isnan( rrd.pdp_prep[i].scratch[PDP_val].u_val )){
+		     	rrd.pdp_prep[i].scratch[PDP_val].u_val= 	pdp_new[i]/interval*pre_int;
+		     } else {
+		        rrd.pdp_prep[i].scratch[PDP_val].u_val+= pdp_new[i]/interval*pre_int;
+		     }
+		 }
+		
 
 		/* if too much of the pdp_prep is unknown we dump it */
-		if ((rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt 
-		     > rrd.ds_def[i].par[DS_mrhb_cnt].u_cnt) ||
+		if ( 
+		    /* removed because this does not agree with the definition
+		       a heart beat can be unknown */
+		    /* (rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt 
+		     > rrd.ds_def[i].par[DS_mrhb_cnt].u_cnt) || */
 		    (occu_pdp_st-proc_pdp_st <= 
 		     rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt)) {
 		    pdp_temp[i] = DNAN;
@@ -798,7 +812,7 @@ _rrd_update(char *filename, char *template, int argc, char **argv,
 		/* make pdp_prep ready for the next run */
 		if(isnan(pdp_new[i])){
 		    rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt = floor(post_int + 0.5);
-		    rrd.pdp_prep[i].scratch[PDP_val].u_val = 0.0;
+		    rrd.pdp_prep[i].scratch[PDP_val].u_val = DNAN;
 		} else {
 		    rrd.pdp_prep[i].scratch[PDP_unkn_sec_cnt].u_cnt = 0;
 		    rrd.pdp_prep[i].scratch[PDP_val].u_val =