|
Packit |
0848f5 |
/* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil ; -*- */
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
*
|
|
Packit |
0848f5 |
* (C) 2003 by Argonne National Laboratory.
|
|
Packit |
0848f5 |
* See COPYRIGHT in top-level directory.
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
#include "mpi.h"
|
|
Packit |
0848f5 |
#include <stdio.h>
|
|
Packit |
0848f5 |
#include <stdlib.h>
|
|
Packit |
0848f5 |
#include "mpitest.h"
|
|
Packit |
0848f5 |
#include "mpitestconf.h"
|
|
Packit |
0848f5 |
#ifdef HAVE_STRING_H
|
|
Packit |
0848f5 |
#include <string.h>
|
|
Packit |
0848f5 |
#endif
|
|
Packit |
0848f5 |
#ifdef HAVE_MEMORY_H
|
|
Packit |
0848f5 |
#include <memory.h>
|
|
Packit |
0848f5 |
#endif
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/*
|
|
Packit |
0848f5 |
static char MTEST_Descrip[] = "Test reading and writing zero bytes (set status correctly)";
|
|
Packit |
0848f5 |
*/
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
int main(int argc, char *argv[])
|
|
Packit |
0848f5 |
{
|
|
Packit |
0848f5 |
int errs = 0;
|
|
Packit |
0848f5 |
int size, rank, i, *buf, count, rc;
|
|
Packit |
0848f5 |
MPI_File fh;
|
|
Packit |
0848f5 |
MPI_Comm comm;
|
|
Packit |
0848f5 |
MPI_Status status;
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MTest_Init(&argc, &argv);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
comm = MPI_COMM_WORLD;
|
|
Packit |
0848f5 |
rc = MPI_File_open(comm, (char *) "test.ord",
|
|
Packit |
0848f5 |
MPI_MODE_RDWR | MPI_MODE_CREATE |
|
|
Packit |
0848f5 |
MPI_MODE_DELETE_ON_CLOSE, MPI_INFO_NULL, &fh;;
|
|
Packit |
0848f5 |
if (rc) {
|
|
Packit |
0848f5 |
MTestPrintErrorMsg("File_open", rc);
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
/* If the open fails, there isn't anything else that we can do */
|
|
Packit |
0848f5 |
goto fn_fail;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Comm_size(comm, &size);
|
|
Packit |
0848f5 |
MPI_Comm_rank(comm, &rank;;
|
|
Packit |
0848f5 |
buf = (int *) malloc(size * sizeof(int));
|
|
Packit |
0848f5 |
buf[0] = rank;
|
|
Packit |
0848f5 |
/* Write to file */
|
|
Packit |
0848f5 |
rc = MPI_File_write_ordered(fh, buf, 1, MPI_INT, &status);
|
|
Packit |
0848f5 |
if (rc) {
|
|
Packit |
0848f5 |
MTestPrintErrorMsg("File_write_ordered", rc);
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
else {
|
|
Packit |
0848f5 |
MPI_Get_count(&status, MPI_INT, &count);
|
|
Packit |
0848f5 |
if (count != 1) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "Wrong count (%d) on write-ordered\n", count);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Set the individual pointer to 0, since we want to use a read_all */
|
|
Packit |
0848f5 |
MPI_File_seek(fh, 0, MPI_SEEK_SET);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Read nothing (check status) */
|
|
Packit |
0848f5 |
memset(&status, 0xff, sizeof(MPI_Status));
|
|
Packit |
0848f5 |
MPI_File_read(fh, buf, 0, MPI_INT, &status);
|
|
Packit |
0848f5 |
MPI_Get_count(&status, MPI_INT, &count);
|
|
Packit |
0848f5 |
if (count != 0) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "Count not zero (%d) on read\n", count);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Write nothing (check status) */
|
|
Packit |
0848f5 |
memset(&status, 0xff, sizeof(MPI_Status));
|
|
Packit |
0848f5 |
MPI_File_write(fh, buf, 0, MPI_INT, &status);
|
|
Packit |
0848f5 |
if (count != 0) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "Count not zero (%d) on write\n", count);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Read shared nothing (check status) */
|
|
Packit |
0848f5 |
MPI_File_seek_shared(fh, 0, MPI_SEEK_SET);
|
|
Packit |
0848f5 |
/* Read nothing (check status) */
|
|
Packit |
0848f5 |
memset(&status, 0xff, sizeof(MPI_Status));
|
|
Packit |
0848f5 |
MPI_File_read_shared(fh, buf, 0, MPI_INT, &status);
|
|
Packit |
0848f5 |
MPI_Get_count(&status, MPI_INT, &count);
|
|
Packit |
0848f5 |
if (count != 0) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "Count not zero (%d) on read shared\n", count);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
/* Write nothing (check status) */
|
|
Packit |
0848f5 |
memset(&status, 0xff, sizeof(MPI_Status));
|
|
Packit |
0848f5 |
MPI_File_write_shared(fh, buf, 0, MPI_INT, &status);
|
|
Packit |
0848f5 |
if (count != 0) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "Count not zero (%d) on write\n", count);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_Barrier(comm);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_File_seek_shared(fh, 0, MPI_SEEK_SET);
|
|
Packit |
0848f5 |
for (i = 0; i < size; i++)
|
|
Packit |
0848f5 |
buf[i] = -1;
|
|
Packit |
0848f5 |
MPI_File_read_ordered(fh, buf, 1, MPI_INT, &status);
|
|
Packit |
0848f5 |
if (buf[0] != rank) {
|
|
Packit |
0848f5 |
errs++;
|
|
Packit |
0848f5 |
fprintf(stderr, "%d: buf = %d\n", rank, buf[0]);
|
|
Packit |
0848f5 |
}
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
free(buf);
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
MPI_File_close(&fh;;
|
|
Packit |
0848f5 |
|
|
Packit |
0848f5 |
fn_fail:
|
|
Packit |
0848f5 |
MTest_Finalize(errs);
|
|
Packit |
0848f5 |
MPI_Finalize();
|
|
Packit |
0848f5 |
return 0;
|
|
Packit |
0848f5 |
}
|