URCU_TLS(nr_successful_dequeues)++;
URCU_TLS(nr_dequeues)++;
}
+ cds_wfcq_destroy(&tmp_head, &tmp_tail);
}
static void *thr_dequeuer(void *_count)
for (i = 0; i < duration; i++) {
sleep(1);
- if (verbose_mode)
- (void) write(1, ".", 1);
+ if (verbose_mode) {
+ fwrite(".", sizeof(char), 1, stdout);
+ fflush(stdout);
+ }
}
test_stop_enqueue = 1;
tot_dequeue_last);
retval = 1;
}
+ cds_wfcq_destroy(&head, &tail);
free(count_enqueuer);
free(count_dequeuer);
free(tid_enqueuer);