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:

• /__w/ucxx/ucxx/cpp/include/ucxx/internal/request_am.h