ports/openmpi
ports/openmpi
1
1
Форкнуть 0
Код Релизы Активность

adding the comm and group MPI interface functions to use the new macro

Просмотр исходного кода 
developed by Jeff for checking of MPI_Init/Finalize

This commit was SVN r1415.
Этот коммит содержится в:
Edgar Gabriel 2004-06-18 19:02:52 +00:00
родитель 5e5da35b03
Коммит 47ec006930
36 изменённых файлов: 65 добавлений и 77 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

5
src/mpi/c/close_port.c
Просмотреть файл

@ -20,9 +20,8 @@
int MPI_Close_port(char *port_name)
{
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Close_port");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == port_name )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Close_port");

5
src/mpi/c/comm_accept.c
Просмотреть файл

@ -30,9 +30,8 @@ int MPI_Comm_accept(char *port_name, MPI_Info info, int root,
comp = (ompi_communicator_t *) comm;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_accept");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_accept");

4
src/mpi/c/comm_compare.c
Просмотреть файл

@ -30,9 +30,7 @@ int MPI_Comm_compare(MPI_Comm comm1, MPI_Comm comm2, int *result) {
int found = 0;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_compare");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm1 || MPI_COMM_NULL == comm2 ||
ompi_comm_invalid ( comm1 ) || ompi_comm_invalid (comm2) )

5
src/mpi/c/comm_connect.c
Просмотреть файл

@ -30,9 +30,8 @@ int MPI_Comm_connect(char *port_name, MPI_Info info, int root,
comp = (ompi_communicator_t *) comm;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_connect");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_connect");

4
src/mpi/c/comm_create.c
Просмотреть файл

