FRIBParallelanalysis
1.0
FrameworkforMPIParalleldataanalysisatFRIB
|
Public Member Functions | |
Application (int argc, char **argv) | |
virtual void | dealer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | farmer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | outputter (int argc, char **argv, AbstractApplication *pApp) |
virtual void | worker (int argc, char **argv, AbstractApplication *pApp) |
Application (int argc, char **argv) | |
virtual void | dealer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | farmer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | outputter (int argc, char **argv, AbstractApplication *pApp) |
virtual void | worker (int argc, char **argv, AbstractApplication *pApp) |
Application (int argc, char **argv) | |
virtual void | dealer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | farmer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | outputter (int argc, char **argv, AbstractApplication *pApp) |
virtual void | worker (int argc, char **argv, AbstractApplication *pApp) |
Application (int argc, char **argv) | |
virtual void | dealer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | farmer (int argc, char **argv, AbstractApplication *pApp) |
virtual void | outputter (int argc, char **argv, AbstractApplication *pApp) |
virtual void | worker (int argc, char **argv, AbstractApplication *pApp) |
![]() | |
AbstractApplication (int argc, char **argv) | |
virtual | ~AbstractApplication () |
virtual void | operator() (CParameterReader ¶mReader) |
MPI_Datatype & | messageHeaderType () |
MPI_Datatype & | requestDataType () |
MPI_Datatype & | parameterHeaderDataType () |
MPI_Datatype & | parameterValueDataType () |
MPI_Datatype & | parameterDefType () |
MPI_Datatype & | variableDefType () |
unsigned | numWorkers () |
void | forwardPassThrough (const void *pData, size_t nBytes) |
int | getRequest () |
void | sendEofs () |
void | sendEof () |
void | requestData (size_t maxBytes) |
void | throwMPIError (int status, const char *reason) |
AbstractApplication (int argc, char **argv) | |
Additional Inherited Members | |
![]() | |
int | getArgc () const |
char ** | getArgv () |
void | makeDataTypes () |
Application We're going to have rank 0 (dealer) just deal a few passthrough items directly at the Outputter and then send an end.. No worker or farmers are needed.
|
virtual |
dealer: We just create a few random passthrough ring items for the outputter to send. They don't actually mean anything but they have known contents. and are therefore amenable to testing.
Implements frib::analysis::AbstractApplication.