All Classes Namespaces Functions Variables Typedefs Enumerations Friends
Public Attributes | List of all members
ucxx::internal::AmData Class Reference

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.
 

Detailed Description

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.

Member Data Documentation

◆ _receiverCallbacks

AmReceiverCallbackOwnerMapType ucxx::internal::AmData::_receiverCallbacks {}

Receiver callbacks to handle specialized Active Messages without a pool.


The documentation for this class was generated from the following file: