fd_end 73 ompi/mca/fcoll/two_phase/fcoll_two_phase.h OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 90 ompi/mca/fcoll/two_phase/fcoll_two_phase.h OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 66 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 82 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 103 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 142 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_start=NULL, *fd_end=NULL, min_st_offset = 0; fd_end 405 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c &fd_end, fd_end 417 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c i, fd_start[i], i, fd_end[i], local_count); fd_end 426 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c fd_end, fd_end 469 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c fd_end, fd_end 524 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c free (fd_end); fd_end 541 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 782 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c min_st_offset, fd_size, fd_start, fd_end, fd_end 808 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c min_st_offset, fd_size, fd_start, fd_end, fd_end 835 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 985 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c min_st_offset, fd_size, fd_start, fd_end, fd_end 1077 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 1127 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_read_all.c fd_end, fd_end 68 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 88 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 110 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 167 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_start=NULL, *fd_end=NULL, min_st_offset; fd_end 464 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c &fd_end, fd_end 477 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c i, fd_start[i], i, fd_end[i], local_count); fd_end 487 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, fd_end 530 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, fd_end 584 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c free (fd_end); fd_end 603 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 809 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, flat_buf, others_req, fd_end 900 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, flat_buf,others_req, fd_end 941 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 1192 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_start, fd_end, send_buf_idx, fd_end 1299 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 1340 ompi/mca/fcoll/two_phase/fcoll_two_phase_file_write_all.c fd_end, fd_end 55 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c OMPI_MPI_OFFSET_TYPE min_st_offset, max_end_offset, *fd_start=NULL, *fd_end=NULL, fd_size; fd_end 88 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end = *fd_end_ptr; fd_end 104 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[0] = end_off - 1; fd_end 108 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_start[i] = fd_end[i-1] + 1; fd_end 116 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[i] = end_off - 1; fd_end 118 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[nprocs_for_coll-1] = max_end_offset; fd_end 122 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[0] = min_st_offset + fd_size - 1; fd_end 125 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_start[i] = fd_end[i-1] + 1; fd_end 126 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[i] = fd_start[i] + fd_size - 1; fd_end 133 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_start[i] = fd_end[i] = -1; fd_end 134 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c if (fd_end[i] > max_end_offset) fd_end 135 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end[i] = max_end_offset; fd_end 152 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 166 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c while (off > fd_end[rank_index]) rank_index++; fd_end 180 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c avail_bytes = fd_end[rank_index] + 1 - off; fd_end 355 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c OMPI_MPI_OFFSET_TYPE *fd_end, fd_end 400 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_start, fd_end, striping_unit, num_aggregators,aggregator_list); fd_end 408 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_size, fd_start, fd_end, striping_unit, fd_end 455 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_size, fd_start, fd_end, fd_end 473 ompi/mca/fcoll/two_phase/fcoll_two_phase_support_fns.c fd_end, striping_unit, fd_end 103 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset *fd_end) fd_end 109 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Assert ( (off <= fd_end[fd->hints->cb_nodes-1] && off >= min_off && fd_start[0] >= min_off ) ); fd_end 130 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c while ( off < fd_start[rank_index] || off > fd_end[rank_index] ) { fd_end 131 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c if ( off > fd_end [rank_index] ) { fd_end 160 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c avail_bytes = fd_end[rank_index] + 1 - off; fd_end 200 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset min_st_offset, max_end_offset, *fd_start, *fd_end, *fd_size; fd_end 259 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_end = *fd_end_ptr; fd_end 432 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_end [aggr] = offset + fd_size[aggr] - 1; fd_end 457 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset *fd_end, ADIO_Offset fd_size, fd_end 508 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_start, fd_end); fd_end 521 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_size, fd_start, fd_end); fd_end 557 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_start, fd_end); fd_end 584 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_size, fd_start, fd_end); fd_end 47 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.h ADIO_Offset *fd_end); fd_end 54 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.h ADIO_Offset *fd_end, ADIO_Offset fd_size, fd_end 40 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 52 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 66 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 79 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_end, fd_end 115 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c *fd_end = NULL, *end_offsets = NULL; fd_end 318 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &fd_start, &fd_end, &fd_size, fd->fs_ptr); fd_end 323 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &fd_start, &fd_end, &fd_size, fd->fs_ptr); fd_end 330 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &fd_start, &fd_end, fd_end 337 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c &fd_start, &fd_end, fd_end 349 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c datatype,error_code, st_offsets, end_offsets, currentNonZeroDataIndex, fd_start, fd_end); fd_end 356 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(fd_end); fd_end 377 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c error_code, st_offsets, end_offsets, fd_start, fd_end); fd_end 387 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(fd_end); fd_end 407 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 413 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 460 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c fd_size, fd_start, fd_end, buf_idx, error_code); fd_end 485 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Free(fd_end); fd_end 506 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 758 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 768 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 807 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 817 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 844 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 950 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 1027 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_end, fd_end 1084 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c fd_end); fd_end 1138 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 1236 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 47 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 58 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 76 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_end, fd_end 89 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 100 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 133 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c *fd_end = NULL, *end_offsets = NULL; fd_end 308 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &fd_start, &fd_end, &fd_size, fd->fs_ptr); fd_end 314 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &fd_start, &fd_end, &fd_size, fd->fs_ptr); fd_end 321 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &fd_start, &fd_end, fd_end 328 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c &fd_start, &fd_end, fd_end 343 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c currentValidDataIndex, fd_start, fd_end, &holeFound); fd_end 354 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(fd_end); fd_end 373 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_OneSidedWriteAggregation(fd, offset_list, len_list, contig_access_count, buf, datatype, error_code, st_offsets, end_offsets, currentValidDataIndex, fd_start, fd_end, &holeFound); fd_end 381 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(fd_end); fd_end 400 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c error_code, st_offsets, end_offsets, fd_start, fd_end); fd_end 409 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(fd_end); fd_end 420 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 426 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 466 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c fd_size, fd_start, fd_end, buf_idx, error_code); fd_end 491 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIOI_Free(fd_end); fd_end 565 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 597 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c group_end = ADIOI_MAX(fd_end[i], group_end); fd_end 618 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 702 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c if (gpfs_find_access_for_ion(fd, st_loc, end_loc, fd_start, fd_end, fd_end 871 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 882 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 955 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 966 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 1013 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 1183 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 1302 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 1353 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c fd_end); fd_end 1536 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_end, fd_end 1603 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 1715 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 1766 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c fd_end); fd_end 79 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_Offset *fd_end) fd_end 95 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c while (off > fd_end[rank_index]) rank_index++; fd_end 114 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c avail_bytes = fd_end[rank_index] + 1 - off; fd_end 139 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_Offset min_st_offset, max_end_offset, *fd_start, *fd_end, fd_size; fd_end 184 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end = *fd_end_ptr; fd_end 202 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[0] = end_off - 1; fd_end 206 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_start[i] = fd_end[i-1] + 1; fd_end 214 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[i] = end_off - 1; fd_end 216 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[nprocs_for_coll-1] = max_end_offset; fd_end 220 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[0] = min_st_offset + fd_size - 1; fd_end 223 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_start[i] = fd_end[i-1] + 1; fd_end 224 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[i] = fd_start[i] + fd_size - 1; fd_end 236 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_start[i] = fd_end[i] = -1; fd_end 237 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (fd_end[i] > max_end_offset) fd_end 238 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_end[i] = max_end_offset; fd_end 257 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c ADIO_Offset *fd_end, ADIO_Offset fd_size, fd_end 307 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_start, fd_end); fd_end 320 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_size, fd_start, fd_end); fd_end 356 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_start, fd_end); fd_end 383 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c fd_size, fd_start, fd_end); fd_end 61 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *fd_end; fd_end 86 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *fd_end; fd_end 144 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *fd_end; fd_end 169 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIO_Offset *fd_end, fd_end 422 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c &vars->fd_start, &vars->fd_end, fd_end 440 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->fd_start, vars->fd_end, vars->fd_size, fd_end 508 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c rae_vars->fd_end = vars->fd_end; fd_end 543 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Free(vars->fd_end); fd_end 849 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_end = vars->fd_end; fd_end 958 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c red_vars->fd_end = vars->fd_end; fd_end 1132 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->fd_end, vars->buftype_extent); fd_end 59 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *fd_end; fd_end 87 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *fd_end; fd_end 150 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *fd_end; fd_end 183 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 430 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c &vars->fd_start, &vars->fd_end, fd_end 439 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->fd_start, vars->fd_end, vars->fd_size, fd_end 502 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c eaw_vars->fd_end = vars->fd_end; fd_end 589 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c ADIOI_Free(vars->fd_end); fd_end 887 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_end = vars->fd_end; fd_end 1006 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c wed_vars->fd_end = vars->fd_end; fd_end 1265 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->fd_start, vars->fd_end, fd_end 26 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 38 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 51 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_end, fd_end 79 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c *fd_end = NULL, *end_offsets = NULL; fd_end 190 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c &fd_start, &fd_end, fd_end 207 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 243 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c fd_size, fd_start, fd_end, buf_idx, error_code); fd_end 263 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Free(fd_end); fd_end 503 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 730 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 759 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 780 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 886 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 963 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIO_Offset *fd_end, fd_end 1020 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c fd_end); fd_end 22 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 33 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 45 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 78 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c *fd_end = NULL, *end_offsets = NULL; fd_end 171 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c &fd_start, &fd_end, fd_end 180 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c min_st_offset, fd_start, fd_end, fd_size, fd_end 211 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c fd_size, fd_start, fd_end, buf_idx, error_code); fd_end 270 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIOI_Free(fd_end); fd_end 302 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 508 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 538 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 572 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 746 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c min_st_offset, fd_size, fd_start, fd_end, fd_end 868 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ADIO_Offset *fd_start, ADIO_Offset *fd_end, fd_end 919 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c fd_end); fd_end 195 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset* fd_end, fd_end 339 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[j] > greatestFileDomainOffset) { fd_end 340 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c greatestFileDomainOffset = fd_end[j]; fd_end 349 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[j] > fd_start[j]) { fd_end 367 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentNumberOfRounds = (int)(((fd_end[j] - fd_start[j])+(ADIO_Offset)1)/coll_bufsize); fd_end 368 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (((ADIO_Offset)currentNumberOfRounds*coll_bufsize) < ((fd_end[j] - fd_start[j])+(ADIO_Offset)1)) fd_end 402 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("fd->hints->ranklist[%d]is %d fd_start is %ld fd_end is %ld\n",i,fd->hints->ranklist[i],fd_start[i],fd_end[i]); fd_end 508 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) { fd_end 509 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) fd_end 514 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("currentAggRankListIndex is %d blockStart %ld blockEnd %ld fd_start[currentAggRankListIndex] %ld fd_end[currentAggRankListIndex] %ld\n",currentAggRankListIndex,blockStart,blockEnd,fd_start[currentAggRankListIndex],fd_end[currentAggRankListIndex]); fd_end 549 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex]; fd_end 594 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd > fd_end[currentAggRankListIndex]) { fd_end 596 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("block extends past current fd, blockEnd %ld >= fd_end[currentAggRankListIndex] %ld total block size is %ld blockStart was %ld\n",blockEnd,fd_end[currentAggRankListIndex], len_list[blockIter],blockStart); fd_end 601 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockEnd >= fd_end[currentAggRankListIndex]) { fd_end 602 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset thisAggBlockEnd = fd_end[currentAggRankListIndex]; fd_end 620 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) { fd_end 621 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) fd_end 638 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex]; fd_end 653 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountToAdvanceSBOffsetForFD = (fd_end[prevAggRankListIndex] fd_end 656 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountToAdvanceSBOffsetForFD = (fd_end[prevAggRankListIndex] fd_end 805 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 807 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) fd_end 810 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; fd_end 813 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; fd_end 1065 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 1067 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) fd_end 1070 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; fd_end 1073 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; fd_end 1079 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("used agg about to writecontig - currentRoundFDStart is %ld currentRoundFDEnd is %ld within file domeain %ld to %ld\n",currentRoundFDStart,currentRoundFDEnd,fd_start[myAggRank],fd_end[myAggRank]); fd_end 1154 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 1156 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) fd_end 1159 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; fd_end 1162 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; fd_end 1232 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset* fd_end) fd_end 1375 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[j] > greatestFileDomainOffset) { fd_end 1376 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c greatestFileDomainOffset = fd_end[j]; fd_end 1385 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[j] > fd_start[j]) { fd_end 1402 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentNumberOfRounds = (int)(((fd_end[j] - fd_start[j])+(ADIO_Offset)1)/coll_bufsize); fd_end 1403 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (((ADIO_Offset)currentNumberOfRounds*coll_bufsize) < ((fd_end[j] - fd_start[j])+(ADIO_Offset)1)) fd_end 1436 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("fd->hints->ranklist[%d]is %d fd_start is %ld fd_end is %ld\n",i,fd->hints->ranklist[i],fd_start[i],fd_end[i]); fd_end 1539 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) { fd_end 1540 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) fd_end 1574 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex]; fd_end 1618 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd > fd_end[currentAggRankListIndex]) { fd_end 1620 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("block extends past current fd, blockEnd %ld >= fd_end[currentAggRankListIndex] %ld total block size is %ld blockStart was %ld\n",blockEnd,fd_end[currentAggRankListIndex], len_list[blockIter],blockStart); fd_end 1624 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockEnd >= fd_end[currentAggRankListIndex]) { fd_end 1625 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset thisAggBlockEnd = fd_end[currentAggRankListIndex]; fd_end 1643 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) { fd_end 1644 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) fd_end 1661 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex]; fd_end 1677 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountToAdvanceSBOffsetForFD = (fd_end[prevAggRankListIndex] - blockStart) + (ADIO_Offset)1; fd_end 1679 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountToAdvanceSBOffsetForFD = (fd_end[prevAggRankListIndex]-fd_start[prevAggRankListIndex]) +(ADIO_Offset)1; fd_end 1843 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 1844 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; fd_end 1868 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { fd_end 1869 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDEnd = fd_end[myAggRank]; fd_end 21 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset* fd_end) fd_end 61 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (fd_end[j] > fd_start[j]) { fd_end 76 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= fd_start[i]) && (myOffsetStart <= fd_end[i])) || ((myOffsetEnd >= fd_start[i]) && (myOffsetEnd <= fd_end[i]))) { fd_end 79 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[i]; fd_end 96 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) || ((end_offsets[i] >= fd_start[myAggRank]) && (end_offsets[i] <= fd_end[myAggRank]))) fd_end 108 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) || ((end_offsets[i] >= fd_start[myAggRank]) && (end_offsets[i] <= fd_end[myAggRank]))) { fd_end 110 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) && ((end_offsets[i] >= fd_start[myAggRank]) && (end_offsets[i] <= fd_end[myAggRank]))) { fd_end 114 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) {/* starts in this fd and goes past it */ fd_end 115 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (fd_end[myAggRank] - st_offsets[i]) +1; fd_end 123 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("getting %ld bytes from source proc %d in fd rank %d with borders %ld to %ld\n",remainingDataAmountToGetPerProc[numSourceProcs],i,fd->hints->ranklist[myAggRank],fd_start[myAggRank],fd_end[myAggRank]); fd_end 255 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 256 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; fd_end 261 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("currentRoundFDStart is %ld currentRoundFDEnd is %ld within file domeain %ld to %ld\n",currentRoundFDStart,currentRoundFDEnd,fd_start[myAggRank],fd_end[myAggRank]); fd_end 492 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset* fd_end) fd_end 531 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (fd_end[j] > fd_start[j]) { fd_end 546 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= fd_start[i]) && (myOffsetStart <= fd_end[i])) || fd_end 547 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ((myOffsetEnd >= fd_start[i]) && (myOffsetEnd <= fd_end[i]))) { fd_end 550 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[i]; fd_end 571 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (st_offsets[i] <= fd_end[myAggRank])) || fd_end 573 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (end_offsets[i] <= fd_end[myAggRank])) ) fd_end 588 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) || ((end_offsets[i] >= fd_start[myAggRank]) && (end_offsets[i] <= fd_end[myAggRank]))) { fd_end 590 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) && ((end_offsets[i] >= fd_start[myAggRank]) && (end_offsets[i] <= fd_end[myAggRank]))) { fd_end 594 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((st_offsets[i] >= fd_start[myAggRank]) && (st_offsets[i] <= fd_end[myAggRank])) {/* starts in this fd and goes past it */ fd_end 595 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToSendPerProc[numTargetProcs] = (fd_end[myAggRank] - st_offsets[i]) +1; fd_end 663 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { fd_end 664 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; fd_end 692 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { fd_end 693 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDEnd = fd_end[myAggRank]; fd_end 488 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset *fd_end); fd_end 493 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset *fd_end, ADIO_Offset fd_size, fd_end 704 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset *fd_end); fd_end 712 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset *fd_end); fd_end 726 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset* fd_end, fd_end 739 ompi/mca/io/romio321/romio/adio/include/adioi.h ADIO_Offset* fd_end);