@ -22,9 +22,7 @@ int MPI_Comm_create(MPI_Comm comm, MPI_Group group, MPI_Comm *newcomm) {
int rc;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_create");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,

5
src/mpi/c/comm_disconnect.c
Просмотреть файл

@ -21,9 +21,8 @@ int MPI_Comm_disconnect(MPI_Comm *comm)
{
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_disconnect");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == *comm || ompi_comm_invalid (*comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_disconnect");

6
src/mpi/c/comm_dup.c
Просмотреть файл

@ -26,10 +26,8 @@ int MPI_Comm_dup(MPI_Comm comm, MPI_Comm *newcomm) {
/* argument checking */
if ( MPI_PARAM_CHECK ) {
if (ompi_mpi_finalized)
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_dup");
OMPI_ERR_INIT_FINALIZE;
if (MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_dup");

4
src/mpi/c/comm_free.c
Просмотреть файл

@ -20,9 +20,7 @@
int MPI_Comm_free(MPI_Comm *comm) {
if ( MPI_PARAM_CHECK ) {
if (ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_free");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == *comm || MPI_COMM_WORLD == *comm ||
MPI_COMM_SELF == *comm || ompi_comm_invalid (*comm))

4
src/mpi/c/comm_get_name.c
Просмотреть файл

@ -26,9 +26,7 @@ int MPI_Comm_get_name(MPI_Comm comm, char *name, int *length) {
ompi_communicator_t* comp;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_get_name");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid ( comm ) )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_COMM,

4
src/mpi/c/comm_group.c
Просмотреть файл

@ -23,9 +23,7 @@ int MPI_Comm_group(MPI_Comm comm, MPI_Group *group) {
/* argument checking */
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_group");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm) )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,

5
src/mpi/c/comm_join.c
Просмотреть файл

@ -27,9 +27,8 @@ int MPI_Comm_join(int fd, MPI_Comm *intercomm)
comp = (ompi_communicator_t *)MPI_COMM_SELF;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_join");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == intercomm )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Comm_join");

4
src/mpi/c/comm_rank.c
Просмотреть файл

@ -21,9 +21,7 @@
int MPI_Comm_rank(MPI_Comm comm, int *rank)
{
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_rank");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,

4
src/mpi/c/comm_set_name.c
Просмотреть файл

@ -26,9 +26,7 @@ int MPI_Comm_set_name(MPI_Comm comm, char *name) {
ompi_communicator_t* comp;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_set_name");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid ( comm ) )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_COMM,

4
src/mpi/c/comm_size.c
Просмотреть файл

@ -20,9 +20,7 @@
int MPI_Comm_size(MPI_Comm comm, int *size) {
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD,
MPI_ERR_INTERN, "MPI_Comm_size");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD,

5
src/mpi/c/comm_spawn.c
Просмотреть файл

@ -31,9 +31,8 @@ int MPI_Comm_spawn(char *command, char **argv, int maxprocs, MPI_Info info,
comp = (ompi_communicator_t *) comm;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_spawn");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_spawn");

5
src/mpi/c/comm_spawn_multiple.c
Просмотреть файл

@ -32,9 +32,8 @@ int MPI_Comm_spawn_multiple(int count, char **array_of_commands, char ***array_o
comp = (ompi_communicator_t *) comm;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_spawn_multiple");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid (comm))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,
"MPI_Comm_spawn_multiple");

4
src/mpi/c/comm_split.c
Просмотреть файл

@ -22,9 +22,7 @@ int MPI_Comm_split(MPI_Comm comm, int color, int key, MPI_Comm *newcomm) {
int rc;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_split");
OMPI_ERR_INIT_FINALIZE;
if ( comm == MPI_COMM_NULL || ompi_comm_invalid ( comm ))
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_COMM,

4
src/mpi/c/comm_test_inter.c
Просмотреть файл

@ -20,9 +20,7 @@
int MPI_Comm_test_inter(MPI_Comm comm, int *flag) {
if ( MPI_PARAM_CHECK ) {
if (ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Comm_test_inter");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == comm || ompi_comm_invalid ( comm ) )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_COMM,

2
src/mpi/c/group_compare.c
Просмотреть файл

@ -31,6 +31,8 @@ int MPI_Group_compare(MPI_Group group1, MPI_Group group2, int *result) {
/* check for errors */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if( ( MPI_GROUP_NULL == group1 ) || ( MPI_GROUP_NULL == group2 ) ||
(NULL == group1) || (NULL==group2) ){
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,

2
src/mpi/c/group_difference.c
Просмотреть файл

@ -29,6 +29,8 @@ int MPI_Group_difference(MPI_Group group1, MPI_Group group2,
/* error checking */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if( (MPI_GROUP_NULL == group1) || (MPI_GROUP_NULL == group2) ||
(NULL == group1) || (NULL == group2) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,

2
src/mpi/c/group_excl.c
Просмотреть файл

@ -30,6 +30,8 @@ int MPI_Group_excl(MPI_Group group, int n, int *ranks,
group_pointer = (ompi_group_t *)group;
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
/* verify that group is valid group */
if ( (MPI_GROUP_NULL == group) || (NULL == group) ||
(NULL == ranks) ) {

2
src/mpi/c/group_free.c
Просмотреть файл

@ -24,6 +24,8 @@ int MPI_Group_free(MPI_Group *group)
/* check to make sure we don't free GROUP_EMPTY or GROUP_NULL */
if (MPI_PARAM_CHECK) {
OMPI_ERR_INIT_FINALIZE;
if ((MPI_GROUP_NULL == *group) || (MPI_GROUP_EMPTY == *group) ||
(NULL == *group) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,

1
src/mpi/c/group_incl.c
Просмотреть файл

@ -28,6 +28,7 @@ int MPI_Group_incl(MPI_Group group, int n, int *ranks, MPI_Group *new_group)
group_pointer = (ompi_group_t *)group;
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
/* verify that group is valid group */
if ( (MPI_GROUP_NULL == group) || ( NULL == group)

12
src/mpi/c/group_intersection.c
Просмотреть файл

@ -27,11 +27,15 @@ int MPI_Group_intersection(MPI_Group group1, MPI_Group group2,
ompi_group_t *group1_pointer, *group2_pointer, *new_group_pointer;
ompi_proc_t *proc1_pointer, *proc2_pointer, *my_proc_pointer;
/* verify that groups are valid */
if ( (MPI_GROUP_NULL == group1) || (MPI_GROUP_NULL == group2) ||
( NULL == group1) || (NULL == group2) ) {
if ( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
/* verify that groups are valid */
if ( (MPI_GROUP_NULL == group1) || (MPI_GROUP_NULL == group2) ||
( NULL == group1) || (NULL == group2) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,
"MPI_Group_intersection");
"MPI_Group_intersection");
}
}
group1_pointer=(ompi_group_t *)group1;

2
src/mpi/c/group_range_excl.c
Просмотреть файл

@ -31,6 +31,8 @@ int MPI_Group_range_excl(MPI_Group group, int n_triplets, int ranges[][3],
/* can't act on NULL group */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if ( (MPI_GROUP_NULL == group) || (NULL == group) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,
"MPI_Group_range_excl");

2
src/mpi/c/group_range_incl.c
Просмотреть файл

@ -30,6 +30,8 @@ int MPI_Group_range_incl(MPI_Group group, int n_triplets, int ranges[][3],
/* can't act on NULL group */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if ( (MPI_GROUP_NULL == group) || (NULL == group) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,
"MPI_Group_range_incl");

2
src/mpi/c/group_rank.c
Просмотреть файл

@ -22,6 +22,8 @@ int MPI_Group_rank(MPI_Group group, int *rank) {
/* error checking */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if( (MPI_GROUP_NULL == group) || ( NULL == group) ){
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,
"MPI_Group_rank");

2
src/mpi/c/group_size.c
Просмотреть файл

@ -22,6 +22,8 @@ int MPI_Group_size(MPI_Group group, int *size) {
/* error checking */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if( (MPI_GROUP_NULL == group) || (NULL == group) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,
"MPI_Group_size");

2
src/mpi/c/group_translate_ranks.c
Просмотреть файл

@ -30,6 +30,8 @@ int MPI_Group_translate_ranks(MPI_Group group1, int n_ranks, int *ranks1,
/* check for errors */
if( MPI_PARAM_CHECK ) {
OMPI_ERR_INIT_FINALIZE;
if ((MPI_GROUP_NULL == group1) || (MPI_GROUP_NULL == group2) ||
(NULL == group1) || (NULL == group2) ) {
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_GROUP,

2
src/mpi/c/group_union.c
Просмотреть файл

@ -28,6 +28,8 @@ int MPI_Group_union(MPI_Group group1, MPI_Group group2, MPI_Group *new_group)
/* check for errors */
if (MPI_PARAM_CHECK) {
OMPI_ERR_INIT_FINALIZE;
if ((MPI_GROUP_NULL == group1) || (MPI_GROUP_NULL == group2) ||
(NULL == group1) || (NULL == group2) ) {
return

4
src/mpi/c/intercomm_create.c
Просмотреть файл

@ -29,9 +29,7 @@ int MPI_Intercomm_create(MPI_Comm local_comm, int local_leader,
int rc, rsize;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Intercomm_create");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == local_comm || ompi_comm_invalid ( local_comm ) ||
( local_comm->c_flags & OMPI_COMM_INTER ) )

4
src/mpi/c/intercomm_merge.c
Просмотреть файл

@ -31,9 +31,7 @@ int MPI_Intercomm_merge(MPI_Comm intercomm, int high,
int rc=MPI_SUCCESS;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE ( MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Intercomm_merge");
OMPI_ERR_INIT_FINALIZE;
if ( MPI_COMM_NULL == intercomm || ompi_comm_invalid ( intercomm ) ||
!( intercomm->c_flags & OMPI_COMM_INTER ) )

5
src/mpi/c/lookup_name.c
Просмотреть файл

@ -24,9 +24,8 @@ int MPI_Lookup_name(char *service_name, MPI_Info info, char *port_name)
char *tmp;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Lookup_name");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == port_name )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Lookup_name");

5
src/mpi/c/open_port.c
Просмотреть файл

@ -21,9 +21,8 @@
int MPI_Open_port(MPI_Info info, char *port_name)
{
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Open_port");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == port_name )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Open_port");

5
src/mpi/c/publish_name.c
Просмотреть файл

@ -24,9 +24,8 @@ int MPI_Publish_name(char *service_name, MPI_Info info,
int rc;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Publish_name");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == port_name )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Publish_name");

5
src/mpi/c/unpublish_name.c
Просмотреть файл

@ -24,9 +24,8 @@ int MPI_Unpublish_name(char *service_name, MPI_Info info,
int rc;
if ( MPI_PARAM_CHECK ) {
if ( ompi_mpi_finalized )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_INTERN,
"MPI_Unpublish_name");
OMPI_ERR_INIT_FINALIZE;
if ( NULL == port_name )
return OMPI_ERRHANDLER_INVOKE(MPI_COMM_WORLD, MPI_ERR_ARG,
"MPI_Unpublish_name");