others_req 60 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c mca_common_ompio_access_array_t *others_req, others_req 84 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c mca_common_ompio_access_array_t *others_req, others_req 144 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c mca_common_ompio_access_array_t *my_req=NULL, *others_req=NULL; others_req 444 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &others_req); others_req 463 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c others_req, others_req 523 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free (others_req); others_req 535 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c mca_common_ompio_access_array_t *others_req, others_req 566 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (others_req[i].count) { others_req 567 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c st_loc = others_req[i].offsets[0]; others_req 568 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c end_loc = others_req[i].offsets[0]; others_req 574 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c for(j=0;j< others_req[i].count; j++){ others_req 576 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPIO_MIN(st_loc, others_req[i].offsets[j]); others_req 578 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPIO_MAX(end_loc, (others_req[i].offsets[j] + others_req 579 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c others_req[i].lens[j] - 1)); others_req 667 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (others_req[i].count) { others_req 669 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; others_req 674 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c req_off = others_req[i].offsets[j] + others_req 676 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c req_len = others_req[i].lens[j] - others_req 680 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c others_req[i].offsets[j] = req_off; others_req 681 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c others_req[i].lens[j] = req_len; others_req 684 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c req_off = others_req[i].offsets[j]; others_req 685 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c req_len = others_req[i].lens[j]; others_req 690 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &(others_req[i].mem_ptrs[j])); others_req 697 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if ((j+1 < others_req[i].count) && others_req 698 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c (others_req[i].offsets[j+1] < others_req 703 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c real_off + real_size - others_req[i].offsets[j+1]); others_req 783 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c flat_buf, others_req, m, buf_idx, others_req 809 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c flat_buf, others_req, m, buf_idx, others_req 837 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c mca_common_ompio_access_array_t *others_req, others_req 942 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c tmp = others_req[i].lens[k]; others_req 943 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c others_req[i].lens[k] = partial_send[i]; others_req 947 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &(others_req[i].lens[start_pos[i]]), others_req 948 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 964 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c if (partial_send[i]) others_req[i].lens[k] = tmp; others_req 62 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c mca_common_ompio_access_array_t *others_req, others_req 90 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c mca_common_ompio_access_array_t *others_req, others_req 123 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c void two_phase_heap_merge(mca_common_ompio_access_array_t *others_req, others_req 169 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c mca_common_ompio_access_array_t *my_req=NULL, *others_req=NULL; others_req 507 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c &others_req); others_req 524 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req, others_req 585 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c free (others_req); others_req 597 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c mca_common_ompio_access_array_t *others_req, others_req 635 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if (others_req[i].count) { others_req 636 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c st_loc = others_req[i].offsets[0]; others_req 637 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c end_loc = others_req[i].offsets[0]; others_req 643 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for(j=0;j< others_req[i].count; j++){ others_req 644 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c st_loc = OMPIO_MIN(st_loc, others_req[i].offsets[j]); others_req 645 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c end_loc = OMPIO_MAX(end_loc, (others_req[i].offsets[j] + others_req[i].lens[j] - 1)); others_req 753 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c if(others_req[i].count){ others_req 755 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; j++) { others_req 759 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c req_off = others_req[i].offsets[j] + others_req 761 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c req_len = others_req[i].lens[j] - others_req 765 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req[i].offsets[j] = req_off; others_req 766 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req[i].lens[j] = req_len; others_req 769 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c req_off = others_req[i].offsets[j]; others_req 770 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c req_len = others_req[i].lens[j]; others_req 782 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c &(others_req[i].mem_ptrs[j])); others_req 785 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req[i].mem_ptrs[j]); others_req 809 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, flat_buf, others_req, others_req 900 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, flat_buf,others_req, others_req 943 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c mca_common_ompio_access_array_t *others_req, others_req 1001 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c tmp_len[i] = others_req[i].lens[k]; others_req 1002 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req[i].lens[k] = partial_recv[i]; others_req 1005 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c &(others_req[i].lens[start_pos[i]]), others_req 1006 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 1032 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c two_phase_heap_merge(others_req, count, srt_off, srt_len, start_pos, fh->f_size,fh->f_rank, nprocs_recv, sum); others_req 1038 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c others_req[i].lens[k] = tmp_len[i]; others_req 1407 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c void two_phase_heap_merge( mca_common_ompio_access_array_t *others_req, others_req 1434 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c a[j].off_list = &(others_req[i].offsets[start_pos[i]]); others_req 1435 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c a[j].len_list = &(others_req[i].lens[start_pos[i]]); others_req 206 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c mca_common_ompio_access_array_t *others_req=NULL; others_req 237 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req = *others_req_ptr; others_req 242 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].count = count_others_req_per_proc[i]; others_req 243 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].offsets = (OMPI_MPI_OFFSET_TYPE *) others_req 245 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].lens = (int *) others_req 247 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].mem_ptrs = (MPI_Aint *) others_req 252 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].count = 0; others_req 267 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c if (others_req[i].count){ others_req 268 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c ret = MCA_PML_CALL(irecv(others_req[i].offsets, others_req 269 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].count, others_req 281 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c ret = MCA_PML_CALL(irecv(others_req[i].lens, others_req 282 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c others_req[i].count, others_req 661 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Access *others_req; others_req 689 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req = *others_req_ptr; others_req 705 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].count = count_others_req_per_proc[i]; others_req 707 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].offsets = (ADIO_Offset *) others_req 709 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].lens = others_req 712 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].mem_ptrs = (MPI_Aint *) others_req 719 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].count = 0; others_req 720 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].offsets = NULL; others_req 721 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c others_req[i].lens = NULL; others_req 774 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c memcpy(others_req[i].offsets, others_req 798 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c memcpy(others_req[i].lens, others_req 36 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *others_req, ADIO_Offset *offset_list, others_req 53 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Access *others_req, others_req 67 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Access *others_req, others_req 106 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Access *others_req; others_req 431 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &others_req); others_req 437 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &others_req); others_req 458 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req, offset_list, others_req 471 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (others_req[i].count) { others_req 472 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(others_req[i].offsets); others_req 473 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(others_req[i].lens); others_req 474 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 477 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(others_req); others_req 503 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *others_req, ADIO_Offset *offset_list, others_req 546 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (others_req[i].count) { others_req 547 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c st_loc = others_req[i].offsets[0]; others_req 548 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c end_loc = others_req[i].offsets[0]; others_req 555 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (j=0; j<others_req[i].count; j++) { others_req 556 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 557 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 558 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c + others_req[i].lens[j] - 1)); others_req 672 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c DBG_FPRINTF(stderr, "rank %d, i %d, others_count %d\n", rank, i, others_req[i].count); others_req 674 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (others_req[i].count) { others_req 676 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; others_req 681 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c req_off = others_req[i].offsets[j] + others_req 683 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c req_len = others_req[i].lens[j] - others_req 687 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req[i].offsets[j] = req_off; others_req 688 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req[i].lens[j] = req_len; others_req 691 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c req_off = others_req[i].offsets[j]; others_req 692 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c req_len = others_req[i].lens[j]; others_req 698 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &(others_req[i].mem_ptrs[j])); others_req 705 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if ((j+1 < others_req[i].count) && others_req 706 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c (others_req[i].offsets[j+1] < others_req 711 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c real_off + real_size - others_req[i].offsets[j+1]); others_req 759 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req, others_req 769 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req, others_req 808 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req, m, others_req 818 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req, others_req 845 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Access *others_req, others_req 914 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c tmp = others_req[i].lens[k]; others_req 915 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req[i].lens[k] = partial_send[i]; others_req 918 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &(others_req[i].lens[start_pos[i]]), others_req 919 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 926 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (partial_send[i]) others_req[i].lens[k] = tmp; others_req 1139 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Access *others_req, others_req 1184 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c tmp = others_req[i].lens[k]; others_req 1185 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c others_req[i].lens[k] = partial_send[i]; others_req 1189 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_ENSURE_AINT_FITS_IN_PTR( others_req[i].mem_ptrs[ start_pos[i]+j ]); others_req 1190 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c from_ptr = (char *) ADIOI_AINT_CAST_TO_VOID_PTR ( others_req[i].mem_ptrs[ start_pos[i]+j ] ); others_req 1191 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c len = others_req[i].lens[ start_pos[i]+j ] ; others_req 1195 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c if (partial_send[i]) others_req[i].lens[k] = tmp; others_req 44 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c *others_req, ADIO_Offset *offset_list, others_req 59 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Access *others_req, others_req 77 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Access *others_req, others_req 104 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c static void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 124 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Access *others_req; others_req 444 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &count_others_req_procs, &others_req); others_req 449 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &count_others_req_procs, &others_req); others_req 464 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, offset_list, others_req 477 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (others_req[i].count) { others_req 478 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(others_req[i].offsets); others_req 479 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(others_req[i].lens); others_req 480 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 483 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(others_req); others_req 615 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c *others_req, ADIO_Offset *offset_list, others_req 668 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (others_req[i].count) { others_req 669 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c st_loc = others_req[i].offsets[0]; others_req 670 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c end_loc = others_req[i].offsets[0]; others_req 676 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (j=0; j < others_req[i].count; j++) { others_req 677 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 678 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 679 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c + others_req[i].lens[j] - 1)); others_req 805 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (others_req[i].count) { others_req 807 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; j++) { others_req 811 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c req_off = others_req[i].offsets[j] + others_req 813 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c req_len = others_req[i].lens[j] - others_req 817 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].offsets[j] = req_off; others_req 818 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].lens[j] = req_len; others_req 821 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c req_off = others_req[i].offsets[j]; others_req 822 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c req_len = others_req[i].lens[j]; others_req 828 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &(others_req[i].mem_ptrs[j])); others_req 838 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if ((j+1 < others_req[i].count) && others_req 839 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c (others_req[i].offsets[j+1] < off+size)) others_req 872 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, curr_to_proc, others_req 883 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, curr_to_proc, others_req 956 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, others_req 967 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req, send_buf_idx, others_req 1014 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Access *others_req, others_req 1050 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c tmp_len[i] = others_req[i].lens[k]; others_req 1051 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].lens[k] = partial_recv[i]; others_req 1054 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &(others_req[i].lens[start_pos[i]]), others_req 1055 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 1073 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Heap_merge(others_req, count, srt_off, srt_len, start_pos, others_req 1080 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].lens[k] = tmp_len[i]; others_req 1402 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c static void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 1420 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c a[j].off_list = &(others_req[i].offsets[start_pos[i]]); others_req 1421 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c a[j].len_list = &(others_req[i].lens[start_pos[i]]); others_req 1537 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Access *others_req, others_req 1633 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Heap_merge(others_req, count, srt_off, srt_len, start_pos, others_req 1680 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c tmp_len[i] = others_req[i].lens[k]; others_req 1681 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].lens[k] = partial_recv[i]; others_req 1686 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_ENSURE_AINT_FITS_IN_PTR(others_req[i].mem_ptrs[ start_pos[i]+j ]); others_req 1687 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c to_ptr = (char *) ADIOI_AINT_CAST_TO_VOID_PTR ( others_req[i].mem_ptrs[ start_pos[i]+j ] ); others_req 1688 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c len = others_req[i].lens[ start_pos[i]+j ] ; others_req 1696 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c others_req[i].lens[k] = tmp_len[i]; others_req 18 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Access *others_req, others_req 50 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Access *others_req, others_req 58 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 78 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Access *others_req; others_req 191 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c &others_req); others_req 196 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c others_req, my_req, offset_list, len_list, others_req 242 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (others_req[i].count) { others_req 243 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(others_req[i].offsets); others_req 244 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(others_req[i].lens); others_req 245 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 248 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Free(others_req); others_req 288 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c int myrank, ADIOI_Access *others_req, others_req 339 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (others_req[i].count) { others_req 340 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c st_loc = others_req[i].offsets[0]; others_req 341 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c end_loc = others_req[i].offsets[0]; others_req 346 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (j = 0; j < others_req[i].count; j++) { others_req 347 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 348 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] + others_req 349 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c others_req[i].lens[j] - 1)); others_req 379 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (j = 0; j < others_req[i].count; j ++) { others_req 380 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c req_off = others_req[i].offsets[j]; others_req 493 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (others_req[i].count) { others_req 495 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c for (j = recv_curr_offlen_ptr[i]; j < others_req[i].count; j++) { others_req 496 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c req_off = others_req[i].offsets[j]; others_req 497 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c req_len = others_req[i].lens[j]; others_req 502 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c &(others_req[i].mem_ptrs[j])); others_req 518 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c striping_info, others_req, send_buf_idx, others_req 625 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Access *others_req, others_req 657 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c &(others_req[i].lens[start_pos[i]]), others_req 658 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 684 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c ADIOI_Heap_merge(others_req, count, *srt_off, *srt_len, start_pos, others_req 443 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Access *others_req; others_req 456 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req = *others_req_ptr; others_req 461 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].count = count_others_req_per_proc[i]; others_req 462 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].offsets = (ADIO_Offset *) others_req 464 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].lens = others_req 466 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].mem_ptrs = (MPI_Aint *) others_req 470 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c else others_req[i].count = 0; others_req 481 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (others_req[i].count) { others_req 482 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c MPI_Irecv(others_req[i].offsets, others_req[i].count, others_req 485 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c MPI_Irecv(others_req[i].lens, others_req[i].count, others_req 568 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIOI_Access *others_req; others_req 571 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req = *others_req_ptr; others_req 576 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].count = count_others_req_per_proc[i]; others_req 577 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].offsets = (ADIO_Offset *) others_req 579 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].lens = others_req 581 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c others_req[i].mem_ptrs = (MPI_Aint *) others_req 585 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c else others_req[i].count = 0; others_req 598 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (others_req[i].count) { others_req 599 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c MPI_Irecv(others_req[i].offsets, others_req[i].count, others_req 602 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c MPI_Irecv(others_req[i].lens, others_req[i].count, others_req 40 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req; others_req 79 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req; others_req 145 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req; others_req 463 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c cor_vars->others_req_ptr = &vars->others_req; others_req 501 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->others_req = vars->others_req; others_req 521 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; others_req 529 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (others_req[i].count) { others_req 530 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(others_req[i].offsets); others_req 531 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(others_req[i].lens); others_req 532 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 535 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(others_req); others_req 581 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; others_req 610 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (others_req[i].count) { others_req 611 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c st_loc = others_req[i].offsets[0]; others_req 612 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c end_loc = others_req[i].offsets[0]; others_req 619 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (j = 0; j < others_req[i].count; j++) { others_req 620 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 621 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 622 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c + others_req[i].lens[j] - 1)); others_req 694 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req; others_req 714 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c others_req = vars->others_req; others_req 774 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->myrank, i, others_req[i].count); others_req 776 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (others_req[i].count) { others_req 778 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c for (j = curr_offlen_ptr[i]; j < others_req[i].count; j++) { others_req 782 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c req_off = others_req[i].offsets[j] + partial_send[i]; others_req 783 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c req_len = others_req[i].lens[j] - partial_send[i]; others_req 786 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c others_req[i].offsets[j] = req_off; others_req 787 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c others_req[i].lens[j] = req_len; others_req 790 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c req_off = others_req[i].offsets[j]; others_req 791 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c req_len = others_req[i].lens[j]; others_req 797 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &(others_req[i].mem_ptrs[j])); others_req 804 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if ((j+1 < others_req[i].count) && others_req 805 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c (others_req[i].offsets[j+1] < real_off + real_size)) { others_req 809 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c real_off + real_size - others_req[i].offsets[j+1]); others_req 850 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->others_req = vars->others_req; others_req 959 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->others_req = vars->others_req; others_req 1025 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Access *others_req = vars->others_req; others_req 1092 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c tmp = others_req[i].lens[k]; others_req 1093 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c others_req[i].lens[k] = partial_send[i]; others_req 1096 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &(others_req[i].lens[start_pos[i]]), others_req 1097 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 1104 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c if (partial_send[i]) others_req[i].lens[k] = tmp; others_req 38 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req; others_req 80 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req; others_req 151 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req; others_req 187 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 461 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c cor_vars->others_req_ptr = &vars->others_req; others_req 495 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->others_req = vars->others_req; others_req 555 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; others_req 575 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (others_req[i].count) { others_req 576 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(others_req[i].offsets); others_req 577 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(others_req[i].lens); others_req 578 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 581 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(others_req); others_req 628 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; others_req 660 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (others_req[i].count) { others_req 661 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c st_loc = others_req[i].offsets[0]; others_req 662 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c end_loc = others_req[i].offsets[0]; others_req 668 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (j = 0; j < others_req[i].count; j++) { others_req 669 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 670 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 671 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c + others_req[i].lens[j] - 1)); others_req 752 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req; others_req 771 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req = vars->others_req; others_req 805 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (others_req[i].count) { others_req 807 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c for (j = curr_offlen_ptr[i]; j < others_req[i].count; j++) { others_req 811 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c req_off = others_req[i].offsets[j] + others_req 813 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c req_len = others_req[i].lens[j] - others_req 817 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req[i].offsets[j] = req_off; others_req 818 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req[i].lens[j] = req_len; others_req 821 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c req_off = others_req[i].offsets[j]; others_req 822 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c req_len = others_req[i].lens[j]; others_req 828 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &(others_req[i].mem_ptrs[j])); others_req 838 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if ((j+1 < others_req[i].count) && others_req 839 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c (others_req[i].offsets[j+1] < off+size)) others_req 888 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->others_req = vars->others_req; others_req 1007 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->others_req = vars->others_req; others_req 1082 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Access *others_req = vars->others_req; others_req 1108 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c tmp_len[i] = others_req[i].lens[k]; others_req 1109 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req[i].lens[k] = partial_recv[i]; others_req 1112 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &(others_req[i].lens[start_pos[i]]), others_req 1113 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 1133 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Heap_merge(others_req, count, srt_off, srt_len, start_pos, others_req 1141 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c others_req[i].lens[k] = tmp_len[i]; others_req 22 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *others_req, ADIO_Offset *offset_list, others_req 39 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Access *others_req, others_req 70 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Access *others_req; others_req 222 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &others_req); others_req 241 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req, offset_list, others_req 249 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (others_req[i].count) { others_req 250 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(others_req[i].offsets); others_req 251 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(others_req[i].lens); others_req 252 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 255 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(others_req); others_req 500 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *others_req, ADIO_Offset *offset_list, others_req 541 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (others_req[i].count) { others_req 542 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c st_loc = others_req[i].offsets[0]; others_req 543 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c end_loc = others_req[i].offsets[0]; others_req 550 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (j=0; j<others_req[i].count; j++) { others_req 551 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 552 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 553 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c + others_req[i].lens[j] - 1)); others_req 660 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c DBG_FPRINTF(stderr, "rank %d, i %d, others_count %d\n", rank, i, others_req[i].count); others_req 662 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (others_req[i].count) { others_req 664 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; others_req 669 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c req_off = others_req[i].offsets[j] + others_req 671 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c req_len = others_req[i].lens[j] - others_req 675 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req[i].offsets[j] = req_off; others_req 676 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req[i].lens[j] = req_len; others_req 679 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c req_off = others_req[i].offsets[j]; others_req 680 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c req_len = others_req[i].lens[j]; others_req 686 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &(others_req[i].mem_ptrs[j])); others_req 693 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if ((j+1 < others_req[i].count) && others_req 694 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c (others_req[i].offsets[j+1] < others_req 699 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c real_off + real_size - others_req[i].offsets[j+1]); others_req 731 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req, others_req 760 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req, m, others_req 781 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Access *others_req, others_req 850 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c tmp = others_req[i].lens[k]; others_req 851 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c others_req[i].lens[k] = partial_send[i]; others_req 854 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &(others_req[i].lens[start_pos[i]]), others_req 855 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 862 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c if (partial_send[i]) others_req[i].lens[k] = tmp; others_req 19 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c *others_req, ADIO_Offset *offset_list, others_req 34 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Access *others_req, others_req 49 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 69 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Access *others_req; others_req 195 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c &count_others_req_procs, &others_req); others_req 209 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req, offset_list, others_req 256 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (others_req[i].count) { others_req 257 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(others_req[i].offsets); others_req 258 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(others_req[i].lens); others_req 259 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(others_req[i].mem_ptrs); others_req 262 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(others_req); others_req 299 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c *others_req, ADIO_Offset *offset_list, others_req 344 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (others_req[i].count) { others_req 345 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c st_loc = others_req[i].offsets[0]; others_req 346 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c end_loc = others_req[i].offsets[0]; others_req 352 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (j=0; j < others_req[i].count; j++) { others_req 353 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c st_loc = ADIOI_MIN(st_loc, others_req[i].offsets[j]); others_req 354 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c end_loc = ADIOI_MAX(end_loc, (others_req[i].offsets[j] others_req 355 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c + others_req[i].lens[j] - 1)); others_req 447 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (others_req[i].count) { others_req 449 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c for (j=curr_offlen_ptr[i]; j<others_req[i].count; j++) { others_req 453 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c req_off = others_req[i].offsets[j] + others_req 455 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c req_len = others_req[i].lens[j] - others_req 459 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req[i].offsets[j] = req_off; others_req 460 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req[i].lens[j] = req_len; others_req 463 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c req_off = others_req[i].offsets[j]; others_req 464 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c req_len = others_req[i].lens[j]; others_req 470 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c &(others_req[i].mem_ptrs[j])); others_req 480 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if ((j+1 < others_req[i].count) && others_req 481 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c (others_req[i].offsets[j+1] < off+size)) others_req 509 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req, send_buf_idx, curr_to_proc, others_req 539 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req, send_buf_idx, others_req 573 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Access *others_req, others_req 609 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c tmp_len[i] = others_req[i].lens[k]; others_req 610 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req[i].lens[k] = partial_recv[i]; others_req 613 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c &(others_req[i].lens[start_pos[i]]), others_req 614 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c &(others_req[i].mem_ptrs[start_pos[i]]), others_req 634 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Heap_merge(others_req, count, srt_off, srt_len, start_pos, others_req 642 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c others_req[i].lens[k] = tmp_len[i]; others_req 969 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c void ADIOI_Heap_merge(ADIOI_Access *others_req, int *count, others_req 987 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c a[j].off_list = &(others_req[i].offsets[start_pos[i]]); others_req 988 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c a[j].len_list = &(others_req[i].lens[start_pos[i]]); others_req 565 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIOI_Access *others_req;