- eat_tag(&ptr2, "cdp_prep");
- for (i = 0; i < (int) rrd->stat_head->ds_cnt; i++) {
- if (eat_tag(&ptr2, "ds") != 1) {
- rrd_set_error
- ("expected to find %lu <ds> entries in <cdp_prep>",
- rrd->stat_head->ds_cnt);
- return -1;
- }
- /* support to read CDP parameters */
- rra_index = rrd->stat_head->rra_cnt - 1;
- skip(&ptr2);
- if (input_version < 2) {
- rrd->cdp_prep[rrd->stat_head->ds_cnt * (rra_index) +
- i].scratch[CDP_primary_val].u_val = 0.0;
- rrd->cdp_prep[rrd->stat_head->ds_cnt * (rra_index) +
- i].scratch[CDP_secondary_val].u_val = 0.0;
- read_tag(&ptr2, "value", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt * (rra_index) +
- i].scratch[CDP_val].u_val));
- read_tag(&ptr2, "unknown_datapoints", "%lu",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt * (rra_index) +
- i].scratch[CDP_unkn_pdp_cnt].u_cnt));
- } else {
-
- if (strncmp(ptr2, "<value>", 7) == 0) {
- parse_patch1028_CDP_params(&ptr2, rrd, rra_index, i);
- } else {
- read_tag(&ptr2, "primary_value", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt * (rra_index)
- + i].scratch[CDP_primary_val].u_val));
- read_tag(&ptr2, "secondary_value", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt * (rra_index)
- +
- i].scratch[CDP_secondary_val].u_val));
- switch (cf_conv(rrd->rra_def[rra_index].cf_nam)) {
- case CF_HWPREDICT:
- case CF_MHWPREDICT:
- read_tag(&ptr2, "intercept", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_intercept].
- u_val));
- read_tag(&ptr2, "last_intercept", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_last_intercept].
- u_val));
- read_tag(&ptr2, "slope", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_slope].u_val));
- read_tag(&ptr2, "last_slope", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_last_slope].
- u_val));
- read_tag(&ptr2, "nan_count", "%lu",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_null_count].
- u_cnt));
- read_tag(&ptr2, "last_nan_count", "%lu",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_last_null_count].
- u_cnt));
- break;
- case CF_SEASONAL:
- case CF_DEVSEASONAL:
- read_tag(&ptr2, "seasonal", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_seasonal].
- u_val));
- read_tag(&ptr2, "last_seasonal", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_hw_last_seasonal].
- u_val));
- read_tag(&ptr2, "init_flag", "%lu",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index)
- +
- i].scratch[CDP_init_seasonal].
- u_cnt));
- break;
- case CF_DEVPREDICT:
- break;
- case CF_FAILURES:
- parse_FAILURES_history(&ptr2, rrd, rra_index, i);
- break;
- case CF_AVERAGE:
- case CF_MAXIMUM:
- case CF_MINIMUM:
- case CF_LAST:
- default:
- read_tag(&ptr2, "value", "%lf",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index) +
- i].scratch[CDP_val].u_val));
- read_tag(&ptr2, "unknown_datapoints", "%lu",
- &(rrd->
- cdp_prep[rrd->stat_head->ds_cnt *
- (rra_index) +
- i].scratch[CDP_unkn_pdp_cnt].
- u_cnt));
- break;
+ unsigned int ds_count;
+
+ status = 0;
+ for ( ds_count = 0; ds_count < rrd->stat_head->ds_cnt;ds_count++){
+ if (expect_element(reader,"ds") == 0) {
+ status = parse_tag_rra_cdp_prep_ds(reader, rrd,
+ cdp_prep + ds_count);
+ if (status != 0)
+ break;
+ } else {
+ status = -1;
+ break;
+ }
+ }
+ if (status == 0)
+ status = expect_element(reader,"/cdp_prep");
+ return (status);
+} /* int parse_tag_rra_cdp_prep */
+
+/*
+ * Parse the <params> block within an RRA definition
+ */
+static int parse_tag_rra_params(
+ xmlTextReaderPtr reader,
+ rra_def_t *rra_def)
+{
+ xmlChar *element;
+ int status;
+
+ status = -1;
+ while ((element = get_xml_element(reader)) != NULL){
+ /*
+ * Parameters for CF_HWPREDICT
+ */
+ if (xmlStrcasecmp(element, (const xmlChar *) "hw_alpha") == 0)
+ status = get_xml_double(reader,
+ &rra_def->par[RRA_hw_alpha].u_val);
+ else if (xmlStrcasecmp(element, (const xmlChar *) "hw_beta") == 0)
+ status = get_xml_double(reader,
+ &rra_def->par[RRA_hw_beta].u_val);
+ else if (xmlStrcasecmp(element,
+ (const xmlChar *) "dependent_rra_idx") == 0)
+ status = get_xml_ulong(reader,
+ &rra_def->
+ par[RRA_dependent_rra_idx].u_cnt);
+ /*
+ * Parameters for CF_SEASONAL and CF_DEVSEASONAL
+ */
+ else if (xmlStrcasecmp(element, (const xmlChar *) "seasonal_gamma") ==
+ 0)
+ status =
+ get_xml_double(reader,
+ &rra_def->par[RRA_seasonal_gamma].u_val);
+ else if (xmlStrcasecmp
+ (element, (const xmlChar *) "seasonal_smooth_idx") == 0)
+ status =
+ get_xml_ulong(reader,
+ &rra_def->
+ par[RRA_seasonal_smooth_idx].u_cnt);
+ else if (xmlStrcasecmp(element, (const xmlChar *) "smoothing_window")
+ == 0)
+ status =
+ get_xml_double(reader,
+ &rra_def->
+ par[RRA_seasonal_smoothing_window].
+ u_val);
+ /* else if (dependent_rra_idx) ...; */
+ /*
+ * Parameters for CF_FAILURES
+ */
+ else if (xmlStrcasecmp(element, (const xmlChar *) "delta_pos") == 0)
+ status = get_xml_double(reader,
+ &rra_def->par[RRA_delta_pos].u_val);
+ else if (xmlStrcasecmp(element, (const xmlChar *) "delta_neg") == 0)
+ status = get_xml_double(reader,
+ &rra_def->par[RRA_delta_neg].u_val);
+ else if (xmlStrcasecmp(element, (const xmlChar *) "window_len") == 0)
+ status = get_xml_ulong(reader,
+ &rra_def->par[RRA_window_len].
+ u_cnt);
+ else if (xmlStrcasecmp(element, (const xmlChar *) "failure_threshold")
+ == 0)
+ status =
+ get_xml_ulong(reader,
+ &rra_def->
+ par[RRA_failure_threshold].u_cnt);
+ /*
+ * Parameters for CF_AVERAGE, CF_MAXIMUM, CF_MINIMUM, and CF_LAST
+ */
+ else if (xmlStrcasecmp(element, (const xmlChar *) "xff") == 0)
+ status = get_xml_double(reader,
+ &rra_def->par[RRA_cdp_xff_val].
+ u_val);
+ /*
+ * Compatibility code for 1.0.49
+ */
+ else if (xmlStrcasecmp(element, (const xmlChar *) "value") == 0) { /* {{{ */
+ unsigned int i = 0;
+
+ for (i=0;i<ARRAY_LENGTH(rra_def->par);i++){
+ if ((i == RRA_dependent_rra_idx)
+ || (i == RRA_seasonal_smooth_idx)
+ || (i == RRA_failure_threshold))
+ status = get_xml_ulong(reader,
+ &rra_def->par[i].
+ u_cnt);
+ else
+ status = get_xml_double(reader,
+ &rra_def->par[i].u_val);
+
+ if (status != 0)
+ break;
+ if ( i-1 < ARRAY_LENGTH(rra_def->par)){
+ status = expect_element(reader,"/value");
+ if (status == 0){
+ status = expect_element(reader,"value");