00001
00002
00003
00004
00005
00006
00007
00008
00009 #include "ad_testfs.h"
00010 #include "adioi.h"
00011
00012 int ADIOI_TESTFS_ReadDone(ADIO_Request *request, ADIO_Status *status, int
00013 *error_code)
00014 {
00015 int myrank, nprocs;
00016
00017 *error_code = MPI_SUCCESS;
00018
00019 if (*request == ADIO_REQUEST_NULL) {
00020 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_ReadDone called on ADIO_REQUEST_NULL\n",
00021 myrank, nprocs);
00022 return 1;
00023 }
00024
00025 MPI_Comm_size((*request)->fd->comm, &nprocs);
00026 MPI_Comm_rank((*request)->fd->comm, &myrank);
00027 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_ReadDone called on %s\n",
00028 myrank, nprocs, (*request)->fd->filename);
00029
00030 #ifdef HAVE_STATUS_SET_BYTES
00031 MPIR_Status_set_bytes(status, (*request)->datatype, (*request)->nbytes);
00032 #endif
00033 (*request)->fd->async_count--;
00034 ADIOI_Free_request((ADIOI_Req_node *) (*request));
00035 *request = ADIO_REQUEST_NULL;
00036 return 1;
00037 }
00038
00039 int ADIOI_TESTFS_WriteDone(ADIO_Request *request, ADIO_Status *status, int
00040 *error_code)
00041 {
00042 int myrank, nprocs;
00043
00044 *error_code = MPI_SUCCESS;
00045
00046 if (*request == ADIO_REQUEST_NULL) {
00047 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_WriteDone called on ADIO_REQUEST_NULL\n",
00048 myrank, nprocs);
00049 return 1;
00050 }
00051
00052 MPI_Comm_size((*request)->fd->comm, &nprocs);
00053 MPI_Comm_rank((*request)->fd->comm, &myrank);
00054 FPRINTF(stdout, "[%d/%d] ADIOI_TESTFS_WriteDone called on %s\n",
00055 myrank, nprocs, (*request)->fd->filename);
00056
00057 #ifdef HAVE_STATUS_SET_BYTES
00058 MPIR_Status_set_bytes(status, (*request)->datatype, (*request)->nbytes);
00059 #endif
00060 (*request)->fd->async_count--;
00061 ADIOI_Free_request((ADIOI_Req_node *) (*request));
00062 *request = ADIO_REQUEST_NULL;
00063 return 1;
00064 }