currentFDSourceBufferState 103 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c FDSourceBufferState *currentFDSourceBufferState, char *packedDataBufer) currentFDSourceBufferState 107 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentIndiceOffset = currentFDSourceBufferState->indiceOffset; currentFDSourceBufferState 108 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset bufTypeExtent = (ADIO_Offset)currentFDSourceBufferState->bufTypeExtent; currentFDSourceBufferState 110 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c (ADIO_Offset)currentFDSourceBufferState->dataTypeExtent; currentFDSourceBufferState 111 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentFlatBufIndice = currentFDSourceBufferState->flatBufIndice; currentFDSourceBufferState 175 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState->indiceOffset = currentIndiceOffset; currentFDSourceBufferState 176 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState->dataTypeExtent = (int) currentDataTypeExtent; currentFDSourceBufferState 177 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState->flatBufIndice = currentFlatBufIndice; currentFDSourceBufferState 281 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c FDSourceBufferState *currentFDSourceBufferState; currentFDSourceBufferState 283 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState = (FDSourceBufferState *) ADIOI_Malloc(naggs * sizeof(FDSourceBufferState)); currentFDSourceBufferState 288 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[i].sourceBufferOffset = -1; currentFDSourceBufferState 291 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[i].indiceOffset = -1; currentFDSourceBufferState 561 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numTargetAggs].sourceBufferOffset == -1) { currentFDSourceBufferState 563 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].sourceBufferOffset = currentSourceBufferOffset; currentFDSourceBufferState 570 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numTargetAggs].indiceOffset == -1) { currentFDSourceBufferState 571 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].indiceOffset = currentIndiceOffset; currentFDSourceBufferState 572 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].bufTypeExtent = bufTypeExtent; currentFDSourceBufferState 573 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].dataTypeExtent = currentDataTypeExtent; currentFDSourceBufferState 574 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].flatBufIndice = currentFlatBufIndice; currentFDSourceBufferState 661 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numTargetAggs].sourceBufferOffset == -1) { currentFDSourceBufferState 663 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].sourceBufferOffset = currentFDSourceBufferState 667 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].sourceBufferOffset = currentFDSourceBufferState 668 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs-1].sourceBufferOffset+amountToAdvanceSBOffsetForFD; currentFDSourceBufferState 672 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("Crossed into new FD - for agg %d sourceBufferOffset initialized to %ld amountToAdvanceSBOffsetForFD is %ld\n",numTargetAggs,currentFDSourceBufferState[numTargetAggs].sourceBufferOffset,amountToAdvanceSBOffsetForFD); currentFDSourceBufferState 676 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if (currentFDSourceBufferState[numTargetAggs].indiceOffset == -1) { currentFDSourceBufferState 686 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].indiceOffset = currentFDSourceBufferState 688 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].bufTypeExtent = bufTypeExtent; currentFDSourceBufferState 689 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].dataTypeExtent = currentFDSourceBufferState 691 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].flatBufIndice = currentFDSourceBufferState 696 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].indiceOffset = currentFDSourceBufferState 697 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs-1].indiceOffset; currentFDSourceBufferState 698 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].bufTypeExtent = currentFDSourceBufferState 699 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs-1].bufTypeExtent; currentFDSourceBufferState 700 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].dataTypeExtent = currentFDSourceBufferState 701 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs-1].dataTypeExtent; currentFDSourceBufferState 702 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs].flatBufIndice = currentFDSourceBufferState 703 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numTargetAggs-1].flatBufIndice; currentFDSourceBufferState 707 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ¤tFDSourceBufferState[numTargetAggs], NULL); currentFDSourceBufferState 709 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("Crossed into new FD - for agg %d dataTypeExtent initialized to %d flatBufIndice to %d indiceOffset to %ld amountToAdvanceSBOffsetForFD is %d\n",numTargetAggs,currentFDSourceBufferState[numTargetAggs].dataTypeExtent,currentFDSourceBufferState[numTargetAggs].flatBufIndice,currentFDSourceBufferState[numTargetAggs].indiceOffset,amountToAdvanceSBOffsetForFD); currentFDSourceBufferState 965 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToSend, MPI_BYTE,targetAggsForMyData[aggIter],targetDisplacementToUseThisRound, bufferAmountToSend,MPI_BYTE,write_buf_window); currentFDSourceBufferState 966 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend; currentFDSourceBufferState 970 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], putSourceData); currentFDSourceBufferState 987 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceBufferDisplacements[targetAggContigAccessCount] = (MPI_Aint)currentFDSourceBufferState[aggIter].sourceBufferOffset; currentFDSourceBufferState 988 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend; currentFDSourceBufferState 992 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], &derivedTypePackedSourceBuffer[derivedTypePackedSourceBufferOffset]); currentFDSourceBufferState 1213 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Free(currentFDSourceBufferState); currentFDSourceBufferState 1317 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c FDSourceBufferState *currentFDSourceBufferState; currentFDSourceBufferState 1319 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState = (FDSourceBufferState *) ADIOI_Malloc(naggs * sizeof(FDSourceBufferState)); currentFDSourceBufferState 1324 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[i].sourceBufferOffset = -1; currentFDSourceBufferState 1327 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[i].indiceOffset = -1; currentFDSourceBufferState 1586 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numSourceAggs].sourceBufferOffset == -1) { currentFDSourceBufferState 1588 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentRecvBufferOffset; currentFDSourceBufferState 1595 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numSourceAggs].indiceOffset == -1) { currentFDSourceBufferState 1596 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].indiceOffset = currentIndiceOffset; currentFDSourceBufferState 1597 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].bufTypeExtent = bufTypeExtent; currentFDSourceBufferState 1598 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentDataTypeExtent; currentFDSourceBufferState 1599 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFlatBufIndice; currentFDSourceBufferState 1683 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentFDSourceBufferState[numSourceAggs].sourceBufferOffset == -1) { currentFDSourceBufferState 1685 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentRecvBufferOffset+amountToAdvanceSBOffsetForFD; currentFDSourceBufferState 1688 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentFDSourceBufferState[numSourceAggs-1].sourceBufferOffset+amountToAdvanceSBOffsetForFD; currentFDSourceBufferState 1692 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("Crossed into new FD - for agg %d sourceBufferOffset initialized to %ld amountToAdvanceSBOffsetForFD is %ld\n",numSourceAggs,currentFDSourceBufferState[numSourceAggs].sourceBufferOffset,amountToAdvanceSBOffsetForFD); currentFDSourceBufferState 1696 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if (currentFDSourceBufferState[numSourceAggs].indiceOffset == -1) { currentFDSourceBufferState 1705 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].indiceOffset = currentIndiceOffset; currentFDSourceBufferState 1706 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].bufTypeExtent = bufTypeExtent; currentFDSourceBufferState 1707 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentDataTypeExtent; currentFDSourceBufferState 1708 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFlatBufIndice; currentFDSourceBufferState 1713 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].indiceOffset = currentFDSourceBufferState[numSourceAggs-1].indiceOffset; currentFDSourceBufferState 1714 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].bufTypeExtent = currentFDSourceBufferState[numSourceAggs-1].bufTypeExtent; currentFDSourceBufferState 1715 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentFDSourceBufferState[numSourceAggs-1].dataTypeExtent; currentFDSourceBufferState 1716 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFDSourceBufferState[numSourceAggs-1].flatBufIndice; currentFDSourceBufferState 1718 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, (int)amountToAdvanceSBOffsetForFD, 0, ¤tFDSourceBufferState[numSourceAggs], NULL); currentFDSourceBufferState 1720 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("Crossed into new FD - for agg %d dataTypeExtent initialized to %d flatBufIndice to %d indiceOffset to %ld amountToAdvanceSBOffsetForFD is %d\n",numSourceAggs,currentFDSourceBufferState[numSourceAggs].dataTypeExtent,currentFDSourceBufferState[numSourceAggs].flatBufIndice,currentFDSourceBufferState[numSourceAggs].indiceOffset,amountToAdvanceSBOffsetForFD); currentFDSourceBufferState 2052 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToRecv, MPI_BYTE,sourceAggsForMyData[aggIter],sourceDisplacementToUseThisRound, bufferAmountToRecv,MPI_BYTE,read_buf_window); currentFDSourceBufferState 2053 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv; currentFDSourceBufferState 2063 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToRecv, 0, ¤tFDSourceBufferState[aggIter], getSourceData); currentFDSourceBufferState 2077 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c recvBufferDisplacements[sourceAggContigAccessCount] = (MPI_Aint)currentFDSourceBufferState[aggIter].sourceBufferOffset; currentFDSourceBufferState 2078 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv; currentFDSourceBufferState 2115 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, derivedTypePackedSourceBufferOffset, 0, ¤tFDSourceBufferState[aggIter], derivedTypePackedSourceBuffer); currentFDSourceBufferState 2169 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Free(currentFDSourceBufferState);