flatBuf 102 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Flatlist_node *flatBuf, int targetNumBytes, int packing, flatBuf 121 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((flatBuf->blocklens[currentFlatBufIndice] - currentIndiceOffset) >= remainingBytesToLoad) { // we can get the rest of our data from this indice flatBuf 122 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset physicalSourceBufferOffset = (currentDataTypeExtent * bufTypeExtent) + flatBuf->indices[currentFlatBufIndice] + currentIndiceOffset; flatBuf 137 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentIndiceOffset >= flatBuf->blocklens[currentFlatBufIndice]) { flatBuf 140 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFlatBufIndice == flatBuf->count) { flatBuf 149 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int amountDataToLoad = (flatBuf->blocklens[currentFlatBufIndice] - currentIndiceOffset); flatBuf 150 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset physicalSourceBufferOffset = (currentDataTypeExtent * bufTypeExtent) + flatBuf->indices[currentFlatBufIndice] + currentIndiceOffset; flatBuf 165 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFlatBufIndice == flatBuf->count) { flatBuf 254 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Flatlist_node *flatBuf=NULL; flatBuf 259 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c flatBuf = ADIOI_Flatten_and_find(datatype); flatBuf 262 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("flatBuf->count is %d bufTypeExtent is %d\n", flatBuf->count,bufTypeExtent); flatBuf 263 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<flatBuf->count;i++) flatBuf 264 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("flatBuf->blocklens[%d] is %d flatBuf->indices[%d] is %ld\n",i,flatBuf->blocklens[i],i,flatBuf->indices[i]); flatBuf 452 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceBlockTotal += (flatBuf->blocklens[currentFlatBufIndice] - currentIndiceOffset); flatBuf 455 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFlatBufIndice == flatBuf->count) { flatBuf 465 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFlatBufIndice = flatBuf->count-1; flatBuf 467 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentIndiceOffset = len_list[blockIter-1] - (sourceBlockTotal - flatBuf->blocklens[lastIndiceUsed]); flatBuf 491 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceBlockTotal += flatBuf->blocklens[tmpCurrentFlatBufIndice]; flatBuf 493 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (tmpCurrentFlatBufIndice == flatBuf->count) { flatBuf 705 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, flatBuf 970 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], putSourceData); flatBuf 992 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], &derivedTypePackedSourceBuffer[derivedTypePackedSourceBufferOffset]); flatBuf 1285 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Flatlist_node *flatBuf=NULL; flatBuf 1291 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c flatBuf = ADIOI_Flatten_and_find(datatype); flatBuf 1294 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("flatBuf->count is %d bufTypeExtent is %d\n", flatBuf->count,bufTypeExtent); flatBuf 1295 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<flatBuf->count;i++) flatBuf 1296 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("flatBuf->blocklens[%d] is %d flatBuf->indices[%d] is %ld\n",i,flatBuf->blocklens[i],i,flatBuf->indices[i]); flatBuf 1483 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceBlockTotal += (flatBuf->blocklens[currentFlatBufIndice] - currentIndiceOffset); flatBuf 1486 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFlatBufIndice == flatBuf->count) { flatBuf 1496 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFlatBufIndice = flatBuf->count-1; flatBuf 1498 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentIndiceOffset = len_list[blockIter-1] - (sourceBlockTotal - flatBuf->blocklens[lastIndiceUsed]); flatBuf 1522 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceBlockTotal += flatBuf->blocklens[tmpCurrentFlatBufIndice]; flatBuf 1524 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (tmpCurrentFlatBufIndice == flatBuf->count) { flatBuf 1718 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, (int)amountToAdvanceSBOffsetForFD, 0, ¤tFDSourceBufferState[numSourceAggs], NULL); flatBuf 2063 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToRecv, 0, ¤tFDSourceBufferState[aggIter], getSourceData); flatBuf 2115 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, derivedTypePackedSourceBufferOffset, 0, ¤tFDSourceBufferState[aggIter], derivedTypePackedSourceBuffer);