static int is_end(ex_t exp) {
return exp.a == END.a && exp.b == END.b && exp.message == END.message;
}
+static void consume(ex_t *exp) {
+ exp->a = CONSUMED.a;
+ exp->b = CONSUMED.b;
+}
static int is_consumed(ex_t exp) {
- return exp.a == CONSUMED.a && exp.b == CONSUMED.b &&
- exp.message == CONSUMED.message;
+ return exp.a == CONSUMED.a && exp.b == CONSUMED.b;
}
static ex_t expectation(time_t a, time_t b, const char *message) {
ex_t exp;
static void consume_expectation(ex_t exps[], const char *line) {
for (size_t i = 0; !is_end(exps[i]); i++) {
if (line_problem(&exps[i], line) == NULL) {
- exps[i] = CONSUMED;
+ consume(&exps[i]);
return;
}
}
if (tt == (time_t)-1)
die_err("Can't pack time?");
- const char *encoded = encode_time(tt);
+ char *encoded = encode_time(tt);
/* Loose check to allow for daylight savings time changes between the current
* time and the target time. :( */
assert(encoded[0] == '2');
assert(encoded[17] == '1');
assert(encoded[18] == '6');
assert(encoded[19] == '\0');
+ free(encoded);
}
static FILE *take_lock(FILE *f, char *lock_type) {
}
results[PARALLELISM] = END;
verify_log_contents_unordered(results);
+ for (int i = 0; i < PARALLELISM; i++) {
+ free((void *)results[i].message);
+ }
}
int main() {