ompio_req 239 ompi/mca/common/ompio/common_ompio_file_read.c mca_ompio_request_t *ompio_req=NULL; ompio_req 248 ompi/mca/common/ompio/common_ompio_file_read.c mca_common_ompio_request_alloc ( &ompio_req, MCA_OMPIO_REQUEST_READ); ompio_req 251 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; ompio_req 252 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 253 ompi/mca/common/ompio/common_ompio_file_read.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 254 ompi/mca/common/ompio/common_ompio_file_read.c *request = (ompi_request_t *) ompio_req; ompio_req 295 ompi/mca/common/ompio/common_ompio_file_read.c OMPIO_PREPARE_READ_BUF(fh,buf,count,datatype,tbuf,&ompio_req->req_convertor,max_data,decoded_iov,iov_count); ompio_req 297 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_tbuf = tbuf; ompio_req 298 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_size = max_data; ompio_req 312 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; ompio_req 313 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 314 ompi/mca/common/ompio/common_ompio_file_read.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 315 ompi/mca/common/ompio/common_ompio_file_read.c *request = (ompi_request_t *) ompio_req; ompio_req 342 ompi/mca/common/ompio/common_ompio_file_read.c fh->f_fbtl->fbtl_ipreadv (fh, (ompi_request_t *) ompio_req); ompio_req 363 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status.MPI_ERROR = ret; ompio_req 364 ompi/mca/common/ompio/common_ompio_file_read.c ompio_req->req_ompi.req_status._ucount = status._ucount; ompio_req 365 ompi/mca/common/ompio/common_ompio_file_read.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 368 ompi/mca/common/ompio/common_ompio_file_read.c *request = (ompi_request_t *) ompio_req; ompio_req 215 ompi/mca/common/ompio/common_ompio_file_write.c mca_ompio_request_t *ompio_req=NULL; ompio_req 224 ompi/mca/common/ompio/common_ompio_file_write.c mca_common_ompio_request_alloc ( &ompio_req, MCA_OMPIO_REQUEST_WRITE); ompio_req 227 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; ompio_req 228 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 229 ompi/mca/common/ompio/common_ompio_file_write.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 230 ompi/mca/common/ompio/common_ompio_file_write.c *request = (ompi_request_t *) ompio_req; ompio_req 276 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_tbuf = tbuf; ompio_req 277 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_size = max_data; ompio_req 291 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; ompio_req 292 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 293 ompi/mca/common/ompio/common_ompio_file_write.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 294 ompi/mca/common/ompio/common_ompio_file_write.c *request = (ompi_request_t *) ompio_req; ompio_req 321 ompi/mca/common/ompio/common_ompio_file_write.c fh->f_fbtl->fbtl_ipwritev (fh, (ompi_request_t *) ompio_req); ompio_req 341 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status.MPI_ERROR = ret; ompio_req 342 ompi/mca/common/ompio/common_ompio_file_write.c ompio_req->req_ompi.req_status._ucount = status._ucount; ompio_req 343 ompi/mca/common/ompio/common_ompio_file_write.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 346 ompi/mca/common/ompio/common_ompio_file_write.c *request = (ompi_request_t *) ompio_req; ompio_req 37 ompi/mca/common/ompio/common_ompio_request.c mca_ompio_request_t *ompio_req = ( mca_ompio_request_t *)*req; ompio_req 38 ompi/mca/common/ompio/common_ompio_request.c if ( NULL != ompio_req->req_tbuf ) { ompio_req 39 ompi/mca/common/ompio/common_ompio_request.c if ( MCA_OMPIO_REQUEST_READ == ompio_req->req_type ){ ompio_req 44 ompi/mca/common/ompio/common_ompio_request.c decoded_iov.iov_base = ompio_req->req_tbuf; ompio_req 45 ompi/mca/common/ompio/common_ompio_request.c decoded_iov.iov_len = ompio_req->req_size; ompio_req 46 ompi/mca/common/ompio/common_ompio_request.c opal_convertor_unpack (&ompio_req->req_convertor, &decoded_iov, &iov_count, &pos ); ompio_req 48 ompi/mca/common/ompio/common_ompio_request.c mca_common_ompio_release_buf ( NULL, ompio_req->req_tbuf ); ompio_req 50 ompi/mca/common/ompio/common_ompio_request.c if ( NULL != ompio_req->req_free_fn ) { ompio_req 51 ompi/mca/common/ompio/common_ompio_request.c ompio_req->req_free_fn (ompio_req ); ompio_req 53 ompi/mca/common/ompio/common_ompio_request.c opal_list_remove_item (&mca_common_ompio_pending_requests, &ompio_req->req_item); ompio_req 115 ompi/mca/common/ompio/common_ompio_request.c mca_ompio_request_t *ompio_req = NULL; ompio_req 117 ompi/mca/common/ompio/common_ompio_request.c ompio_req = OBJ_NEW(mca_ompio_request_t); ompio_req 118 ompi/mca/common/ompio/common_ompio_request.c ompio_req->req_type = type; ompio_req 119 ompi/mca/common/ompio/common_ompio_request.c ompio_req->req_ompi.req_state = OMPI_REQUEST_ACTIVE; ompio_req 121 ompi/mca/common/ompio/common_ompio_request.c *req=ompio_req; ompio_req 751 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c mca_ompio_request_t *ompio_req = NULL; ompio_req 753 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c mca_common_ompio_request_alloc ( &ompio_req, MCA_OMPIO_REQUEST_WRITE ); ompio_req 766 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ret = fh->f_fbtl->fbtl_ipwritev(fh, (ompi_request_t *) ompio_req); ompio_req 769 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status.MPI_ERROR = ret; ompio_req 770 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 781 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status.MPI_ERROR = ret; ompio_req 782 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status._ucount = ret_temp; ompio_req 783 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 790 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status.MPI_ERROR = OMPI_SUCCESS; ompio_req 791 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompio_req->req_ompi.req_status._ucount = 0; ompio_req 792 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c ompi_request_complete (&ompio_req->req_ompi, false); ompio_req 795 ompi/mca/fcoll/vulcan/fcoll_vulcan_file_write_all.c *request = (ompi_request_t *) ompio_req;