15 : interComm(interComm)
16 , serverRank(serverRank)
17 , bufferSize(bufferSize)
18 , estimatedMaxEventSize(estimatedMaxEventSize)
23 , maxBufferedEvents(maxBufferedEvents)
29 info(10) <<
"CClientBuffer: allocated 2 x " << bufferSize <<
" bytes for server " << serverRank <<
" with a maximum of " << maxBufferedEvents <<
" buffered events" << endl;
47 ERROR(
"bool CClientBuffer::isBufferFree(StdSize size)",
48 <<
"The requested size (" << size <<
" bytes) is too big to fit the buffer (" <<
bufferSize <<
" bytes), please increase the client buffer size." << endl);
55 error(0) <<
"WARNING: Unexpected event of size " << size <<
" for server " <<
serverRank
77 ERROR(
"CBufferOut* CClientBuffer::getBuffer(StdSize size)",
78 <<
"Not enough space in buffer, this should not have happened...");
91 MPI_Test(&
request, &flag, &status);
93 if (flag ==
true)
pending =
false;
102 if (current == 1) current = 0;
CClientBuffer(MPI_Comm intercomm, int serverRank, StdSize bufferSize, StdSize estimatedMaxEventSize, StdSize maxBufferedEvents)
bool hasPendingRequest(void)
CBufferOut * getBuffer(StdSize size)
CATCH CScalarAlgorithmReduceScalar::CScalarAlgorithmReduceScalar(CScalar *scalarDestination, CScalar *scalarSource, CReduceScalarToScalar *algo ERROR)("CScalarAlgorithmReduceScalar::CScalarAlgorithmReduceScalar(CScalar* scalarDestination, CScalar* scalarSource, CReduceScalarToScalar* algo)",<< "Operation must be defined."<< "Scalar source "<< scalarSource->getId()<< std::endl<< "Scalar destination "<< scalarDestination->getId())
CLog error("error", cerr.rdbuf())
bool isBufferFree(StdSize size)
const StdSize maxBufferedEvents
void realloc(size_t size)
static size_t maxRequestSize
const StdSize estimatedMaxEventSize