This is an automated email from the git hooks/post-receive script. It was generated because a ref change was pushed to the repository containing the project "MPICH primary repository". The branch, master has been updated via c0ae22e5aed7adb132f5e75f8f542240b51b14d4 (commit) from 352e1a4696dd54f07fc6ce506ee9931317a24655 (commit) Those revisions listed above that are new to this repository have not appeared on any other notification email; so we list those revisions in full, below. - Log ----------------------------------------------------------------- http://git.mpich.org/mpich.git/commitdiff/c0ae22e5aed7adb132f5e75f8f542240b5... commit c0ae22e5aed7adb132f5e75f8f542240b51b14d4 Author: Huiwei Lu <[email protected]> Date: Thu Jul 16 09:17:39 2015 -0500 Adds tests for threaded collective operations A new test directory test/mpi/threads/coll is created and two new tests are added to this directory. The new tests will test threaded overlapped collective operations. A comprehensive test of these two new test case is still needed. For now, the new tests are known to fail with ch3:socket so they are marked as xfail. Refs #2108 Signed-off-by: Lena Oden <[email protected]> diff --git a/test/mpi/.gitignore b/test/mpi/.gitignore index 86babec..8b72685 100644 --- a/test/mpi/.gitignore +++ b/test/mpi/.gitignore @@ -1084,6 +1084,8 @@ /threads/pt2pt/threads /threads/spawn/multispawn /threads/spawn/th_taskmaster +/threads/coll/iallred +/threads/coll/allred /topo/cartcreates /topo/cartzero /topo/dgraph_unwgt diff --git a/test/mpi/configure.ac b/test/mpi/configure.ac index 9408bc1..acc04bf 100644 --- a/test/mpi/configure.ac +++ b/test/mpi/configure.ac @@ -1624,6 +1624,7 @@ AC_OUTPUT(maint/testmerge \ threads/mpi_t/Makefile \ threads/spawn/Makefile \ threads/rma/Makefile \ + threads/coll/Makefile \ errors/Makefile \ errors/attr/Makefile \ errors/basic/Makefile \ diff --git a/test/mpi/threads/Makefile.am b/test/mpi/threads/Makefile.am index 421d45b..5c4cd47 100644 --- a/test/mpi/threads/Makefile.am +++ b/test/mpi/threads/Makefile.am @@ -9,5 +9,5 @@ include $(top_srcdir)/Makefile.mtest EXTRA_DIST = testlist.in -SUBDIRS = util pt2pt comm init mpi_t $(spawndir) rma -DIST_SUBDIRS = util pt2pt comm init mpi_t spawn rma +SUBDIRS = util pt2pt comm init mpi_t $(spawndir) rma coll +DIST_SUBDIRS = util pt2pt comm init mpi_t spawn rma coll diff --git a/test/mpi/threads/coll/Makefile.am b/test/mpi/threads/coll/Makefile.am new file mode 100644 index 0000000..82c994e --- /dev/null +++ b/test/mpi/threads/coll/Makefile.am @@ -0,0 +1,13 @@ +## -*- Mode: Makefile; -*- +## vim: set ft=automake : +## +## (C) 2011 by Argonne National Laboratory. +## See COPYRIGHT in top-level directory. +## + +include $(top_srcdir)/threads/Makefile_threads.mtest + +EXTRA_DIST = testlist + +noinst_PROGRAMS = iallred allred + diff --git a/test/mpi/threads/coll/allred.c b/test/mpi/threads/coll/allred.c new file mode 100644 index 0000000..1e00c78 --- /dev/null +++ b/test/mpi/threads/coll/allred.c @@ -0,0 +1,80 @@ +/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */ +/* + * (C) 2012 by Argonne National Laboratory. + * See COPYRIGHT in top-level directory. + */ + +/* + * Test threaded overlapped collective operations. + * + * Create one communicator for each thread, then do collective operation + * on the communicator. For different threads on different processes, try to + * do the collective in a overlapped order. + */ + +#include <stdio.h> +#include <mpi.h> +#include "mpitest.h" +#include "mpithreadtest.h" + +#define NUM_THREADS 2 +#define BUF_SIZE 1024 + +#define check(X_) \ + do { \ + if (!(X_)) { \ + printf("[%s:%d] -- Assertion failed: %s\n", __FILE__, __LINE__, #X_);\ + MPI_Abort(MPI_COMM_WORLD, 1); \ + } \ + } while (0) + +MPI_Comm comms[NUM_THREADS]; +int rank, size; + +MTEST_THREAD_RETURN_TYPE test_iallred(void *arg) +{ + MPI_Request req; + int tid = *(int *) arg; + int buf[BUF_SIZE]; + + if (tid == rank) + MTestSleep(1); + MPI_Allreduce(MPI_IN_PLACE, buf, BUF_SIZE, MPI_INT, MPI_BAND, comms[tid]); + + return (MTEST_THREAD_RETURN_TYPE)0; +} + + +int main(int argc, char **argv) +{ + int thread_args[NUM_THREADS]; + int i, provided; + int errs = 0; + + MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided); + + check(provided == MPI_THREAD_MULTIPLE); + + MPI_Comm_rank(MPI_COMM_WORLD, &rank); + MPI_Comm_size(MPI_COMM_WORLD, &size); + + for (i = 0; i < NUM_THREADS; i++) { + MPI_Comm_dup(MPI_COMM_WORLD, &comms[i]); + } + + for (i = 0; i < NUM_THREADS; i++) { + thread_args[i] = i; + MTest_Start_thread( test_iallred, (void *)&thread_args[i] ); + } + + errs = MTest_Join_threads(); + + for (i = 0; i < NUM_THREADS; i++) { + MPI_Comm_free(&comms[i]); + } + + MTest_Finalize(errs); + MPI_Finalize(); + + return 0; +} diff --git a/test/mpi/threads/coll/iallred.c b/test/mpi/threads/coll/iallred.c new file mode 100644 index 0000000..e80cfc5 --- /dev/null +++ b/test/mpi/threads/coll/iallred.c @@ -0,0 +1,81 @@ +/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */ +/* + * (C) 2012 by Argonne National Laboratory. + * See COPYRIGHT in top-level directory. + */ + +/* + * Test threaded overlapped nonblocking collective operations. + * + * Create one communicator for each thread, then do collective operation + * on the communicator. For different threads on different processes, try to + * do the collective in a overlapped order. + */ + +#include <stdio.h> +#include <mpi.h> +#include "mpitest.h" +#include "mpithreadtest.h" + +#define NUM_THREADS 2 +#define BUF_SIZE 1024 + +#define check(X_) \ + do { \ + if (!(X_)) { \ + printf("[%s:%d] -- Assertion failed: %s\n", __FILE__, __LINE__, #X_);\ + MPI_Abort(MPI_COMM_WORLD, 1); \ + } \ + } while (0) + +MPI_Comm comms[NUM_THREADS]; +int rank, size; + +MTEST_THREAD_RETURN_TYPE test_iallred(void *arg) +{ + MPI_Request req; + int tid = *(int *) arg; + int buf[BUF_SIZE]; + + if (tid == rank) + MTestSleep(1); + MPI_Iallreduce(MPI_IN_PLACE, buf, BUF_SIZE, MPI_INT, MPI_BAND, comms[tid], &req); + MPI_Wait(&req, MPI_STATUS_IGNORE); + + return (MTEST_THREAD_RETURN_TYPE)0; +} + + +int main(int argc, char **argv) +{ + int thread_args[NUM_THREADS]; + int i, provided; + int errs = 0; + + MPI_Init_thread(&argc, &argv, MPI_THREAD_MULTIPLE, &provided); + + check(provided == MPI_THREAD_MULTIPLE); + + MPI_Comm_rank(MPI_COMM_WORLD, &rank); + MPI_Comm_size(MPI_COMM_WORLD, &size); + + for (i = 0; i < NUM_THREADS; i++) { + MPI_Comm_dup(MPI_COMM_WORLD, &comms[i]); + } + + for (i = 0; i < NUM_THREADS; i++) { + thread_args[i] = i; + MTest_Start_thread( test_iallred, (void *)&thread_args[i] ); + } + + errs = MTest_Join_threads(); + + for (i = 0; i < NUM_THREADS; i++) { + MPI_Comm_free(&comms[i]); + } + + MTest_Finalize(errs); + MPI_Finalize(); + + return 0; +} diff --git a/test/mpi/threads/coll/testlist b/test/mpi/threads/coll/testlist new file mode 100644 index 0000000..f66e46b --- /dev/null +++ b/test/mpi/threads/coll/testlist @@ -0,0 +1,2 @@ +allred 2 xfail=ticket2108 +iallred 2 xfail=ticket2108 diff --git a/test/mpi/threads/testlist.in b/test/mpi/threads/testlist.in index ac3f3cc..41993e1 100644 --- a/test/mpi/threads/testlist.in +++ b/test/mpi/threads/testlist.in @@ -4,3 +4,4 @@ init mpi_t @spawndir@ @rmadir@ +coll ----------------------------------------------------------------------- Summary of changes: test/mpi/.gitignore | 2 + test/mpi/configure.ac | 1 + test/mpi/threads/Makefile.am | 4 +- test/mpi/threads/{mpi_t => coll}/Makefile.am | 2 +- .../{comm/comm_create_threads.c => coll/allred.c} | 52 +++++++++----------- .../{comm/comm_create_threads.c => coll/iallred.c} | 53 +++++++++----------- test/mpi/threads/coll/testlist | 2 + test/mpi/threads/testlist.in | 1 + 8 files changed, 56 insertions(+), 61 deletions(-) copy test/mpi/threads/{mpi_t => coll}/Makefile.am (87%) copy test/mpi/threads/{comm/comm_create_threads.c => coll/allred.c} (58%) copy test/mpi/threads/{comm/comm_create_threads.c => coll/iallred.c} (58%) create mode 100644 test/mpi/threads/coll/testlist hooks/post-receive -- MPICH primary repository