numAggs 197 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int numAggs = confInfo->aggRatio * confInfo->ioMinSize /*virtualPsetSize*/; numAggs 199 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if(numAggs == 1) numAggs 202 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c aggTotal = confInfo->numBridgeRanks * numAggs; numAggs 250 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if (aggAssignments[j].numAggsAssigned < numAggs) { numAggs 279 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if (aggAssignments[i].numAggsAssigned < numAggs) numAggs 312 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int distance, numAggs; numAggs 331 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c numAggs = confInfo->aggRatio * confInfo->ioMinSize /*virtualPsetSize*/; numAggs 332 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if(numAggs == 1) numAggs 337 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c aggTotal = confInfo->numBridgeRanks * (numAggs+1); numAggs 341 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c TRACE_ERR("numBridgeRanks: %d, aggRatio: %f numBridge: %d pset size: %d/%d numAggs: %d, aggTotal: %d\n", confInfo->numBridgeRanks, confInfo->aggRatio, confInfo->numBridgeRanks, confInfo->ioMinSize, confInfo->ioMaxSize /*virtualPsetSize*/, numAggs, aggTotal); numAggs 378 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c distance = psetSize/numAggs; numAggs 380 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c if(numAggs>1) numAggs 382 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for(j = 0; j < numAggs; j++) numAggs 402 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c TRACE_ERR("memcpy(tmp_ranklist, aggList, (numAggs(%u)*confInfo->numBridgeRanks(%u)+numAggs(%u)) (%u) %u*sizeof(int))\n",numAggs,confInfo->numBridgeRanks,numAggs,(numAggs*confInfo->numBridgeRanks+numAggs),aggTotal); numAggs 57 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c int numAggs = 0; numAggs 87 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs = atoi(tmpBuf); numAggs 88 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c if (numAggs == 0) numAggs 90 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c else if (!((numAggs > 0 ) && (numAggs <= commSize))) { numAggs 92 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs = commSize; numAggs 94 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c fd->hints->ranklist = (int *) ADIOI_Malloc (numAggs * sizeof(int)); numAggs 97 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c while (aggIndex < numAggs) { numAggs 139 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c else if (aggIndex < numAggs) numAggs 140 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c FPRINTF(stderr,"ERROR: ATTENTION: %d aggregators were specified in MP_IOTASKLIST but only %d were correctly specified - setting the number of aggregators to %d.\n",numAggs, aggIndex,aggIndex); numAggs 141 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs = aggIndex; numAggs 145 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c if (numAggs == 0) { numAggs 202 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs++; numAggs 212 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs++; numAggs 220 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs = cntType; numAggs 226 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c fd->hints->ranklist = (int *) ADIOI_Malloc (numAggs * sizeof(int)); numAggs 228 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c while (rankListIndex < numAggs) { numAggs 253 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c numAggs++; numAggs 264 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c printf("Agg rank list of %d generated:\n", numAggs); numAggs 265 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c for (i=0;i<numAggs;i++) { numAggs 272 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c fd->hints->cb_nodes = numAggs;