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;
}
}
}
results[PARALLELISM] = END;
verify_log_contents_unordered(results);
+ for (int i = 0; i < PARALLELISM; i++) {
+ free((void *)results[i].message);
+ }
}
int main() {