aio_req 61 ompi/mca/io/romio321/romio/adio/ad_nfs/ad_nfs_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 66 ompi/mca/io/romio321/romio/adio/ad_nfs/ad_nfs_iwrite.c aio_req = (ADIOI_AIO_Request*)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); aio_req 119 ompi/mca/io/romio321/romio/adio/ad_nfs/ad_nfs_iwrite.c aio_req->aiocbp = aiocbp; aio_req 126 ompi/mca/io/romio321/romio/adio/ad_nfs/ad_nfs_iwrite.c MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, aio_req, request); aio_req 127 ompi/mca/io/romio321/romio/adio/ad_nfs/ad_nfs_iwrite.c memcpy(&(aio_req->req), request, sizeof(MPI_Request)); aio_req 44 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 50 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req = (ADIOI_AIO_Request *)extra_state; aio_req 53 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c if(!GetOverlappedResult( aio_req->fd, aio_req->lpOvl, aio_req 54 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c &(aio_req->nbytes), FALSE)){ aio_req 63 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c mpi_errno = MPI_Grequest_complete(aio_req->req); aio_req 138 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 140 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req = (ADIOI_AIO_Request *)extra_state; aio_req 143 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c MPI_Status_set_elements(status, MPI_BYTE, aio_req->nbytes); aio_req 159 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 162 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req = (ADIOI_AIO_Request*)extra_state; aio_req 163 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c CloseHandle(aio_req->lpOvl->hEvent); aio_req 164 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_Free(aio_req->lpOvl); aio_req 165 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_Free(aio_req); aio_req 216 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 225 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req = (ADIOI_AIO_Request *)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); aio_req 226 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c if (aio_req == NULL) aio_req 233 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req->lpOvl = (LPOVERLAPPED ) ADIOI_Calloc(sizeof(OVERLAPPED), 1); aio_req 234 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c if (aio_req->lpOvl == NULL) aio_req 239 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_Free(aio_req); aio_req 242 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req->lpOvl->hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); aio_req 243 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c if (aio_req->lpOvl->hEvent == NULL) aio_req 251 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_Free(aio_req->lpOvl); aio_req 252 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ADIOI_Free(aio_req); aio_req 255 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req->lpOvl->Offset = DWORDLOW(offset); aio_req 256 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req->lpOvl->OffsetHigh = DWORDHIGH(offset); aio_req 257 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c aio_req->fd = fd_sys; aio_req 262 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ret_val = WriteFile(fd_sys, buf, len, &dwNumWritten, aio_req->lpOvl); aio_req 266 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c ret_val = ReadFile(fd_sys, buf, len, &dwNumRead, aio_req->lpOvl); aio_req 297 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c mpi_errno = MPIX_Grequest_class_allocate(ADIOI_NTFS_greq_class, aio_req, request); aio_req 301 ompi/mca/io/romio321/romio/adio/ad_ntfs/ad_ntfs_iwrite.c memcpy(&(aio_req->req), request, sizeof(MPI_Request)); aio_req 53 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ADIOI_AIO_Request *aio_req; aio_req 58 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c aio_req = (ADIOI_AIO_Request*)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); aio_req 63 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ret = PVFS_Request_contiguous(len, PVFS_BYTE, &(aio_req->mem_req)); aio_req 75 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ret = PVFS_Request_contiguous(len, PVFS_BYTE, &(aio_req->file_req)); aio_req 95 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ret = PVFS_isys_read(pvfs_fs->object_ref, aio_req->file_req, offset, aio_req 96 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c buf, aio_req->mem_req, &(pvfs_fs->credentials), aio_req 97 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c &(aio_req->resp_io), &(aio_req->op_id), NULL); aio_req 105 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ret = PVFS_isys_write(pvfs_fs->object_ref, aio_req->file_req, offset, aio_req 106 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c buf, aio_req->mem_req, &(pvfs_fs->credentials), aio_req 107 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c &(aio_req->resp_io), &(aio_req->op_id), NULL); aio_req 132 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c MPIX_Grequest_class_allocate(ADIOI_PVFS2_greq_class, aio_req, request); aio_req 133 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c memcpy(&(aio_req->req), request, sizeof(*request)); aio_req 153 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ADIOI_AIO_Request *aio_req; aio_req 154 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c aio_req = (ADIOI_AIO_Request*)extra_state; aio_req 156 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c PVFS_Request_free(&(aio_req->mem_req)); aio_req 157 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c PVFS_Request_free(&(aio_req->file_req)); aio_req 158 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ADIOI_Free(aio_req); aio_req 165 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ADIOI_AIO_Request *aio_req; aio_req 168 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c aio_req = (ADIOI_AIO_Request *)extra_state; aio_req 171 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c ret = PVFS_sys_wait(aio_req->op_id, "ADIOI_PVFS2_aio_poll_fn", &error); aio_req 173 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c aio_req->nbytes = aio_req->resp_io.total_completed; aio_req 174 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_aio.c MPI_Grequest_complete(aio_req->req); aio_req 90 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_AIO_Request *aio_req=NULL; aio_req 110 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req = (ADIOI_AIO_Request*)ADIOI_Calloc(sizeof(ADIOI_AIO_Request), 1); aio_req 162 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c if (aio_req != NULL) ADIOI_Free(aio_req); aio_req 165 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_Free(aio_req); aio_req 170 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req->aiocbp = aiocbp; aio_req 177 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, aio_req, request); aio_req 178 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c memcpy(&(aio_req->req), request, sizeof(MPI_Request)); aio_req 213 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 216 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req = (ADIOI_AIO_Request *)extra_state; aio_req 219 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c errno = aio_error(aio_req->aiocbp); aio_req 226 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ssize_t n = aio_return(aio_req->aiocbp); aio_req 227 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req->nbytes = n; aio_req 228 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c errcode = MPI_Grequest_complete(aio_req->req); aio_req 313 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 314 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req = (ADIOI_AIO_Request*)extra_state; aio_req 316 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c if (aio_req->aiocbp != NULL) aio_req 317 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_Free(aio_req->aiocbp); aio_req 318 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_Free(aio_req); aio_req 326 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c ADIOI_AIO_Request *aio_req; aio_req 328 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c aio_req = (ADIOI_AIO_Request *)extra_state; aio_req 330 ompi/mca/io/romio321/romio/adio/common/ad_iwrite.c MPI_Status_set_elements_x(status, MPI_BYTE, aio_req->nbytes);