Blame test/mpix/mutex/mutex_lock_unlock.c

Packit Service c5cf8c
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
Packit Service c5cf8c
/*
Packit Service c5cf8c
 *
Packit Service c5cf8c
 *  (C) 2011 by Argonne National Laboratory.
Packit Service c5cf8c
 *      See COPYRIGHT in top-level directory.
Packit Service c5cf8c
 */
Packit Service c5cf8c
Packit Service c5cf8c
/** MPI Mutex test -- James Dinan <dinan@mcs.anl.gov>
Packit Service c5cf8c
  *
Packit Service c5cf8c
  * All processes create N mutexes then lock+unlock all mutexes on all
Packit Service c5cf8c
  * processes.
Packit Service c5cf8c
  */
Packit Service c5cf8c
Packit Service c5cf8c
#include <stdio.h>
Packit Service c5cf8c
#include <stdlib.h>
Packit Service c5cf8c
#include <assert.h>
Packit Service c5cf8c
Packit Service c5cf8c
#include <mpi.h>
Packit Service c5cf8c
Packit Service c5cf8c
#define NUM_MUTEXES 100
Packit Service c5cf8c
Packit Service c5cf8c
const int verbose = 0;
Packit Service c5cf8c
Packit Service c5cf8c
int main(int argc, char **argv)
Packit Service c5cf8c
{
Packit Service c5cf8c
    int rank, nproc, i, j;
Packit Service c5cf8c
    MPIX_Mutex mtx;
Packit Service c5cf8c
Packit Service c5cf8c
    MPI_Init(&argc, &argv);
Packit Service c5cf8c
Packit Service c5cf8c
    MPI_Comm_rank(MPI_COMM_WORLD, &rank;;
Packit Service c5cf8c
    MPI_Comm_size(MPI_COMM_WORLD, &nproc);
Packit Service c5cf8c
Packit Service c5cf8c
    if (rank == 0 && verbose)
Packit Service c5cf8c
        printf("Starting mutex test with %d processes\n", nproc);
Packit Service c5cf8c
Packit Service c5cf8c
    MPIX_Mutex_create(NUM_MUTEXES, MPI_COMM_WORLD, &mtx);
Packit Service c5cf8c
Packit Service c5cf8c
    for (i = 0; i < nproc; i++)
Packit Service c5cf8c
        for (j = 0; j < NUM_MUTEXES; j++) {
Packit Service c5cf8c
            MPIX_Mutex_lock(mtx, j, (rank + i) % nproc);
Packit Service c5cf8c
            MPIX_Mutex_unlock(mtx, j, (rank + i) % nproc);
Packit Service c5cf8c
        }
Packit Service c5cf8c
Packit Service c5cf8c
    if (verbose) {
Packit Service c5cf8c
        printf(" + %3d done\n", rank);
Packit Service c5cf8c
        fflush(NULL);
Packit Service c5cf8c
    }
Packit Service c5cf8c
Packit Service c5cf8c
    MPIX_Mutex_free(&mtx);
Packit Service c5cf8c
Packit Service c5cf8c
    if (rank == 0)
Packit Service c5cf8c
        printf(" No Errors\n");
Packit Service c5cf8c
Packit Service c5cf8c
    MPI_Finalize();
Packit Service c5cf8c
Packit Service c5cf8c
    return 0;
Packit Service c5cf8c
}