Active Message data owned by a ucxx::Worker
.
More...
#include <request_am.h>
Public Attributes | |
std::weak_ptr< Worker > | _worker {} |
The worker to which the Active Message callback belongs. | |
std::string | _ownerString {} |
The owner string used for logging. | |
AmPoolType | _recvPool {} |
The pool of completed receive requests (waiting for user request) | |
AmPoolType | _recvWait {} |
The pool of user receive requests (waiting for message arrival) | |
RecvAmMessageMapType | _recvAmMessageMap {} |
The active messages waiting to be handled by callback. | |
AmReceiverCallbackOwnerMapType | _receiverCallbacks {} |
std::mutex | _mutex {} |
Mutex to provide access to pools/maps. | |
std::function< void(std::shared_ptr< Request >)> | _registerInflightRequest {} |
Worker function to register inflight requests with. | |
std::unordered_map< ucs_memory_type_t, AmAllocatorType > | _allocators {} |
Default and user-defined active message allocators. | |
Active Message data owned by a ucxx::Worker
.
Receiving Active Messages are handled directly by a ucxx::Worker
without the user necessarily creating a ucxx::RequestAm
for it. When there is an incoming message, the worker will populate the internal pool of received messages in an orderly-fashion.
AmReceiverCallbackOwnerMapType ucxx::internal::AmData::_receiverCallbacks {} |
Receiver callbacks to handle specialized Active Messages without a pool.