Merge pull request #7445 from rhc54/topic/tests

Save the old ORTE simple tests

Author: rhc54

test/simple/Makefile.include

@@ -0,0 +1,60 @@
+# -*- makefile -*-
+#
+# Copyright (c) 2004-2005 The Trustees of Indiana University and Indiana
+#                         University Research and Technology
+#                         Corporation.  All rights reserved.
+# Copyright (c) 2004-2005 The University of Tennessee and The University
+#                         of Tennessee Research Foundation.  All rights
+#                         reserved.
+# Copyright (c) 2004-2005 High Performance Computing Center Stuttgart,
+#                         University of Stuttgart.  All rights reserved.
+# Copyright (c) 2004-2005 The Regents of the University of California.
+#                         All rights reserved.
+# Copyright (c) 2006      Cisco Systems, Inc.  All rights reserved.
+# Copyright (c) 2007      Sun Microsystems, Inc.  All rights reserved.
+# Copyright (c) 2017      Intel, Inc. All rights reserved.
+# $COPYRIGHT$
+#
+# Additional copyrights may follow
+#
+# $HEADER$
+#
+
+# Note that this file does not stand on its own.  It is included by a
+# higher-level Makefile so that Automake features such as "make dist"
+# work properly (and include all the relevant files in this directory
+# in the distribution tarball).
+
+# If you are looking for the file that builds these examples, look at
+# "Makefile" in this same directory (it is *NOT* generated by
+# Automake).
+
+EXTRA_DIST += \
+        test/mpi/Makefile \
+        test/mpi/abort.c \
+        test/mpi/accept.c \
+        test/mpi/bad_exit.c \
+        test/mpi/concurrent_spawn.c \
+        test/mpi/connect.c \
+        test/mpi/crisscross.c \
+        test/mpi/delayed_abort.c \
+        test/mpi/hello_barrier.c \
+        test/mpi/hello.c \
+        test/mpi/loop_child.c \
+        test/mpi/loop_spawn.c \
+        test/mpi/mpi_barrier.c \
+        test/mpi/mpi_no_op.c \
+        test/mpi/mpi_spin.c \
+        test/mpi/multi_abort.c \
+        test/mpi/pubsub.c \
+        test/mpi/sendrecv_blaster.c \
+        test/mpi/simple_spawn.c \
+        test/mpi/slave.c \
+        test/mpi/spawn_multiple.c \
+        test/mpi/ziatest.c \
+        test/mpi/ziaprobe.c \
+        test/mpi/singleton_client_server.c \
+        test/mpi/spawn_tree.c \
+        test/mpi/info_spawn.c \
+		test/mpi/pmix.c \
+		test/mpi/xlib.c

test/simple/abort.c

@@ -0,0 +1,44 @@
+/* -*- C -*-
+ *
+ * $HEADER$
+ *
+ * The most basic of MPI applications
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+
+#include "mpi.h"
+
+int main(int argc, char* argv[])
+{
+    int rank, size;
+    int errcode;
+
+    if (1 < argc) {
+        errcode = strtol(argv[1], NULL, 10);
+    } else {
+        errcode = 2;
+    }
+
+    MPI_Init(&argc, &argv);
+    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+    MPI_Comm_size(MPI_COMM_WORLD, &size);
+
+    printf("Hello, World, I am %d of %d\n", rank, size);
+
+    if (1 == size) {
+            MPI_Abort(MPI_COMM_WORLD, errcode);
+    } else {
+        if (1 == rank) {
+            MPI_Abort(MPI_COMM_WORLD, errcode);
+        } else {
+            errcode = 0;
+            sleep(99999999);
+        }
+    }
+
+    MPI_Finalize();
+    return errcode;
+}

test/simple/accept.c

@@ -0,0 +1,44 @@
+/* -*- C -*-
+ *
+ * $HEADER$
+ *
+ * Test of connect/accept - the accept (server) side
+ */
+
+#include <stdio.h>
+#include "mpi.h"
+
+int main(int argc, char* argv[])
+{
+    int rank, size;
+    MPI_Info info;
+    char port[MPI_MAX_PORT_NAME];
+    MPI_Comm client;
+
+    MPI_Init(&argc, &argv);
+
+    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+    MPI_Comm_size(MPI_COMM_WORLD, &size);
+
+    printf("Hello, World, I am %d of %d\n", rank, size);
+    fflush(stdout);
+
+    MPI_Info_create(&info);
+    MPI_Info_set(info, "ompi_global_scope", "true");
+
+    if (0 == rank) {
+        MPI_Open_port(MPI_INFO_NULL, port);
+        MPI_Publish_name("test-pub", info, port);
+        MPI_Comm_accept(port, MPI_INFO_NULL, 0, MPI_COMM_WORLD, &client);
+    }
+
+    MPI_Barrier(client);
+
+    if (0 == rank) {
+        MPI_Unpublish_name("test-pub", info, port);
+        MPI_Close_port(port);
+    }
+
+    MPI_Finalize();
+    return 0;
+}

