Commit 746653af authored by James Dinan's avatar James Dinan
Browse files

[svn-r10675] RMA State Tracking: PSCW ordering test

This test case verified that an odd (but correct) usage pattern of generalized
active target synchronization works correctly: start-before-post.

Reviewer: goodell
parent 2497e69b
......@@ -105,7 +105,8 @@ noinst_PROGRAMS = \
flush \
reqops \
req_example \
win_info
win_info \
pscw_ordering
strided_acc_indexed_LDADD = $(LDADD) -lm
strided_acc_onelock_LDADD = $(LDADD) -lm
......
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
/*
* (C) 2001 by Argonne National Laboratory.
* See COPYRIGHT in top-level directory.
*/
/* This test checks an oddball case for generalized active target
* synchronization where the start occurs before the post. Since start can
* block until the corresponding post, the group passed to start must be
* disjoint from the group passed to post and processes must avoid a circular
* wait. Here, odd/even groups are used to accomplish this and the even group
* reverses its start/post calls.
*/
#include <stdio.h>
#include <stdlib.h>
#include <mpi.h>
#include "mpitest.h"
#include "squelch.h"
int main(int argc, char **argv) {
int i, rank, nproc, errors = 0;
int *win_buf;
MPI_Win win;
int odd_nproc, even_nproc;
int *odd_ranks, *even_ranks;
MPI_Group odd_group, even_group, world_group;
MTest_Init(&argc, &argv);
MPI_Comm_rank(MPI_COMM_WORLD, &rank);
MPI_Comm_size(MPI_COMM_WORLD, &nproc);
if (nproc < 2) {
if (rank == 0)
printf("Error: this test requires two or more processes\n");
MPI_Abort(MPI_COMM_WORLD, 100);
}
/* Set up odd/even groups and buffers */
odd_nproc = nproc / 2;
even_nproc = nproc / 2 + ( (nproc % 2 == 0) ? 0 : 1 );
odd_ranks = malloc(sizeof(int) * odd_nproc);
even_ranks = malloc(sizeof(int) * even_nproc);
for (i = 0; i < even_nproc; i++)
even_ranks[i] = i*2;
for (i = 0; i < odd_nproc; i++)
odd_ranks[i] = i*2+1;
MPI_Comm_group(MPI_COMM_WORLD, &world_group);
MPI_Group_incl(world_group, odd_nproc, odd_ranks, &odd_group);
MPI_Group_incl(world_group, even_nproc, even_ranks, &even_group);
/* Create the window */
MPI_Alloc_mem(nproc*sizeof(int), MPI_INFO_NULL, &win_buf);
for (i = 0; i < nproc; i++)
win_buf[i] = -1;
MPI_Win_create(win_buf, nproc*sizeof(int), sizeof(int), MPI_INFO_NULL,
MPI_COMM_WORLD, &win);
/* Perform PSCW communication: Odd/even matchup */
if (rank % 2 == 0) {
MPI_Win_start(odd_group, 0, win); /* Even-numbered procs target odd procs */
MPI_Win_post(odd_group, 0, win); /* Even procs are targeted by odd procs */
/* Write to my slot at each target */
for (i = 0; i < odd_nproc; i++)
MPI_Put(&rank, 1, MPI_INT, odd_ranks[i], rank, 1, MPI_INT, win);
}
else {
MPI_Win_post(even_group, 0, win); /* Odd procs are targeted by even procs */
MPI_Win_start(even_group, 0, win); /* Odd-numbered procs target even procs */
/* Write to my slot at each target */
for (i = 0; i < even_nproc; i++)
MPI_Put(&rank, 1, MPI_INT, even_ranks[i], rank, 1, MPI_INT, win);
}
MPI_Win_complete(win);
MPI_Win_wait(win);
/* Perform PSCW communication: Odd/odd and even/even matchup */
if (rank % 2 == 0) {
MPI_Win_post(even_group, 0, win); /* Even procs are targeted by even procs */
MPI_Win_start(even_group, 0, win); /* Even-numbered procs target even procs */
/* Write to my slot at each target */
for (i = 0; i < even_nproc; i++)
MPI_Put(&rank, 1, MPI_INT, even_ranks[i], rank, 1, MPI_INT, win);
}
else {
MPI_Win_post(odd_group, 0, win); /* Odd procs are targeted by odd procs */
MPI_Win_start(odd_group, 0, win); /* Odd-numbered procs target odd procs */
/* Write to my slot at each target */
for (i = 0; i < odd_nproc; i++)
MPI_Put(&rank, 1, MPI_INT, odd_ranks[i], rank, 1, MPI_INT, win);
}
MPI_Win_complete(win);
MPI_Win_wait(win);
for (i = 0; i < nproc; i++) {
if (win_buf[i] != i) {
errors++;
SQUELCH( printf("%d: Error -- win_buf[%d] = %d, expected %d\n",
rank, i, win_buf[i], i);
);
}
}
MPI_Win_free(&win);
MPI_Free_mem(win_buf);
MPI_Group_free(&world_group);
MPI_Group_free(&odd_group);
MPI_Group_free(&even_group);
free(odd_ranks);
free(even_ranks);
MTest_Finalize( errors );
MPI_Finalize();
return MTestReturnValue( errors );
}
......@@ -91,3 +91,4 @@ reqops 4 mpiversion=3.0
req_example 4 mpiversion=3.0
win_info 4 mpiversion=3.0
linked_list_lockall 4 mpiversion=3.0
pscw_ordering 4 mpiversion=3.0
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment