myAggRank 319 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int myAggRank = -1; /* if I am an aggregor this is my index into fd->hints->ranklist */ myAggRank 348 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c myAggRank = j; myAggRank 791 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = fd_start[myAggRank]; myAggRank 792 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (myAggRank == smallestFileDomainAggRank) { myAggRank 796 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if (myAggRank == greatestFileDomainAggRank) { myAggRank 805 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 806 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (myAggRank == greatestFileDomainAggRank) { myAggRank 807 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) myAggRank 810 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; myAggRank 813 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; myAggRank 1065 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 1066 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (myAggRank == greatestFileDomainAggRank) { myAggRank 1067 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) myAggRank 1070 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; myAggRank 1073 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; myAggRank 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]); myAggRank 1154 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 1155 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (myAggRank == greatestFileDomainAggRank) { myAggRank 1156 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_end[myAggRank] > lastFileOffset) myAggRank 1159 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; myAggRank 1162 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = fd_end[myAggRank]; myAggRank 1357 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int myAggRank = -1; /* if I am an aggregor this is my index into fd->hints->ranklist */ myAggRank 1384 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c myAggRank = j; myAggRank 1794 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = fd_start[myAggRank]; myAggRank 1795 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDStart = fd_start[myAggRank]; myAggRank 1796 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (myAggRank == smallestFileDomainAggRank) { myAggRank 1802 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if (myAggRank == greatestFileDomainAggRank) { myAggRank 1843 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 1844 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; myAggRank 1868 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { myAggRank 1869 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDEnd = fd_end[myAggRank]; myAggRank 41 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int myAggRank = -1; /* if I am an aggregor this is my index into fd->hints->ranklist */ myAggRank 60 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c myAggRank = j; myAggRank 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]))) myAggRank 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]))) { myAggRank 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]))) { myAggRank 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 */ myAggRank 115 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (fd_end[myAggRank] - st_offsets[i]) +1; myAggRank 119 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (end_offsets[i] - fd_start[myAggRank]) +1; myAggRank 120 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = fd_start[myAggRank]; myAggRank 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]); myAggRank 168 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart = fd_start[myAggRank]; myAggRank 255 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 256 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; myAggRank 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]); myAggRank 516 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int myAggRank = -1; /* if I am an aggregor this is my index into fd->hints->ranklist */ myAggRank 530 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c myAggRank = j; myAggRank 570 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((st_offsets[i] >= fd_start[myAggRank]) && myAggRank 571 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (st_offsets[i] <= fd_end[myAggRank])) || myAggRank 572 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ((end_offsets[i] >= fd_start[myAggRank]) && myAggRank 573 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (end_offsets[i] <= fd_end[myAggRank])) ) myAggRank 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]))) { myAggRank 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]))) { myAggRank 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 */ myAggRank 595 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToSendPerProc[numTargetProcs] = (fd_end[myAggRank] - st_offsets[i]) +1; myAggRank 599 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToSendPerProc[numTargetProcs] = (end_offsets[i] - fd_start[myAggRank]) +1; myAggRank 600 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToSendPerProc[numTargetProcs] = fd_start[myAggRank]; myAggRank 626 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart = fd_start[myAggRank]; myAggRank 627 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDStart = fd_start[myAggRank]; myAggRank 663 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { myAggRank 664 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; myAggRank 692 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { myAggRank 693 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDEnd = fd_end[myAggRank];