216 static int flush_cached_updates(updcacheitem_t *cacheitem, char *newdata)  in flush_cached_updates()  argument
223 		  cacheitem->key, (newdata ? 1 : 0) + cacheitem->valcount, cacheitem->tpl->template);  in flush_cached_updates()
226 	updparams[3] = cacheitem->tpl->template;  in flush_cached_updates()
229 	for (i=0; (i < cacheitem->valcount); i++) updparams[4+i] = cacheitem->vals[i];  in flush_cached_updates()
232 		updparams[4+cacheitem->valcount] = newdata;  in flush_cached_updates()
233 		updparams[4+cacheitem->valcount+1] = NULL;  in flush_cached_updates()
237 		updparams[4+cacheitem->valcount] = NULL;  in flush_cached_updates()
254 	for (i=0; (i < cacheitem->valcount); i++) {  in flush_cached_updates()
255 		cacheitem->updseq[i] = 0;  in flush_cached_updates()
256 		cacheitem->updtime[i] = 0;  in flush_cached_updates()
257 		if (cacheitem->vals[i]) xfree(cacheitem->vals[i]);  in flush_cached_updates()
259 	cacheitem->valcount = 0;  in flush_cached_updates()
271 	updcacheitem_t *cacheitem = NULL;  in create_and_update_rrd()  local
321 		cacheitem = (updcacheitem_t *)calloc(1, sizeof(updcacheitem_t));  in create_and_update_rrd()
322 		cacheitem->key = strdup(updcachekey);  in create_and_update_rrd()
323 		cacheitem->tpl = template;  in create_and_update_rrd()
324 		xtreeAdd(updcache, cacheitem->key, cacheitem);  in create_and_update_rrd()
327 		cacheitem = (updcacheitem_t *)xtreeData(updcache, handle);  in create_and_update_rrd()
328 		if (!template) template = cacheitem->tpl;  in create_and_update_rrd()
394 	if (cacheitem->valcount > 0) {  in create_and_update_rrd()
397 		if (cacheitem->updseq[cacheitem->valcount-1] == seq) {  in create_and_update_rrd()
410 		else if (cacheitem->updtime[cacheitem->valcount-1] > updtime) {  in create_and_update_rrd()
411 … Now=%d, previous=%d\n", hostname, rrdfn, (int) updtime, (int)cacheitem->updtime[cacheitem->valcou…  in create_and_update_rrd()
416 		else if (cacheitem->updtime[cacheitem->valcount-1] == updtime) {  in create_and_update_rrd()
417 			int identical = (strcmp(rrdvalues, cacheitem->vals[cacheitem->valcount-1]) == 0);  in create_and_update_rrd()
425 				for (i=0; (i < cacheitem->valcount); i++)   in create_and_update_rrd()
426 					dbgprintf("Val %d: Seq %d: %s\n", i, cacheitem->updseq[i], cacheitem->vals[i]);  in create_and_update_rrd()
477 		if (cacheitem && (cacheitem->valcount < CACHESZ)) {  in create_and_update_rrd()
478 			cacheitem->updseq[cacheitem->valcount] = seq;  in create_and_update_rrd()
479 			cacheitem->updtime[cacheitem->valcount] = updtime;  in create_and_update_rrd()
480 			cacheitem->vals[cacheitem->valcount] = strdup(rrdvalues);  in create_and_update_rrd()
481 			cacheitem->valcount += 1;  in create_and_update_rrd()
490 	result = flush_cached_updates(cacheitem, rrdvalues);  in create_and_update_rrd()
517 	updcacheitem_t *cacheitem;  in rrdcacheflushall()  local
522 		cacheitem = (updcacheitem_t *) xtreeData(updcache, handle);  in rrdcacheflushall()
523 		if (cacheitem->valcount > 0) {  in rrdcacheflushall()
524 			sprintf(filedir, "%s%s", rrddir, cacheitem->key);  in rrdcacheflushall()
525 			flush_cached_updates(cacheitem, NULL);  in rrdcacheflushall()
533 	updcacheitem_t *cacheitem;  in rrdcacheflushhost()  local
567 		cacheitem = (updcacheitem_t *) xtreeData(updcache, handle);  in rrdcacheflushhost()
569 		switch (strncasecmp(cacheitem->key, hostname, keylen)) {  in rrdcacheflushhost()
574 			if (cacheitem->valcount > 0) {  in rrdcacheflushhost()
575 				dbgprintf("Flushing cache '%s'\n", cacheitem->key);  in rrdcacheflushhost()
576 				sprintf(filedir, "%s%s", rrddir, cacheitem->key);  in rrdcacheflushhost()
577 				flush_cached_updates(cacheitem, NULL);  in rrdcacheflushhost()