nbc_req 521 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c void ADIOI_Icalc_others_req(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 523 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; nbc_req 539 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (nbc_req->rdwr == ADIOI_READ) { nbc_req 540 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c nbc_req->data.rd.state = ADIOI_IRC_STATE_ICALC_OTHERS_REQ; nbc_req 542 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Assert(nbc_req->rdwr == ADIOI_WRITE); nbc_req 543 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c nbc_req->data.wr.state = ADIOI_IWC_STATE_ICALC_OTHERS_REQ; nbc_req 547 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c void ADIOI_Icalc_others_req_main(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 549 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; nbc_req 622 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (nbc_req->rdwr == ADIOI_READ) { nbc_req 623 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c nbc_req->data.rd.state = ADIOI_IRC_STATE_ICALC_OTHERS_REQ_MAIN; nbc_req 625 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Assert(nbc_req->rdwr == ADIOI_WRITE); nbc_req 626 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c nbc_req->data.wr.state = ADIOI_IWC_STATE_ICALC_OTHERS_REQ_MAIN; nbc_req 630 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c void ADIOI_Icalc_others_req_fini(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 632 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; nbc_req 648 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c nbc_req->cor_vars = NULL; nbc_req 651 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c next_fn(nbc_req, error_code); nbc_req 212 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_NBC_Request *nbc_req = NULL; nbc_req 228 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req = (ADIOI_NBC_Request *)ADIOI_Calloc(1, sizeof(ADIOI_NBC_Request)); nbc_req 229 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->rdwr = ADIOI_READ; nbc_req 238 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, nbc_req, request); nbc_req 239 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c memcpy(&nbc_req->req, request, sizeof(MPI_Request)); nbc_req 244 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.rsc_vars = vars; nbc_req 298 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_GEN_IREADSTRIDEDCOLL; nbc_req 302 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_indio(nbc_req, error_code); nbc_req 305 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_GEN_IreadStridedColl_inter(ADIOI_NBC_Request *nbc_req, nbc_req 308 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; nbc_req 324 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_indio(nbc_req, error_code); nbc_req 327 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_GEN_IreadStridedColl_indio(ADIOI_NBC_Request *nbc_req, nbc_req 330 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; nbc_req 381 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_fini(nbc_req, error_code); nbc_req 397 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_GEN_IREADSTRIDEDCOLL_INDIO; nbc_req 455 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->cor_vars = cor_vars; nbc_req 466 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Icalc_others_req(nbc_req, error_code); nbc_req 469 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_GEN_IreadStridedColl_read(ADIOI_NBC_Request *nbc_req, nbc_req 472 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; nbc_req 495 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.rae_vars = rae_vars; nbc_req 512 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch(nbc_req, error_code); nbc_req 515 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_GEN_IreadStridedColl_free(ADIOI_NBC_Request *nbc_req, nbc_req 518 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; nbc_req 547 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_fini(nbc_req, error_code); nbc_req 550 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_GEN_IreadStridedColl_fini(ADIOI_NBC_Request *nbc_req, nbc_req 553 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; nbc_req 560 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->nbytes = size * vars->count; nbc_req 563 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (nbc_req->data.rd.rsc_vars) { nbc_req 564 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(nbc_req->data.rd.rsc_vars); nbc_req 565 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.rsc_vars = NULL; nbc_req 569 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Grequest_complete(nbc_req->req); nbc_req 570 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_COMPLETE; nbc_req 574 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 576 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 685 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_IREAD_AND_EXCH; nbc_req 688 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_l1_begin(ADIOI_NBC_Request *nbc_req, nbc_req 691 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 708 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_reset(nbc_req, error_code); nbc_req 830 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.red_vars = red_vars; nbc_req 868 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_IREAD_AND_EXCH_L1_BEGIN; nbc_req 873 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data(nbc_req, error_code); nbc_req 876 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_l1_end(ADIOI_NBC_Request *nbc_req, nbc_req 879 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 906 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_l1_begin(nbc_req, error_code); nbc_req 909 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_reset(ADIOI_NBC_Request *nbc_req, nbc_req 912 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 921 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_l2_begin(nbc_req, error_code); nbc_req 924 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_l2_begin(ADIOI_NBC_Request *nbc_req, nbc_req 927 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 932 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_fini(nbc_req, error_code); nbc_req 939 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.red_vars = red_vars; nbc_req 965 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data(nbc_req, error_code); nbc_req 968 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_l2_end(ADIOI_NBC_Request *nbc_req, nbc_req 971 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 974 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_l2_begin(nbc_req, error_code); nbc_req 977 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_Iread_and_exch_fini(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 979 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; nbc_req 993 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(nbc_req->data.rd.rae_vars); nbc_req 994 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.rae_vars = NULL; nbc_req 997 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c next_fn(nbc_req, error_code); nbc_req 1001 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_R_Iexchange_data(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 1003 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; nbc_req 1010 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_R_IEXCHANGE_DATA; nbc_req 1013 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_R_Iexchange_data_recv(ADIOI_NBC_Request *nbc_req, nbc_req 1016 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; nbc_req 1111 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_R_IEXCHANGE_DATA_RECV; nbc_req 1115 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_fill(nbc_req, error_code); nbc_req 1118 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_R_Iexchange_data_fill(ADIOI_NBC_Request *nbc_req, nbc_req 1121 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; nbc_req 1135 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.state = ADIOI_IRC_STATE_R_IEXCHANGE_DATA_FILL; nbc_req 1138 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c static void ADIOI_R_Iexchange_data_fini(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 1140 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; nbc_req 1159 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.red_vars = NULL; nbc_req 1162 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c next_fn(nbc_req, error_code); nbc_req 1168 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1170 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1172 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Status_set_elements_x(status, MPI_BYTE, nbc_req->nbytes); nbc_req 1188 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1190 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1191 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(nbc_req); nbc_req 1198 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1206 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1208 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c switch (nbc_req->data.rd.state) { nbc_req 1210 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rsc_vars = nbc_req->data.rd.rsc_vars; nbc_req 1214 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_inter(nbc_req, &errcode); nbc_req 1219 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rsc_vars = nbc_req->data.rd.rsc_vars; nbc_req 1223 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_fini(nbc_req, &errcode); nbc_req 1228 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars = nbc_req->cor_vars; nbc_req 1231 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Icalc_others_req_main(nbc_req, &errcode); nbc_req 1236 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars = nbc_req->cor_vars; nbc_req 1241 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Icalc_others_req_fini(nbc_req, &errcode); nbc_req 1244 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Icalc_others_req_fini(nbc_req, &errcode); nbc_req 1249 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars = nbc_req->data.rd.rae_vars; nbc_req 1253 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_l1_begin(nbc_req, &errcode); nbc_req 1258 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars = nbc_req->data.rd.rae_vars; nbc_req 1261 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data(nbc_req, &errcode); nbc_req 1266 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars = nbc_req->data.rd.red_vars; nbc_req 1269 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_recv(nbc_req, &errcode); nbc_req 1274 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars = nbc_req->data.rd.red_vars; nbc_req 1278 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_fill(nbc_req, &errcode); nbc_req 1283 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars = nbc_req->data.rd.red_vars; nbc_req 1288 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_fini(nbc_req, &errcode); nbc_req 235 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_NBC_Request *nbc_req = NULL; nbc_req 251 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req = (ADIOI_NBC_Request *)ADIOI_Calloc(1, sizeof(ADIOI_NBC_Request)); nbc_req 252 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->rdwr = ADIOI_WRITE; nbc_req 261 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPIX_Grequest_class_allocate(ADIOI_GEN_greq_class, nbc_req, request); nbc_req 262 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c memcpy(&nbc_req->req, request, sizeof(MPI_Request)); nbc_req 267 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wsc_vars = vars; nbc_req 316 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_GEN_IWRITESTRIDEDCOLL; nbc_req 320 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_indio(nbc_req, error_code); nbc_req 323 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_inter(ADIOI_NBC_Request *nbc_req, nbc_req 326 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 342 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_indio(nbc_req, error_code); nbc_req 345 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_indio(ADIOI_NBC_Request *nbc_req, nbc_req 348 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 400 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_fini(nbc_req, error_code); nbc_req 417 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_GEN_IWRITESTRIDEDCOLL_INDIO; nbc_req 453 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->cor_vars = cor_vars; nbc_req 464 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Icalc_others_req(nbc_req, error_code); nbc_req 467 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_exch(ADIOI_NBC_Request *nbc_req, nbc_req 470 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 489 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.eaw_vars = eaw_vars; nbc_req 506 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write(nbc_req, error_code); nbc_req 509 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_bcast(ADIOI_NBC_Request *nbc_req, nbc_req 512 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 546 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_GEN_IWRITESTRIDEDCOLL_BCAST; nbc_req 549 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_free(ADIOI_NBC_Request *nbc_req, nbc_req 552 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 596 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_fini(nbc_req, error_code); nbc_req 599 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_GEN_IwriteStridedColl_fini(ADIOI_NBC_Request *nbc_req, nbc_req 602 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; nbc_req 608 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->nbytes = size * vars->count; nbc_req 611 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (nbc_req->data.wr.wsc_vars) { nbc_req 612 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(nbc_req->data.wr.wsc_vars); nbc_req 613 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wsc_vars = NULL; nbc_req 617 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Grequest_complete(nbc_req->req); nbc_req 618 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_COMPLETE; nbc_req 622 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 624 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 744 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_IEXCH_AND_WRITE; nbc_req 747 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_l1_begin(ADIOI_NBC_Request *nbc_req, nbc_req 750 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 766 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_reset(nbc_req, error_code); nbc_req 864 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wed_vars = wed_vars; nbc_req 898 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data(nbc_req, error_code); nbc_req 901 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_l1_body(ADIOI_NBC_Request *nbc_req, nbc_req 904 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 928 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_IEXCH_AND_WRITE_L1_BODY; nbc_req 933 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l1_end(nbc_req, error_code); nbc_req 936 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_l1_end(ADIOI_NBC_Request *nbc_req, nbc_req 939 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 947 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l1_begin(nbc_req, error_code); nbc_req 950 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_reset(ADIOI_NBC_Request *nbc_req, nbc_req 953 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 962 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l2_begin(nbc_req, error_code); nbc_req 965 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_l2_begin(ADIOI_NBC_Request *nbc_req, nbc_req 968 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 974 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_fini(nbc_req, error_code); nbc_req 983 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wed_vars = wed_vars; nbc_req 1018 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data(nbc_req, error_code); nbc_req 1021 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_l2_end(ADIOI_NBC_Request *nbc_req, nbc_req 1024 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 1027 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l2_begin(nbc_req, error_code); nbc_req 1030 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_Iexch_and_write_fini(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 1032 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; nbc_req 1049 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(nbc_req->data.wr.eaw_vars); nbc_req 1050 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.eaw_vars = NULL; nbc_req 1053 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c next_fn(nbc_req, error_code); nbc_req 1057 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_W_Iexchange_data(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 1059 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; nbc_req 1067 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_W_IEXCHANGE_DATA; nbc_req 1070 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_W_Iexchange_data_hole(ADIOI_NBC_Request *nbc_req, nbc_req 1073 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; nbc_req 1179 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_W_IEXCHANGE_DATA_HOLE; nbc_req 1184 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_send(nbc_req, error_code); nbc_req 1187 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_W_Iexchange_data_send(ADIOI_NBC_Request *nbc_req, nbc_req 1190 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; nbc_req 1287 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_W_IEXCHANGE_DATA_SEND; nbc_req 1291 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_wait(nbc_req, error_code); nbc_req 1294 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_W_Iexchange_data_wait(ADIOI_NBC_Request *nbc_req, nbc_req 1297 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; nbc_req 1318 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_fini(nbc_req, error_code); nbc_req 1320 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.state = ADIOI_IWC_STATE_W_IEXCHANGE_DATA_WAIT; nbc_req 1324 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c static void ADIOI_W_Iexchange_data_fini(ADIOI_NBC_Request *nbc_req, int *error_code) nbc_req 1326 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; nbc_req 1350 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wed_vars = NULL; nbc_req 1353 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c next_fn(nbc_req, error_code); nbc_req 1359 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1361 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1363 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Status_set_elements_x(status, MPI_BYTE, nbc_req->nbytes); nbc_req 1379 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1381 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1382 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(nbc_req); nbc_req 1389 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_NBC_Request *nbc_req; nbc_req 1397 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req = (ADIOI_NBC_Request *)extra_state; nbc_req 1399 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c switch (nbc_req->data.wr.state) { nbc_req 1401 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wsc_vars = nbc_req->data.wr.wsc_vars; nbc_req 1405 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_inter(nbc_req, &errcode); nbc_req 1410 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wsc_vars = nbc_req->data.wr.wsc_vars; nbc_req 1414 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_fini(nbc_req, &errcode); nbc_req 1419 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wsc_vars = nbc_req->data.wr.wsc_vars; nbc_req 1423 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_free(nbc_req, &errcode); nbc_req 1428 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars = nbc_req->cor_vars; nbc_req 1431 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Icalc_others_req_main(nbc_req, &errcode); nbc_req 1436 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars = nbc_req->cor_vars; nbc_req 1441 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Icalc_others_req_fini(nbc_req, &errcode); nbc_req 1444 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Icalc_others_req_fini(nbc_req, &errcode); nbc_req 1449 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars = nbc_req->data.wr.eaw_vars; nbc_req 1453 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l1_begin(nbc_req, &errcode); nbc_req 1458 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars = nbc_req->data.wr.eaw_vars; nbc_req 1461 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_l1_end(nbc_req, &errcode); nbc_req 1466 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars = nbc_req->data.wr.wed_vars; nbc_req 1469 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_hole(nbc_req, &errcode); nbc_req 1474 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars = nbc_req->data.wr.wed_vars; nbc_req 1487 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_send(nbc_req, &errcode); nbc_req 1492 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars = nbc_req->data.wr.wed_vars; nbc_req 1496 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_wait(nbc_req, &errcode); nbc_req 1501 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars = nbc_req->data.wr.wed_vars; nbc_req 1513 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_fini(nbc_req, &errcode); nbc_req 593 ompi/mca/io/romio321/romio/adio/include/adioi.h void ADIOI_Icalc_others_req(ADIOI_NBC_Request *nbc_req, int *error_code); nbc_req 594 ompi/mca/io/romio321/romio/adio/include/adioi.h void ADIOI_Icalc_others_req_main(ADIOI_NBC_Request *nbc_req, int *error_code); nbc_req 595 ompi/mca/io/romio321/romio/adio/include/adioi.h void ADIOI_Icalc_others_req_fini(ADIOI_NBC_Request *nbc_req, int *error_code);