if (me & 1)
{
AO_t my_counter1;
- if (me != 1)
- fprintf(stderr, "acqrel test: too many threads\n");
+ if (me != 1)
+ {
+ fprintf(stderr, "acqrel test: too many threads\n");
+ abort();
+ }
my_counter1 = AO_load(&counter1);
AO_store(&counter1, my_counter1 + 1);
AO_store_release_write(&counter2, my_counter1 + 1);
if (0 == p) {
# ifdef HAVE_MMAP
fprintf(stderr, "AO_malloc(%d) failed\n", LARGE_OBJ_SIZE);
+ abort();
# else
fprintf(stderr, "AO_malloc(%d) failed: This is normal without mmap\n",
LARGE_OBJ_SIZE);
p = (list_element *)AO_REAL_NEXT_PTR(p -> next))
{
if (p -> data > n || p -> data <= 0)
- fprintf(stderr, "Found erroneous list element %d\n", p -> data);
+ {
+ fprintf(stderr, "Found erroneous list element %d\n", p -> data);
+ abort();
+ }
if (marks[p -> data] != 0)
- fprintf(stderr, "Found duplicate list element %d\n", p -> data);
+ {
+ fprintf(stderr, "Found duplicate list element %d\n", p -> data);
+ abort();
+ }
marks[p -> data] = 1;
}
for (i = 1; i <= n; ++i)
if (marks[i] != 1)
- fprintf(stderr, "Missing list element %d\n", i);
+ {
+ fprintf(stderr, "Missing list element %d\n", i);
+ abort();
+ }
}
volatile AO_t ops_performed = 0;
int code;
if ((code = pthread_join(thread[i], 0)) != 0) {
fprintf(stderr, "Thread join failed %u\n", code);
+ abort();
}
}
times[nthreads][exper_n] = (unsigned long)(get_msecs() - start_time);