Charm++: Charm Source Code Documentation

00001 /* -*- Mode: C; c-basic-offset:4 ; -*- */
00002 /* 
00003  *
00004  *   Copyright (C) 1997 University of Chicago. 
00005  *   See COPYRIGHT notice in top-level directory.
00006  */
00007 
00008 #include "mpioimpl.h"
00009 
00010 #ifdef HAVE_WEAK_SYMBOLS
00011 
00012 #if defined(HAVE_PRAGMA_WEAK)
00013 #pragma weak MPIO_Test = PMPIO_Test
00014 #elif defined(HAVE_PRAGMA_HP_SEC_DEF)
00015 #pragma _HP_SECONDARY_DEF PMPIO_Test MPIO_Test
00016 #elif defined(HAVE_PRAGMA_CRI_DUP)
00017 #pragma _CRI duplicate MPIO_Test as PMPIO_Test
00018 /* end of weak pragmas */
00019 #endif
00020 
00021 /* Include mapping from MPI->PMPI */
00022 #define MPIO_BUILD_PROFILING
00023 #include "mpioprof.h"
00024 #endif
00025 
00026 /* status object not filled currently */
00027 
00028 /*@
00029     MPIO_Test - Test the completion of a nonblocking read or write
00030                 
00031 Input Parameters:
00032 . request - request object (handle)
00033 
00034 Output Parameters:
00035 . flag - true if operation completed (logical)
00036 . status - status object (Status)
00037 
00038 .N fortran
00039 @*/
00040 #ifdef HAVE_MPI_GREQUEST
00041 int MPIO_Test(MPIO_Request *request, int *flag, MPI_Status *status)
00042 {
00043     return (MPI_Test(request, flag, status));
00044 }
00045 #else
00046 int MPIO_Test(MPIO_Request *request, int *flag, MPI_Status *status)
00047 {
00048     int error_code;
00049     static char myname[] = "MPIO_TEST";
00050     MPIU_THREADPRIV_DECL;
00051 #ifdef MPI_hpux
00052     int fl_xmpi;
00053 
00054     if (*request != MPIO_REQUEST_NULL) {
00055     HPMP_IO_WSTART(fl_xmpi, BLKMPIOTEST, TRDTSYSTEM, (*request)->fd);
00056     }
00057 #endif /* MPI_hpux */
00058 
00059     MPIU_THREAD_CS_ENTER(ALLFUNC,);
00060 
00061     if (*request == MPIO_REQUEST_NULL) {
00062         error_code = MPI_SUCCESS;
00063         goto fn_exit;
00064     }
00065 
00066     /* --BEGIN ERROR HANDLING-- */
00067     if ((*request < (MPIO_Request) 0) || 
00068     ((*request)->cookie != ADIOI_REQ_COOKIE))
00069     {
00070     error_code = MPIO_Err_create_code(MPI_SUCCESS, MPIR_ERR_RECOVERABLE,
00071                       myname, __LINE__, MPI_ERR_REQUEST,
00072                       "**request", 0);
00073     error_code = MPIO_Err_return_file(MPI_FILE_NULL, error_code);
00074     goto fn_exit;
00075     }
00076     /* --END ERROR HANDLING-- */
00077 
00078     switch ((*request)->optype) {
00079     case ADIOI_READ:
00080         *flag = ADIO_ReadDone(request, status, &error_code);
00081         break;
00082     case ADIOI_WRITE:
00083         *flag = ADIO_WriteDone(request, status, &error_code);
00084         break;
00085     }
00086 
00087 #ifdef MPI_hpux
00088     HPMP_IO_WEND(fl_xmpi);
00089 #endif /* MPI_hpux */
00090 
00091 fn_exit:
00092     MPIU_THREAD_CS_EXIT(ALLFUNC,);
00093     return error_code;
00094 }
00095 #endif
libs/ck-libs/ampi/romio/mpi-io/iotest.c
