![]() |
PEARL
Parallel Event Access and Replay Library
|
Active message runtime class. More...
#include <pearl/AmRuntime.h>
Public Member Functions | |
AmRuntime progress | |
size_t | advance () |
void | wait () |
void | wait (const Communicator &comm) |
void | allfence () |
void | fence (const Communicator &comm) |
Accessing runtime parameters | |
void | setCbdata (CallbackData *data) |
CallbackData * | getCbdata () const |
void | setCbmanager (const CallbackManager &cbmanager) |
const CallbackManager & | getCbmanager () const |
Message handling | |
void | attach (AmHandler &handler) |
void | enqueue (AmRequest::Ptr request) |
void | startListen (const Communicator &comm) |
void | stopListen (const Communicator &comm) |
Runtime information | |
void | printSummary () |
AmRuntime creation & destruction | |
static AmRuntime & | getInstance () |
void | shutdown () |
This class implements the core runtime environment for the active messaging framework. It is designed as a singleton so an application can have only one runtime object at any time. The runtime uses three different classes to implement its active message scheme. An AmRequest object is used to send data to a remote location. An AmListener object is used to probe for and receive messages on the remote location. Handler classes are used to pack the initial message buffers on the origin side and to unpack and execute their business logic on the target side.
size_t pearl::AmRuntime::advance | ( | ) |
void pearl::AmRuntime::allfence | ( | ) |
void pearl::AmRuntime::attach | ( | AmHandler & | handler | ) |
void pearl::AmRuntime::enqueue | ( | AmRequest::Ptr | request | ) |
void pearl::AmRuntime::fence | ( | const Communicator & | comm | ) |
CallbackData* pearl::AmRuntime::getCbdata | ( | ) | const |
const CallbackManager& pearl::AmRuntime::getCbmanager | ( | ) | const |
|
static |
void pearl::AmRuntime::printSummary | ( | ) |
void pearl::AmRuntime::setCbdata | ( | CallbackData * | data | ) |
void pearl::AmRuntime::setCbmanager | ( | const CallbackManager & | cbmanager | ) |
void pearl::AmRuntime::shutdown | ( | ) |
void pearl::AmRuntime::startListen | ( | const Communicator & | comm | ) |
void pearl::AmRuntime::stopListen | ( | const Communicator & | comm | ) |
void pearl::AmRuntime::wait | ( | ) |
void pearl::AmRuntime::wait | ( | const Communicator & | comm | ) |
![]() |
Copyright © 1998–2019 Forschungszentrum Jülich GmbH,
Jülich Supercomputing Centre
Copyright © 2009–2015 German Research School for Simulation Sciences GmbH, Laboratory for Parallel Programming |