Commit e1ca26ab authored by Francois Tessier's avatar Francois Tessier

Specify the source of the data for data movement to a memory tier

parent d48d7184
......@@ -15,7 +15,7 @@ Memory::~Memory ()
/**********************/
/* |-- Allocation */
/**********************/
void Memory::memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, MPI_Comm comm ) {
void Memory::memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, mem_t memSrc, MPI_Comm comm ) {
int rank, err;
this->mem_ = mem;
......
......@@ -23,7 +23,7 @@ public:
/**********************/
/* |-- Allocation */
/**********************/
void memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, MPI_Comm comm );
void memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, mem_t memSrc, MPI_Comm comm );
void memFree ( );
/**********************/
......
......@@ -11,7 +11,7 @@ public:
/************************/
/* |-- Allocation */
/************************/
virtual void memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, MPI_Comm comm ) = 0;
virtual void memAlloc ( int64_t buffSize, mem_t mem, bool masterRank, char* fileName, mem_t memSrc, MPI_Comm comm ) = 0;
virtual void memFree ( ) = 0;
/************************/
......
......@@ -104,7 +104,7 @@ void Tapioca::setAggregationTier ( )
sprintf ( buffer_file, "tp_buffer_%d.agg", i );
memBuffer.memAlloc ( this->bufferSize_, this->memAggr_, this->amAnAggr_, buffer_file, this->subComm_ );
memBuffer.memAlloc ( this->bufferSize_, this->memAggr_, this->amAnAggr_, buffer_file, DDR, this->subComm_ );
this->memBuffers.push_back ( memBuffer );
}
}
......@@ -119,9 +119,9 @@ void Tapioca::setTargetTier ( char* fileName )
MPI_Comm_split (this->subComm_, this->amAnAggr_, this->commRank_, &targetComm);
if ( this->amAnAggr_ )
this->memTarget.memAlloc ( 0, memTarget, true, fileName, targetComm );
this->memTarget.memAlloc ( 0, memTarget, true, fileName, this->memAggr_, targetComm );
else
this->memTarget.memAlloc ( 0, memTarget, false, "/dev/null", targetComm );
this->memTarget.memAlloc ( 0, memTarget, false, "/dev/null", this->memAggr_, targetComm );
}
......
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