X-Git-Url: https://pintos-os.org/cgi-bin/gitweb.cgi?a=blobdiff_plain;f=src%2Fdata%2Fcasereader-translator.c;h=831077466b0fd373a60f38928e3e4fe388aedc1e;hb=76762fd5bcdcdf30f45ef7775f7b2a3cad7cc0e0;hp=cab13fe31dd98a2f5280af5dd406a7b6b485ada4;hpb=96994a54e60e9c95b8bba54c2281acf7059b1203;p=pspp diff --git a/src/data/casereader-translator.c b/src/data/casereader-translator.c index cab13fe31d..831077466b 100644 --- a/src/data/casereader-translator.c +++ b/src/data/casereader-translator.c @@ -264,7 +264,7 @@ can_translate (struct ccase *c, void *can_) struct casereader_append_numeric *can = can_; double new_value = can->func (c, can->n++, can->aux); c = case_unshare_and_resize (c, can->proto); - case_data_rw_idx (c, caseproto_get_n_widths (can->proto) - 1)->f = new_value; + *case_num_rw_idx (c, caseproto_get_n_widths (can->proto) - 1) = new_value; return c; } @@ -309,7 +309,7 @@ struct casereader * casereader_create_arithmetic_sequence (struct casereader *subreader, double first, double increment) { - struct arithmetic_sequence *as = xzalloc (sizeof *as); + struct arithmetic_sequence *as = XZALLOC (struct arithmetic_sequence); as->first = first; as->increment = increment; return casereader_create_append_numeric (subreader, next_arithmetic, @@ -405,7 +405,7 @@ car_translate (struct ccase *input, void *car_) { struct casereader_append_rank *car = car_; - const double value = case_data (input, car->var)->f; + const double value = case_num (input, car->var); if (car->prev_value != SYSMIS) { @@ -420,7 +420,7 @@ car_translate (struct ccase *input, void *car_) double weight = 1.0; if (car->weight) { - weight = case_data (input, car->weight)->f; + weight = case_num (input, car->weight); if (car->err && weight < 0) *car->err |= RANK_ERR_NEGATIVE_WEIGHT; } @@ -430,13 +430,13 @@ car_translate (struct ccase *input, void *car_) struct ccase *c = casereader_peek (car->clone, car->n + ++k); if (c == NULL) break; - vxx = case_data (c, car->var)->f; + vxx = case_num (c, car->var); if (vxx == value) { if (car->weight) { - double w = case_data (c, car->weight)->f; + double w = case_num (c, car->weight); if (car->err && w < 0) *car->err |= RANK_ERR_NEGATIVE_WEIGHT; @@ -462,7 +462,7 @@ car_translate (struct ccase *input, void *car_) car->n++; input = case_unshare_and_resize (input, car->proto); - case_data_rw_idx (input, caseproto_get_n_widths (car->proto) - 1)->f + *case_num_rw_idx (input, caseproto_get_n_widths (car->proto) - 1) = car->mean_rank; car->prev_value = value; return input; @@ -490,7 +490,7 @@ uniquify (const struct ccase *c, void *aux) struct consolidator *cdr = aux; const union value *current_value = case_data (c, cdr->key); const int key_width = var_get_width (cdr->key); - const double weight = cdr->weight ? case_data (c, cdr->weight)->f : 1.0; + const double weight = cdr->weight ? case_num (c, cdr->weight) : 1.0; struct ccase *next_case = casereader_peek (cdr->clone, cdr->n + 1); int dir = 0; @@ -502,6 +502,11 @@ uniquify (const struct ccase *c, void *aux) dir = value_compare_3way (case_data (next_case, cdr->key), current_value, key_width); + if (dir > 0) + dir = 1; + if (dir < 0) + dir = -1; + case_unref (next_case); if (dir != 0) { @@ -530,12 +535,12 @@ consolodate_weight (struct ccase *input, void *aux) if (cdr->weight) { c = case_unshare (input); - case_data_rw (c, cdr->weight)->f = cdr->prev_cc; + *case_num_rw (c, cdr->weight) = cdr->prev_cc; } else { c = case_unshare_and_resize (input, cdr->proto); - case_data_rw_idx (c, caseproto_get_n_widths (cdr->proto) - 1)->f = cdr->prev_cc; + *case_num_rw_idx (c, caseproto_get_n_widths (cdr->proto) - 1) = cdr->prev_cc; } return c;