Commit 34cfa64d authored by Francois Tessier's avatar Francois Tessier

Remove useless printfs

parent c78c3b8f
......@@ -300,8 +300,9 @@ void Tapioca::SetNodesList ()
MPI_Allgather(&this->hostId_, 1, MPI_INT, hostIdList, 1, MPI_INT, this->subComm_);
for ( i = 0; i < this->commSize_; i++ )
for ( i = 0; i < this->commSize_; i++ ) {
this->excludedNode[ hostIdList[i] ] = false;
}
free (hostIdList);
}
......@@ -358,7 +359,7 @@ void Tapioca::IdentifyMyAggregators ()
offsetInAggrData = this->chunkOffset_[c] - this->offsetInFile_;
globalRoundId = floor ( offsetInAggrData / this->bufferSize_ );
upperBound = ( offsetInAggrData % this->bufferSize_ ) + remainingData;
while ( remainingData > 0 ) {
this->globalAggregatorsRanks.push_back ( rounds[globalRoundId].aggr );
this->roundsIds.push_back ( rounds[globalRoundId].round );
......@@ -500,8 +501,7 @@ void Tapioca::ElectAggregators ()
for ( aggr = 0; aggr < this->nAggr_; aggr++ ) {
color = this->DataSizeSentToAggr (aggr);
//fprintf (stdout, "[LOCK] Agg %d/%d, commRamk %d, datasize %lld (%d)\n", aggr, this->nAggr_, this->commRank_, color, worldSize);
startTime = MPI_Wtime();
if ( this->commSplit_ )
......@@ -572,7 +572,6 @@ void Tapioca::ElectAggregators ()
this->totalWrites_ = ceil ( (double)this->aggrDataSize_ / (double)this->bufferSize_);
this->globalAggrRank_ = aggr;
aggrCoords = this->hostId_;
//fprintf ( stdout, "[LOCK] Rank %d Isend to 0 its coordinates %d\n", this->worldRank_, aggrCoords );
MPI_Isend ( &aggrCoords, 1, MPI_INT, 0, 0, MPI_COMM_WORLD, &request );
}
......@@ -600,9 +599,7 @@ void Tapioca::ElectAggregators ()
*/
for ( i = 0; i < ( (worldSize / topology.ProcessPerNode ()) / (this->commSize_ / topology.ProcessPerNode ()) ); i++ ) {
if ( this->worldRank_ == 0 ) {
//fprintf ( stdout, "[LOCK] Rank %d about to Recv from ANY_SOURCE\n", this->worldRank_ );
MPI_Recv ( &aggrCoords, 1, MPI_INT, MPI_ANY_SOURCE, 0, MPI_COMM_WORLD, &status );
//fprintf ( stdout, "[LOCK] Rank %d Recv from %d its coordinates %d\n", this->worldRank_, status.MPI_SOURCE, aggrCoords );
}
MPI_Bcast ( &aggrCoords, 1, MPI_INT, 0, MPI_COMM_WORLD);
......@@ -621,9 +618,6 @@ int64_t Tapioca::DataSizeSentToAggr (int aggrId)
int i;
int64_t dataSize = 0;
// for ( i = 0; i < this->aggregatorsRanks.size(); i++ )
// fprintf ( stdout, "[LOCK][%d] %lld to %d (%d)\n", i, this->dataSize[i], this->globalAggregatorsRanks[i], aggrId );
for ( i = 0; i < this->aggregatorsRanks.size(); i++ )
if ( this->globalAggregatorsRanks[i] == aggrId )
dataSize += this->dataSize[i];
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment