/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
/*
 *
 *  (C) 2011 by Argonne National Laboratory.
 *      See COPYRIGHT in top-level directory.
 */

/** MPI Mutex test -- James Dinan <dinan@mcs.anl.gov>
  * 
  * All processes create N mutexes then lock+unlock all mutexes on all
  * processes.
  */

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>

#include <mpi.h>

#define NUM_MUTEXES 100

const int verbose = 0;

int main(int argc, char ** argv) {
  int rank, nproc, i, j;
  MPIX_Mutex mtx;

  MPI_Init(&argc, &argv);

  MPI_Comm_rank(MPI_COMM_WORLD, &rank);
  MPI_Comm_size(MPI_COMM_WORLD, &nproc);

  if (rank == 0 && verbose)
    printf("Starting mutex test with %d processes\n", nproc);

  MPIX_Mutex_create(NUM_MUTEXES, MPI_COMM_WORLD, &mtx);

  for (i = 0; i < nproc; i++)
    for (j = 0; j < NUM_MUTEXES; j++) {
      MPIX_Mutex_lock(  mtx, j, (rank+i)%nproc);
      MPIX_Mutex_unlock(mtx, j, (rank+i)%nproc);
    }

  if (verbose) {
    printf(" + %3d done\n", rank);
    fflush(NULL);
  }

  MPIX_Mutex_free(&mtx);

  if (rank == 0)
    printf(" No Errors\n");

  MPI_Finalize();

  return 0;
}