X-Git-Url: http://info.iut-bm.univ-fcomte.fr/pub/gitweb/simgrid.git/blobdiff_plain/dccf1b41e9c7b5a696f01abceaa2779fe65f154f..3037a0963f5d462b145ee127ffaed836dffd0085:/teshsuite/smpi/mpich3-test/rma/linked_list_lockall.c diff --git a/teshsuite/smpi/mpich3-test/rma/linked_list_lockall.c b/teshsuite/smpi/mpich3-test/rma/linked_list_lockall.c index 2690692133..eed66f3a37 100644 --- a/teshsuite/smpi/mpich3-test/rma/linked_list_lockall.c +++ b/teshsuite/smpi/mpich3-test/rma/linked_list_lockall.c @@ -23,7 +23,7 @@ #include #include "mpitest.h" -#if HAVE_UNISTD_H +#ifdef HAVE_UNISTD_H #include #endif @@ -33,7 +33,7 @@ /* Linked list pointer */ typedef struct { - int rank; + int rank; MPI_Aint disp; } llist_ptr_t; @@ -44,40 +44,42 @@ typedef struct { } llist_elem_t; static const llist_ptr_t nil = { -1, (MPI_Aint) MPI_BOTTOM }; -static const int verbose = 0; -/* List of locally allocated list elements. */ -static llist_elem_t **my_elems = NULL; -static int my_elems_size = 0; -static int my_elems_count = 0; +static const int verbose = 0; /* Allocate a new shared linked list element */ -MPI_Aint alloc_elem(int value, MPI_Win win) { +static MPI_Aint alloc_elem(int value, MPI_Win win, llist_elem_t ***my_elems, int* my_elems_size, int* my_elems_count) +{ MPI_Aint disp; llist_elem_t *elem_ptr; /* Allocate the new element and register it with the window */ MPI_Alloc_mem(sizeof(llist_elem_t), MPI_INFO_NULL, &elem_ptr); elem_ptr->value = value; - elem_ptr->next = nil; + elem_ptr->next = nil; MPI_Win_attach(win, elem_ptr, sizeof(llist_elem_t)); /* Add the element to the list of local elements so we can free it later. */ - if (my_elems_size == my_elems_count) { - my_elems_size += 100; - my_elems = realloc(my_elems, my_elems_size*sizeof(void*)); + if (*my_elems_size == *my_elems_count) { + *my_elems_size += 100; + *my_elems = realloc(*my_elems, *my_elems_size * sizeof(void *)); } - my_elems[my_elems_count] = elem_ptr; - my_elems_count++; + (*my_elems)[*my_elems_count] = elem_ptr; + (*my_elems_count)++; MPI_Get_address(elem_ptr, &disp); return disp; } -int main(int argc, char **argv) { - int procid, nproc, i; - MPI_Win llist_win; - llist_ptr_t head_ptr, tail_ptr; +int main(int argc, char **argv) +{ + int procid, nproc, i; + MPI_Win llist_win; + llist_ptr_t head_ptr, tail_ptr; + /* List of locally allocated list elements. */ + llist_elem_t **my_elems = NULL; + int my_elems_size = 0; + int my_elems_count = 0; MPI_Init(&argc, &argv); @@ -88,7 +90,7 @@ int main(int argc, char **argv) { /* Process 0 creates the head node */ if (procid == 0) - head_ptr.disp = alloc_elem(-1, llist_win); + head_ptr.disp = alloc_elem(-1, llist_win, &my_elems, &my_elems_size, &my_elems_count); /* Broadcast the head pointer to everyone */ head_ptr.rank = 0; @@ -105,16 +107,17 @@ int main(int argc, char **argv) { /* Create a new list element and register it with the window */ new_elem_ptr.rank = procid; - new_elem_ptr.disp = alloc_elem(procid, llist_win); + new_elem_ptr.disp = alloc_elem(procid, llist_win, &my_elems, &my_elems_size, &my_elems_count); /* Append the new node to the list. This might take multiple attempts if - others have already appended and our tail pointer is stale. */ + * others have already appended and our tail pointer is stale. */ do { llist_ptr_t next_tail_ptr = nil; - MPI_Compare_and_swap((void*) &new_elem_ptr.rank, (void*) &nil.rank, - (void*) &next_tail_ptr.rank, MPI_INT, tail_ptr.rank, - (MPI_Aint) &(((llist_elem_t*)tail_ptr.disp)->next.rank), llist_win); + MPI_Compare_and_swap((void *) &new_elem_ptr.rank, (void *) &nil.rank, + (void *) &next_tail_ptr.rank, MPI_INT, tail_ptr.rank, + (MPI_Aint) & (((llist_elem_t *) tail_ptr.disp)->next.rank), + llist_win); MPI_Win_flush(tail_ptr.rank, llist_win); success = (next_tail_ptr.rank == nil.rank); @@ -123,25 +126,27 @@ int main(int argc, char **argv) { int i, flag; MPI_Accumulate(&new_elem_ptr.disp, 1, MPI_AINT, tail_ptr.rank, - (MPI_Aint) &(((llist_elem_t*)tail_ptr.disp)->next.disp), 1, + (MPI_Aint) & (((llist_elem_t *) tail_ptr.disp)->next.disp), 1, MPI_AINT, MPI_REPLACE, llist_win); MPI_Win_flush(tail_ptr.rank, llist_win); tail_ptr = new_elem_ptr; /* For implementations that use pt-to-pt messaging, force progress for other threads' - RMA operations. */ + * RMA operations. */ for (i = 0; i < NPROBE; i++) - MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, MPI_STATUS_IGNORE); + MPI_Iprobe(MPI_ANY_SOURCE, MPI_ANY_TAG, MPI_COMM_WORLD, &flag, + MPI_STATUS_IGNORE); - } else { + } + else { /* Tail pointer is stale, fetch the displacement. May take multiple tries - if it is being updated. */ + * if it is being updated. */ do { - MPI_Get_accumulate( NULL, 0, MPI_DATATYPE_NULL, &next_tail_ptr.disp, - 1, MPI_AINT, tail_ptr.rank, - (MPI_Aint) &(((llist_elem_t*)tail_ptr.disp)->next.disp), - 1, MPI_AINT, MPI_NO_OP, llist_win); + MPI_Get_accumulate(NULL, 0, MPI_DATATYPE_NULL, &next_tail_ptr.disp, + 1, MPI_AINT, tail_ptr.rank, + (MPI_Aint) & (((llist_elem_t *) tail_ptr.disp)->next.disp), + 1, MPI_AINT, MPI_NO_OP, llist_win); MPI_Win_flush(tail_ptr.rank, llist_win); } while (next_tail_ptr.disp == nil.disp); tail_ptr = next_tail_ptr; @@ -153,13 +158,13 @@ int main(int argc, char **argv) { MPI_Barrier(MPI_COMM_WORLD); /* Traverse the list and verify that all processes inserted exactly the correct - number of elements. */ + * number of elements. */ if (procid == 0) { - int have_root = 0; - int errors = 0; + int have_root = 0; + int errors = 0; int *counts, count = 0; - counts = (int*) malloc(sizeof(int) * nproc); + counts = (int *) malloc(sizeof(int) * nproc); assert(counts != NULL); for (i = 0; i < nproc; i++) @@ -204,14 +209,15 @@ int main(int argc, char **argv) { MPI_Win_unlock_all(llist_win); if (verbose) - printf("\n\n"); + printf("\n\n"); /* Verify the counts we collected */ for (i = 0; i < nproc; i++) { int expected = NUM_ELEMS; if (counts[i] != expected) { - printf("Error: Rank %d inserted %d elements, expected %d\n", i, counts[i], expected); + printf("Error: Rank %d inserted %d elements, expected %d\n", i, counts[i], + expected); errors++; } } @@ -223,8 +229,8 @@ int main(int argc, char **argv) { MPI_Win_free(&llist_win); /* Free all the elements in the list */ - for ( ; my_elems_count > 0; my_elems_count--) - MPI_Free_mem(my_elems[my_elems_count-1]); + for (; my_elems_count > 0; my_elems_count--) + MPI_Free_mem(my_elems[my_elems_count - 1]); MPI_Finalize(); return 0;