vars 523 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; vars 532 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c vars->count_others_req_per_proc = vars 533 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c (int *)ADIOI_Malloc(vars->nprocs * sizeof(int)); vars 535 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c *error_code = MPI_Ialltoall(vars->count_my_req_per_proc, 1, MPI_INT, vars 536 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c vars->count_others_req_per_proc, 1, MPI_INT, vars->fd->comm, vars 537 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c &vars->req1); vars 549 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; vars 550 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_File fd = vars->fd; vars 551 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int count_my_req_procs = vars->count_my_req_procs; vars 552 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Access *my_req = vars->my_req; vars 553 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int nprocs = vars->nprocs; vars 554 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int myrank = vars->myrank; vars 555 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Access **others_req_ptr = vars->others_req_ptr; vars 565 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c int *count_others_req_per_proc = vars->count_others_req_per_proc; vars 587 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c vars->count_others_req_procs = count_others_req_procs; vars 591 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c vars->req2 = (MPI_Request *) vars 600 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_OFFSET, i, i+myrank, fd->comm, &vars->req2[j]); vars 603 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_OFFSET, i, i+myrank+1, fd->comm, &vars->req2[j]); vars 611 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_OFFSET, i, i+myrank, fd->comm, &vars->req2[j]); vars 614 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_OFFSET, i, i+myrank+1, fd->comm, &vars->req2[j]); vars 620 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c vars->num_req2 = j; vars 632 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Icalc_others_req_vars *vars = nbc_req->cor_vars; vars 635 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Free(vars->req2); vars 636 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Free(vars->count_others_req_per_proc); vars 638 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c *vars->count_others_req_procs_ptr = vars->count_others_req_procs; vars 644 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c next_fn = vars->next_fn; vars 647 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Free(vars); vars 213 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = NULL; vars 242 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars = (ADIOI_GEN_IreadStridedColl_vars *)ADIOI_Calloc( vars 244 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->data.rd.rsc_vars = vars; vars 247 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->fd = fd; vars 248 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->buf = buf; vars 249 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->count = count; vars 250 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->datatype = datatype; vars 251 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->file_ptr_type = file_ptr_type; vars 252 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->offset = offset; vars 256 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs = nprocs; vars 257 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->myrank = myrank; vars 260 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_for_coll = fd->hints->cb_nodes; vars 261 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->orig_fp = fd->fp_ind; vars 272 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->offset_list, &vars->len_list, vars 273 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->start_offset, &vars->end_offset, vars 274 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->contig_access_count); vars 277 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < vars->contig_access_count; i++) { vars 279 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c myrank, vars->offset_list[i], vars->len_list[i]); vars 287 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->st_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); vars 288 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->end_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); vars 290 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Iallgather(&vars->start_offset, 1, ADIO_OFFSET, vars 291 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->st_offsets, 1, ADIO_OFFSET, vars 292 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->comm, &vars->req_offset[0]); vars 294 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Iallgather(&vars->end_offset, 1, ADIO_OFFSET, vars 295 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->end_offsets, 1, ADIO_OFFSET, vars 296 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->comm, &vars->req_offset[1]); vars 308 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; vars 309 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 310 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *st_offsets = vars->st_offsets; vars 311 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *end_offsets = vars->end_offsets; vars 322 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->interleave_count = interleave_count; vars 330 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; vars 332 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_File fd = vars->fd; vars 335 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Datatype datatype = vars->datatype; vars 341 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Datatype_iscontig(datatype, &vars->buftype_is_contig); vars 344 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c || (!vars->interleave_count && (fd->hints->cb_read == ADIOI_HINT_AUTO))) vars 346 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c buf = vars->buf; vars 347 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c count = vars->count; vars 348 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c file_ptr_type = vars->file_ptr_type; vars 349 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c offset = vars->offset; vars 353 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->offset_list); vars 354 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->len_list); vars 355 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->st_offsets); vars 356 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->end_offsets); vars 359 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->fp_ind = vars->orig_fp; vars 368 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->buftype_is_contig && filetype_is_contig) { vars 383 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->buftype_is_contig && filetype_is_contig) { vars 387 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c off, &vars->req_ind_io, error_code); vars 390 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c 0, &vars->req_ind_io, error_code); vars 394 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c offset, &vars->req_ind_io, error_code); vars 402 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs = vars->nprocs; vars 420 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Calc_file_domains(vars->st_offsets, vars->end_offsets, nprocs, vars 421 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_for_coll, &vars->min_st_offset, vars 422 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->fd_start, &vars->fd_end, vars 423 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->hints->min_fdomain_size, &vars->fd_size, vars 438 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Calc_my_req(fd, vars->offset_list, vars->len_list, vars 439 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->contig_access_count, vars->min_st_offset, vars 440 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->fd_start, vars->fd_end, vars->fd_size, vars 441 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs, &vars->count_my_req_procs, vars 442 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->count_my_req_per_proc, &vars->my_req, vars 443 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->buf_idx); vars 456 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->fd = vars->fd; vars 457 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->count_my_req_procs = vars->count_my_req_procs; vars 458 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->count_my_req_per_proc = vars->count_my_req_per_proc; vars 459 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->my_req = vars->my_req; vars 460 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->nprocs = vars->nprocs; vars 461 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->myrank = vars->myrank; vars 462 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->count_others_req_procs_ptr = &vars->count_others_req_procs; vars 463 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->others_req_ptr = &vars->others_req; vars 472 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; vars 474 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *my_req = vars->my_req; vars 475 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 481 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->count_my_req_per_proc); vars 496 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->fd = vars->fd; vars 497 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->buf = vars->buf; vars 498 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->datatype = vars->datatype; vars 499 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->nprocs = vars->nprocs; vars 500 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->myrank = vars->myrank; vars 501 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->others_req = vars->others_req; vars 502 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->offset_list = vars->offset_list; vars 503 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->len_list = vars->len_list; vars 504 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->contig_access_count = vars->contig_access_count; vars 505 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->min_st_offset = vars->min_st_offset; vars 506 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->fd_size = vars->fd_size; vars 507 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->fd_start = vars->fd_start; vars 508 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->fd_end = vars->fd_end; vars 509 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->buf_idx = vars->buf_idx; vars 518 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; vars 519 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_File fd = vars->fd; vars 520 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Datatype datatype = vars->datatype; vars 521 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; vars 522 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 525 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (!vars->buftype_is_contig) ADIOI_Delete_flattened(datatype); vars 537 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->buf_idx); vars 538 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->offset_list); vars 539 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->len_list); vars 540 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->st_offsets); vars 541 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->end_offsets); vars 542 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->fd_start); vars 543 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->fd_end); vars 553 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_GEN_IreadStridedColl_vars *vars = nbc_req->data.rd.rsc_vars; vars 559 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Type_size_x(vars->datatype, &size); vars 560 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nbc_req->nbytes = size * vars->count; vars 576 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 577 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_File fd = vars->fd; vars 578 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Datatype datatype = vars->datatype; vars 579 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 581 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; vars 606 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->coll_bufsize = coll_bufsize; vars 625 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->st_loc = st_loc; vars 626 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->end_loc = end_loc; vars 635 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->ntimes = 0; vars 639 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->ntimes = (int)((end_loc - st_loc + coll_bufsize) / coll_bufsize); vars 642 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Iallreduce(&vars->ntimes, &vars->max_ntimes, 1, MPI_INT, vars 643 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_MAX, fd->comm, &vars->req1); vars 645 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->read_buf = fd->io_buf; /* Allocated at open time */ vars 647 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->curr_offlen_ptr = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 650 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->count = (int *)ADIOI_Malloc(nprocs * sizeof(int)); vars 654 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->partial_send = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 659 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->send_size = (int *)ADIOI_Malloc(nprocs * sizeof(int)); vars 662 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs * sizeof(int)); vars 666 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recd_from_proc = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 670 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->start_pos = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 674 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Datatype_iscontig(datatype, &vars->buftype_is_contig); vars 675 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (!vars->buftype_is_contig) { vars 676 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->flat_buf = ADIOI_Flatten_and_find(datatype); vars 678 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Type_get_extent(datatype, &lb, &vars->buftype_extent); vars 680 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->done = 0; vars 681 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->off = st_loc; vars 682 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->for_curr_iter = vars->for_next_iter = 0; vars 691 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 707 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->m >= vars->ntimes) { vars 712 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd = vars->fd; vars 713 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c nprocs = vars->nprocs; vars 714 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c others_req = vars->others_req; vars 716 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c read_buf = vars->read_buf; vars 717 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c curr_offlen_ptr = vars->curr_offlen_ptr; vars 718 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c count = vars->count; vars 719 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c send_size = vars->send_size; vars 720 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c partial_send = vars->partial_send; vars 721 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c start_pos = vars->start_pos; vars 760 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c size = ADIOI_MIN((unsigned)vars->coll_bufsize, vars 761 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->end_loc - vars->st_loc + 1 - vars->done); vars 762 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c real_off = vars->off - vars->for_curr_iter; vars 763 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c real_size = size + vars->for_curr_iter; vars 765 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->size = size; vars 766 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->real_size = real_size; vars 774 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->myrank, i, others_req[i].count); vars 821 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->for_next_iter = for_next_iter; vars 831 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd = vars->fd; vars 832 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buf = vars->buf; vars 833 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->flat_buf = vars->flat_buf; vars 834 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->offset_list = vars->offset_list; vars 835 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->len_list = vars->len_list; vars 836 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->send_size = vars->send_size; vars 837 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recv_size = vars->recv_size; vars 838 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->count = vars->count; vars 839 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->start_pos = vars->start_pos; vars 840 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->partial_send = vars->partial_send; vars 841 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recd_from_proc = vars->recd_from_proc; vars 842 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->nprocs = vars->nprocs; vars 843 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->myrank = vars->myrank; vars 844 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buftype_is_contig = vars->buftype_is_contig; vars 845 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->contig_access_count = vars->contig_access_count; vars 846 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->min_st_offset = vars->min_st_offset; vars 847 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_size = vars->fd_size; vars 848 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_start = vars->fd_start; vars 849 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_end = vars->fd_end; vars 850 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->others_req = vars->others_req; vars 851 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->iter = vars->m; vars 852 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buftype_extent = vars->buftype_extent; vars 853 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buf_idx = vars->buf_idx; vars 860 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_ReadContig(fd, read_buf+vars->for_curr_iter, (int)size, vars 861 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_BYTE, ADIO_EXPLICIT_OFFSET, vars->off, vars 864 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_IreadContig(fd, read_buf+vars->for_curr_iter, (int)size, vars 865 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_BYTE, ADIO_EXPLICIT_OFFSET, vars->off, vars 866 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->req2, error_code); vars 879 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 880 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_File fd = vars->fd; vars 881 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset size = vars->size; vars 882 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset real_size = vars->real_size; vars 883 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset for_next_iter = vars->for_next_iter; vars 884 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c char *read_buf = vars->read_buf; vars 887 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->for_curr_iter = for_next_iter; vars 892 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Assert((for_next_iter+vars->coll_bufsize) == (size_t)(for_next_iter+vars->coll_bufsize)); vars 895 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->io_buf = (char *)ADIOI_Malloc(for_next_iter+vars->coll_bufsize); vars 897 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->read_buf = fd->io_buf; vars 901 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->off += size; vars 902 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->done += size; vars 905 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->m++; vars 912 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 913 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 914 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *count = vars->count; vars 915 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *send_size = vars->send_size; vars 920 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->m = vars->ntimes; vars 927 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 931 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->m >= vars->max_ntimes) { vars 940 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd = vars->fd; vars 941 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buf = vars->buf; vars 942 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->flat_buf = vars->flat_buf; vars 943 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->offset_list = vars->offset_list; vars 944 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->len_list = vars->len_list; vars 945 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->send_size = vars->send_size; vars 946 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recv_size = vars->recv_size; vars 947 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->count = vars->count; vars 948 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->start_pos = vars->start_pos; vars 949 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->partial_send = vars->partial_send; vars 950 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->recd_from_proc = vars->recd_from_proc; vars 951 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->nprocs = vars->nprocs; vars 952 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->myrank = vars->myrank; vars 953 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buftype_is_contig = vars->buftype_is_contig; vars 954 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->contig_access_count = vars->contig_access_count; vars 955 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->min_st_offset = vars->min_st_offset; vars 956 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_size = vars->fd_size; vars 957 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_start = vars->fd_start; vars 958 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_end = vars->fd_end; vars 959 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->others_req = vars->others_req; vars 960 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->iter = vars->m; vars 961 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buftype_extent = vars->buftype_extent; vars 962 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->buf_idx = vars->buf_idx; vars 971 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 973 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->m++; vars 979 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Iread_and_exch_vars *vars = nbc_req->data.rd.rae_vars; vars 982 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->curr_offlen_ptr); vars 983 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->count); vars 984 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->partial_send); vars 985 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->send_size); vars 986 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->recv_size); vars 987 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->recd_from_proc); vars 988 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->start_pos); vars 990 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c next_fn = vars->next_fn; vars 1003 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; vars 1007 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c *error_code = MPI_Ialltoall(vars->send_size, 1, MPI_INT, vars->recv_size, 1, vars 1008 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_INT, vars->fd->comm, &vars->req1); vars 1016 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; vars 1017 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_File fd = vars->fd; vars 1018 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *send_size = vars->send_size; vars 1019 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *recv_size = vars->recv_size; vars 1020 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *count = vars->count; vars 1021 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *start_pos = vars->start_pos; vars 1022 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *partial_send = vars->partial_send; vars 1023 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int nprocs = vars->nprocs; vars 1024 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int myrank = vars->myrank; vars 1025 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; vars 1026 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int iter = vars->iter; vars 1027 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int *buf_idx = vars->buf_idx; vars 1035 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_recv = nprocs_recv; vars 1039 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_send = nprocs_send; vars 1041 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->req2 = (MPI_Request *) vars 1052 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->buftype_is_contig) { vars 1056 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c MPI_Irecv(((char *)vars->buf) + buf_idx[i], recv_size[i], vars 1058 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->req2 + j); vars 1066 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_buf = recv_buf; vars 1075 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->req2 + j); vars 1102 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->comm, vars->req2 + nprocs_recv + j); vars 1121 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; vars 1123 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->nprocs_recv) { vars 1125 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (!vars->buftype_is_contig) vars 1126 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Fill_user_buffer(vars->fd, vars->buf, vars->flat_buf, vars 1127 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->recv_buf, vars->offset_list, vars->len_list, vars 1128 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c (unsigned*)vars->recv_size, vars 1129 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->req2, NULL, vars->recd_from_proc, vars 1130 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs, vars->contig_access_count, vars 1131 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->min_st_offset, vars->fd_size, vars->fd_start, vars 1132 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->fd_end, vars->buftype_extent); vars 1140 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_R_Iexchange_data_vars *vars = nbc_req->data.rd.red_vars; vars 1144 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->req2); vars 1146 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (!vars->buftype_is_contig) { vars 1147 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (i = 0; i < vars->nprocs; i++) vars 1148 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (vars->recv_size[i]) ADIOI_Free(vars->recv_buf[i]); vars 1149 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->recv_buf); vars 1155 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c next_fn = vars->next_fn; vars 1158 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars); vars 236 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = NULL; vars 265 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars = (ADIOI_GEN_IwriteStridedColl_vars *)ADIOI_Calloc( vars 267 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->data.wr.wsc_vars = vars; vars 270 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->fd = fd; vars 271 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->buf = buf; vars 272 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->count = count; vars 273 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->datatype = datatype; vars 274 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->file_ptr_type = file_ptr_type; vars 275 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->offset = offset; vars 279 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs = nprocs; vars 280 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->myrank = myrank; vars 285 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_for_coll = fd->hints->cb_nodes; vars 286 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->orig_fp = fd->fp_ind; vars 297 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->offset_list, &vars->len_list, vars 298 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->start_offset, &vars->end_offset, vars 299 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->contig_access_count); vars 305 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->st_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); vars 306 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->end_offsets = (ADIO_Offset *)ADIOI_Malloc(nprocs*sizeof(ADIO_Offset)); vars 308 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Iallgather(&vars->start_offset, 1, ADIO_OFFSET, vars 309 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->st_offsets, 1, ADIO_OFFSET, vars 310 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->comm, &vars->req_offset[0]); vars 312 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Iallgather(&vars->end_offset, 1, ADIO_OFFSET, vars 313 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->end_offsets, 1, ADIO_OFFSET, vars 314 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->comm, &vars->req_offset[1]); vars 326 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 327 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 328 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *st_offsets = vars->st_offsets; vars 329 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *end_offsets = vars->end_offsets; vars 340 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->interleave_count = interleave_count; vars 348 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 350 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 353 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Datatype datatype = vars->datatype; vars 359 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Datatype_iscontig(datatype, &vars->buftype_is_contig); vars 362 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c (!vars->interleave_count && (fd->hints->cb_write == ADIOI_HINT_AUTO))) vars 364 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c buf = vars->buf; vars 365 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c count = vars->count; vars 366 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c file_ptr_type = vars->file_ptr_type; vars 367 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c offset = vars->offset; vars 371 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->offset_list); vars 372 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->len_list); vars 373 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->st_offsets); vars 374 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->end_offsets); vars 377 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->fp_ind = vars->orig_fp; vars 386 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (vars->buftype_is_contig && filetype_is_contig) { vars 402 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (vars->buftype_is_contig && filetype_is_contig) { vars 407 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c off, &vars->req_ind_io, error_code); vars 410 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c 0, &vars->req_ind_io, error_code); vars 414 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c offset, &vars->req_ind_io, error_code); vars 422 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs = vars->nprocs; vars 428 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Calc_file_domains(vars->st_offsets, vars->end_offsets, nprocs, vars 429 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_for_coll, &vars->min_st_offset, vars 430 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->fd_start, &vars->fd_end, vars 431 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->hints->min_fdomain_size, &vars->fd_size, vars 437 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Calc_my_req(fd, vars->offset_list, vars->len_list, vars 438 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->contig_access_count, vars->min_st_offset, vars 439 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->fd_start, vars->fd_end, vars->fd_size, vars 440 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs, &vars->count_my_req_procs, vars 441 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->count_my_req_per_proc, &vars->my_req, vars 442 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->buf_idx); vars 454 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->fd = vars->fd; vars 455 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->count_my_req_procs = vars->count_my_req_procs; vars 456 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->count_my_req_per_proc = vars->count_my_req_per_proc; vars 457 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->my_req = vars->my_req; vars 458 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->nprocs = vars->nprocs; vars 459 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->myrank = vars->myrank; vars 460 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->count_others_req_procs_ptr = &vars->count_others_req_procs; vars 461 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->others_req_ptr = &vars->others_req; vars 470 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 472 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *my_req = vars->my_req; vars 473 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 476 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->count_my_req_per_proc); vars 490 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->fd = vars->fd; vars 491 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->buf = (char *)vars->buf; vars 492 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->datatype = vars->datatype; vars 493 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->nprocs = vars->nprocs; vars 494 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->myrank = vars->myrank; vars 495 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->others_req = vars->others_req; vars 496 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->offset_list = vars->offset_list; vars 497 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->len_list = vars->len_list; vars 498 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->contig_access_count = vars->contig_access_count; vars 499 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->min_st_offset = vars->min_st_offset; vars 500 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->fd_size = vars->fd_size; vars 501 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->fd_start = vars->fd_start; vars 502 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->fd_end = vars->fd_end; vars 503 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->buf_idx = vars->buf_idx; vars 512 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 513 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 526 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->old_error = *error_code; vars 534 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->error_code = *error_code; vars 536 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Ibcast(&vars->error_code, 1, MPI_INT, vars 538 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->req_err); vars 540 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->tmp_error = *error_code; vars 541 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Iallreduce(&vars->tmp_error, &vars->error_code, 1, vars 543 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->req_err); vars 552 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 553 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 554 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Datatype datatype = vars->datatype; vars 555 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; vars 556 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 557 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int old_error = vars->old_error; vars 571 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (!vars->buftype_is_contig) ADIOI_Delete_flattened(datatype); vars 583 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->buf_idx); vars 584 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->offset_list); vars 585 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->len_list); vars 586 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->st_offsets); vars 587 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->end_offsets); vars 588 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->fd_start); vars 589 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->fd_end); vars 602 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_GEN_IwriteStridedColl_vars *vars = nbc_req->data.wr.wsc_vars; vars 607 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Type_size_x(vars->datatype, &size); vars 608 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nbc_req->nbytes = size * vars->count; vars 624 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 625 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 626 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Datatype datatype = vars->datatype; vars 627 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 628 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; vars 656 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->coll_bufsize = coll_bufsize; vars 674 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->st_loc = st_loc; vars 675 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->end_loc = end_loc; vars 679 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->ntimes = (int)((end_loc - st_loc + coll_bufsize) / coll_bufsize); vars 682 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->ntimes = 0; /* this process does no writing. */ vars 685 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Iallreduce(&vars->ntimes, &vars->max_ntimes, 1, MPI_INT, vars 686 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_MAX, fd->comm, &vars->req1); vars 688 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->write_buf = fd->io_buf; vars 690 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->curr_offlen_ptr = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 693 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->count = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 697 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->partial_recv = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 702 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_size = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 706 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->recv_size = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 709 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->sent_to_proc = (int *)ADIOI_Calloc(nprocs, sizeof(int)); vars 713 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_buf_idx = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 714 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->curr_to_proc = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 715 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->done_to_proc = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 718 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->start_pos = (int *)ADIOI_Malloc(nprocs*sizeof(int)); vars 722 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Datatype_iscontig(datatype, &vars->buftype_is_contig); vars 723 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (!vars->buftype_is_contig) { vars 724 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->flat_buf = ADIOI_Flatten_and_find(datatype); vars 726 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Type_get_extent(datatype, &lb, &vars->buftype_extent); vars 740 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->done = 0; vars 741 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->off = st_loc; vars 750 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 765 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (vars->m >= vars->ntimes) { vars 770 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c nprocs = vars->nprocs; vars 771 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req = vars->others_req; vars 773 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c off = vars->off; vars 774 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c write_buf = vars->write_buf; vars 775 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c curr_offlen_ptr = vars->curr_offlen_ptr; vars 776 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c count = vars->count; vars 777 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c recv_size = vars->recv_size; vars 778 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c partial_recv = vars->partial_recv; vars 779 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c start_pos = vars->start_pos; vars 800 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c size = ADIOI_MIN((unsigned)vars->coll_bufsize, vars 801 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->end_loc - vars->st_loc + 1 - vars->done); vars 802 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->size = size; vars 866 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd = vars->fd; vars 867 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buf = vars->buf; vars 868 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->write_buf = vars->write_buf; vars 869 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->flat_buf = vars->flat_buf; vars 870 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->offset_list = vars->offset_list; vars 871 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->len_list = vars->len_list; vars 872 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->send_size = vars->send_size; vars 873 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->recv_size = vars->recv_size; vars 874 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->off = vars->off; vars 875 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->size = vars->size; vars 876 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->count = vars->count; vars 877 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->start_pos = vars->start_pos; vars 878 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->partial_recv = vars->partial_recv; vars 879 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->sent_to_proc = vars->sent_to_proc; vars 880 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->nprocs = vars->nprocs; vars 881 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->myrank = vars->myrank; vars 882 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buftype_is_contig = vars->buftype_is_contig; vars 883 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->contig_access_count = vars->contig_access_count; vars 884 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->min_st_offset = vars->min_st_offset; vars 885 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_size = vars->fd_size; vars 886 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_start = vars->fd_start; vars 887 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_end = vars->fd_end; vars 888 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->others_req = vars->others_req; vars 889 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->send_buf_idx = vars->send_buf_idx; vars 890 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->curr_to_proc = vars->curr_to_proc; vars 891 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->done_to_proc = vars->done_to_proc; vars 892 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->hole = &vars->hole; vars 893 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->iter = vars->m; vars 894 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buftype_extent = vars->buftype_extent; vars 895 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buf_idx = vars->buf_idx; vars 904 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 905 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 906 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 907 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset size = vars->size; vars 908 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c char *write_buf = vars->write_buf; vars 909 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *count = vars->count; vars 921 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_EXPLICIT_OFFSET, vars->off, &status, vars 925 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_EXPLICIT_OFFSET, vars->off, &vars->req3, vars 939 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 940 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset size = vars->size; vars 942 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->off += size; vars 943 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->done += size; vars 946 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->m++; vars 953 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 954 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 955 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *count = vars->count; vars 956 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; vars 961 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->m = vars->ntimes; vars 968 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 969 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset size = vars->size; vars 973 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (vars->m >= vars->max_ntimes) { vars 985 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd = vars->fd; vars 986 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buf = vars->buf; vars 987 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->write_buf = vars->write_buf; vars 988 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->flat_buf = vars->flat_buf; vars 989 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->offset_list = vars->offset_list; vars 990 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->len_list = vars->len_list; vars 991 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->send_size = vars->send_size; vars 992 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->recv_size = vars->recv_size; vars 993 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->off = vars->off; vars 994 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->size = (int)vars->size; vars 995 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->count = vars->count; vars 996 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->start_pos = vars->start_pos; vars 997 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->partial_recv = vars->partial_recv; vars 998 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->sent_to_proc = vars->sent_to_proc; vars 999 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->nprocs = vars->nprocs; vars 1000 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->myrank = vars->myrank; vars 1001 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buftype_is_contig = vars->buftype_is_contig; vars 1002 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->contig_access_count = vars->contig_access_count; vars 1003 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->min_st_offset = vars->min_st_offset; vars 1004 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_size = vars->fd_size; vars 1005 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_start = vars->fd_start; vars 1006 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_end = vars->fd_end; vars 1007 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->others_req = vars->others_req; vars 1008 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->send_buf_idx = vars->send_buf_idx; vars 1009 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->curr_to_proc = vars->curr_to_proc; vars 1010 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->done_to_proc = vars->done_to_proc; vars 1011 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->hole = &vars->hole; vars 1012 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->iter = vars->m; vars 1013 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buftype_extent = vars->buftype_extent; vars 1014 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->buf_idx = vars->buf_idx; vars 1024 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 1026 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->m++; vars 1032 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Iexch_and_write_vars *vars = nbc_req->data.wr.eaw_vars; vars 1035 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->curr_offlen_ptr); vars 1036 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->count); vars 1037 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->partial_recv); vars 1038 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->send_size); vars 1039 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->recv_size); vars 1040 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->sent_to_proc); vars 1041 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->start_pos); vars 1042 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->send_buf_idx); vars 1043 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->curr_to_proc); vars 1044 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->done_to_proc); vars 1046 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c next_fn = vars->next_fn; vars 1059 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; vars 1064 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c *error_code = MPI_Ialltoall(vars->recv_size, 1, MPI_INT, vars->send_size, 1, vars 1065 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_INT, vars->fd->comm, &vars->req1); vars 1073 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; vars 1074 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 1075 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; vars 1076 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset off = vars->off; vars 1077 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int size = vars->size; vars 1078 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *count = vars->count; vars 1079 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *start_pos = vars->start_pos; vars 1080 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *partial_recv = vars->partial_recv; vars 1081 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 1082 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; vars 1083 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *hole = vars->hole; vars 1094 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_recv = nprocs_recv; vars 1098 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->recv_types = recv_types; vars 1176 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_IreadContig(fd, vars->write_buf, size, MPI_BYTE, vars 1177 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_EXPLICIT_OFFSET, off, &vars->req2, vars 1178 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->err); vars 1190 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; vars 1191 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 1192 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c void *buf = vars->buf; vars 1193 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *send_size = vars->send_size; vars 1194 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *recv_size = vars->recv_size; vars 1195 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 1196 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int myrank = vars->myrank; vars 1197 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int iter = vars->iter; vars 1198 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *buf_idx = vars->buf_idx; vars 1200 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_recv = vars->nprocs_recv; vars 1201 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Datatype *recv_types = vars->recv_types; vars 1209 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_send = nprocs_send; vars 1213 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->requests = (MPI_Request *) vars 1215 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_req = vars->requests; vars 1218 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->requests = (MPI_Request *) vars 1227 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->comm, vars->requests+j); vars 1231 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_req = vars->requests + nprocs_recv; vars 1240 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (vars->buftype_is_contig) { vars 1246 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_req+j); vars 1254 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_buf = send_buf; vars 1259 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Fill_send_buffer(fd, buf, vars->flat_buf, send_buf, vars 1260 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->offset_list, vars->len_list, send_size, vars 1261 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_req, vars 1262 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->sent_to_proc, nprocs, myrank, vars 1263 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->contig_access_count, vars 1264 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->min_st_offset, vars->fd_size, vars 1265 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->fd_start, vars->fd_end, vars 1266 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->send_buf_idx, vars->curr_to_proc, vars 1267 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->done_to_proc, iter, vars 1268 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->buftype_extent); vars 1273 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->req3 = (MPI_Request *) vars 1282 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c fd->comm, vars->req3+j); vars 1297 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; vars 1298 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 1299 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_send = vars->nprocs_send; vars 1300 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs_recv = vars->nprocs_recv; vars 1301 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Datatype *recv_types = vars->recv_types; vars 1310 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Testall(nprocs_send, vars->send_req, &i, MPI_STATUSES_IGNORE); vars 1313 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c MPI_Testall(nprocs_send+nprocs_recv, vars->requests, &i, vars 1326 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_W_Iexchange_data_vars *vars = nbc_req->data.wr.wed_vars; vars 1328 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_File fd = vars->fd; vars 1329 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int *send_size = vars->send_size; vars 1330 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int nprocs = vars->nprocs; vars 1331 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c char **send_buf = vars->send_buf; vars 1334 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (fd->atomicity) ADIOI_Free(vars->req3); vars 1339 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->requests); vars 1340 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (!vars->buftype_is_contig && vars->nprocs_send) { vars 1346 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c next_fn = vars->next_fn; vars 1349 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars); vars 29 ompi/mpi/tool/category_get_cvars.c const int *vars; vars 46 ompi/mpi/tool/category_get_cvars.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); vars 49 ompi/mpi/tool/category_get_cvars.c indices[i] = vars[i]; vars 29 ompi/mpi/tool/category_get_pvars.c const int *vars; vars 46 ompi/mpi/tool/category_get_pvars.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_pvars, int); vars 49 ompi/mpi/tool/category_get_pvars.c indices[i] = vars[i]; vars 501 opal/mca/base/mca_base_var_group.c int *vars; vars 510 opal/mca/base/mca_base_var_group.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); vars 513 opal/mca/base/mca_base_var_group.c if (0 <= vars[i]) { vars 514 opal/mca/base/mca_base_var_group.c (void) mca_base_var_set_flag (vars[i], flags, set); vars 415 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c int *vars; vars 424 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c vars = PMIX_VALUE_ARRAY_GET_BASE(&group->group_vars, int); vars 427 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (0 <= vars[i]) { vars 428 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c (void) pmix_mca_base_var_set_flag (vars[i], flags, set); vars 669 orte/mca/schizo/ompi/schizo_ompi.c char **vars; vars 709 orte/mca/schizo/ompi/schizo_ompi.c vars = NULL; vars 710 orte/mca/schizo/ompi/schizo_ompi.c if (OPAL_SUCCESS == mca_base_var_process_env_list_from_file(&vars) && vars 711 orte/mca/schizo/ompi/schizo_ompi.c NULL != vars) { vars 712 orte/mca/schizo/ompi/schizo_ompi.c for (i=0; NULL != vars[i]; i++) { vars 713 orte/mca/schizo/ompi/schizo_ompi.c value = strchr(vars[i], '='); vars 719 orte/mca/schizo/ompi/schizo_ompi.c opal_setenv(vars[i], value, true, dstenv); vars 721 orte/mca/schizo/ompi/schizo_ompi.c opal_setenv(vars[i], value, true, &orte_forwarded_envars); vars 724 orte/mca/schizo/ompi/schizo_ompi.c opal_argv_free(vars); vars 764 orte/mca/schizo/ompi/schizo_ompi.c vars = NULL; vars 765 orte/mca/schizo/ompi/schizo_ompi.c if (OPAL_SUCCESS == mca_base_var_process_env_list(env_set_flag, &vars) && vars 766 orte/mca/schizo/ompi/schizo_ompi.c NULL != vars) { vars 767 orte/mca/schizo/ompi/schizo_ompi.c for (i=0; NULL != vars[i]; i++) { vars 768 orte/mca/schizo/ompi/schizo_ompi.c value = strchr(vars[i], '='); vars 774 orte/mca/schizo/ompi/schizo_ompi.c opal_setenv(vars[i], value, true, dstenv); vars 776 orte/mca/schizo/ompi/schizo_ompi.c opal_setenv(vars[i], value, true, &orte_forwarded_envars); vars 778 orte/mca/schizo/ompi/schizo_ompi.c opal_argv_free(vars);