Commit 63a2ea59 authored by Francois Tessier's avatar Francois Tessier

If persistent memory, resize the buffer size and use a single aggregation buffer

parent e1ca26ab
......@@ -324,6 +324,16 @@ void Tapioca::IdentifyMyAggregators ()
int64_t remainingData, offsetInAggrData;
std::vector<Round_t> rounds;
/* TODO */
if ( this->memAggr_ == NVR || this->memAggr_ == NAM ) {
this->nBuffers_ = 1;
this->bufferSize_ = 1.05 * ceil ( (double)this->commDataSize_ / (double)this->nAggr_ );
if ( this->commRank_ == 0 )
printMsg ( WARNING, "Persistent aggregation layer. One aggregation buffer per aggregator. %lld B buffer size\n", this->bufferSize_);
}
this->totalNeededBuffers_ = ceil ( (double)this->commDataSize_ / (double)this->bufferSize_ );
/*
......@@ -339,7 +349,7 @@ void Tapioca::IdentifyMyAggregators ()
if ( nAggr != this->nAggr_ ) {
if ( this->commRank_ == 0 )
fprintf ( stdout, "[INFO] Number of aggregators decreased from %d to %d\n",
printMsg ( WARNING, "Number of aggregators decreased from %d to %d\n",
this->nAggr_, nAggr);
this->nAggr_ = nAggr;
......
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