test/simple/add_host.c

@@ -0,0 +1,85 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include <sys/param.h>
+
+#include "opal/runtime/opal.h"
+
+#include <mpi.h>
+
+int main(int argc, char* argv[])
+{
+    int msg, rc;
+    MPI_Comm parent, child;
+    int rank, size;
+    const char *hostname;
+    pid_t pid;
+    char *env_rank,*env_nspace;
+    MPI_Info info;
+
+    env_rank = getenv("PMIX_RANK");
+    env_nspace = getenv("PMIX_NAMESPACE");
+    pid = getpid();
+    hostname = opal_gethostname();
+
+    printf("[%s:%s pid %ld] starting up on node %s!\n", env_nspace, env_rank, (long)pid, hostname);
+
+    MPI_Init(NULL, NULL);
+    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+    printf("%d completed MPI_Init\n", rank);
+    MPI_Comm_size(MPI_COMM_WORLD, &size);
+    MPI_Comm_get_parent(&parent);
+    /* If we get COMM_NULL back, then we're the parent */
+    if (MPI_COMM_NULL == parent) {
+        pid = getpid();
+        printf("Parent [pid %ld] about to spawn!\n", (long)pid);
+        MPI_Info_create(&info);
+        MPI_Info_set(info, "add-host", "rhc002:24");
+        if (MPI_SUCCESS != (rc = MPI_Comm_spawn(argv[0], MPI_ARGV_NULL, 3, info,
+                                                0, MPI_COMM_WORLD, &child, MPI_ERRCODES_IGNORE))) {
+            printf("Child failed to spawn\n");
+            return rc;
+        }
+        printf("Parent done with spawn\n");
+        if (0 == rank) {
+            msg = 38;
+            printf("Parent sending message to child\n");
+            MPI_Send(&msg, 1, MPI_INT, 0, 1, child);
+        }
+        MPI_Comm_disconnect(&child);
+        printf("Parent disconnected\n");
+        /* do it again */
+        MPI_Info_set(info, "add-host", "rhc003:24");
+        if (MPI_SUCCESS != (rc = MPI_Comm_spawn(argv[0], MPI_ARGV_NULL, 3, info,
+                                                0, MPI_COMM_WORLD, &child, MPI_ERRCODES_IGNORE))) {
+            printf("Child failed to spawn\n");
+            return rc;
+        }
+        printf("Parent done with second spawn\n");
+        if (0 == rank) {
+            msg = 38;
+            printf("Parent sending message to second children\n");
+            MPI_Send(&msg, 1, MPI_INT, 0, 1, child);
+        }
+        MPI_Comm_disconnect(&child);
+        printf("Parent disconnected again\n");
+    }
+    /* Otherwise, we're the child */
+    else {
+        MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+        MPI_Comm_size(MPI_COMM_WORLD, &size);
+        pid = getpid();
+        printf("Hello from the child %d of %d on host %s pid %ld\n", rank, 3, hostname, (long)pid);
+        if (0 == rank) {
+            MPI_Recv(&msg, 1, MPI_INT, 0, 1, parent, MPI_STATUS_IGNORE);
+            printf("Child %d received msg: %d\n", rank, msg);
+        }
+        MPI_Comm_disconnect(&parent);
+        printf("Child %d disconnected\n", rank);
+    }
+
+    MPI_Finalize();
+    fprintf(stderr, "%d: exiting\n", pid);
+    return 0;
+}

test/simple/attach.c

@@ -0,0 +1,30 @@
+/* -*- C -*-
+ *
+ * $HEADER$
+ *
+ * The most basic of MPI applications
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <unistd.h>
+
+int main(int argc, char* argv[])
+{
+    unsigned char fifo_cmd = 1;
+    int fd;
+
+    if (1 > argc) {
+        fprintf(stderr, "usage: attach <full-path-to-debugger-fifo-file>\n");
+        exit(1);
+    }
+
+    fd = open(argv[1], O_WRONLY);
+    write(fd, &fifo_cmd, sizeof(unsigned char));
+    close(fd);
+
+    return 0;
+}

test/simple/bad_exit.c

@@ -0,0 +1,25 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <mpi.h>
+
+#define RANK_DEATH 1
+
+int main(int argc, char **argv)
+{
+   int rank;
+   MPI_Init(&argc,&argv);
+   MPI_Comm_rank(MPI_COMM_WORLD,&rank);
+
+   sleep(2);
+   if (rank==RANK_DEATH) {
+       printf("Rank %d exiting without calling finalize...\n", rank);
+       exit(1);
+   }
+   sleep(2);
+   printf("Rank %d calling MPI_Finalize\n", rank);
+   MPI_Finalize();
+   printf("Rank %d exiting\n", rank);
+   return 0;
+}
+

test/simple/badcoll.c

@@ -0,0 +1,28 @@
+#include <stdio.h>
+#include <unistd.h>
+#include "mpi.h"
+
+const int count = 1234;
+int buffer[1234] = {0};
+
+int main(int argc, char *argv[])
+{
+    int rank, size, i;
+
+    MPI_Init(&argc, &argv);
+    MPI_Comm_rank(MPI_COMM_WORLD, &rank);
+    MPI_Comm_size(MPI_COMM_WORLD, &size);
+
+
+    for (i=0; i < 1000; i++) {
+        fprintf(stderr, "%d: Executing Bcast #%d\n", rank, i);
+        MPI_Bcast(buffer, count, MPI_INT, 0, MPI_COMM_WORLD);
+        if (0 != rank) {
+            sleep(1);
+        }
+    }
+
+    MPI_Finalize();
+    return 0;
+}
+

test/simple/bcast_loop.c

@@ -0,0 +1,36 @@
+#include <mpi.h>
+#include <stdio.h>
+
+int main(int argc, char* argv[])
+{
+    int myid, nprocs, tag;
+    int i, m, nt;
+    MPI_Status status;
+    double workarray1[561], workarray2[561];
+    const int numm = 50000;
+    const int numt = 142;
+
+    MPI_Init(NULL, NULL);
+    MPI_Comm_size(MPI_COMM_WORLD, &nprocs);
+    MPI_Comm_rank(MPI_COMM_WORLD, &myid);
+
+    for (m = 0; m < numm; ++m) {
+        if (0 == (m % 1000)) {
+            printf("rank %d, m = %d\n", myid, m);
+        }
+        for (nt = 0; nt <= numt; ++nt) {
+            if (0 == myid) {
+                for (i = 0; i < 561; ++i) {
+                    workarray1[i] = numm * numt * i;
+                    workarray2[i] = numm * numt * (i + 1);
+                }
+            }
+            MPI_Bcast(workarray1, 561, MPI_DOUBLE, 0, MPI_COMM_WORLD);
+            MPI_Bcast(workarray2, 561, MPI_DOUBLE, 0, MPI_COMM_WORLD);
+        }
+    }
+    MPI_Finalize();
+
+    return 0;
+}
+