All Classes Namespaces Functions Variables Typedefs Enumerations Friends
ucxx::Worker Member List

This is the complete list of members for ucxx::Worker, including all inherited members.

_amDataucxx::Workerprotected
_enableFutureucxx::Workerprotected
_futuresPoolucxx::Workerprotected
_futuresPoolMutexucxx::Workerprotected
_notifierucxx::Workerprotected
_parentucxx::Componentprotected
amProbe(const ucp_ep_h endpointHandle) constucxx::Worker
arm()ucxx::Worker
cancelInflightRequests(uint64_t period=0, uint64_t maxAttempts=1)ucxx::Worker
clearFuturesPool()ucxx::Workervirtual
createEndpointFromHostname(std::string ipAddress, uint16_t port, bool endpointErrorHandling=true)ucxx::Worker
createEndpointFromWorkerAddress(std::shared_ptr< Address > address, bool endpointErrorHandling=true)ucxx::Worker
createListener(uint16_t port, ucp_listener_conn_callback_t callback, void *callbackArgs)ucxx::Worker
createRequestAm(std::shared_ptr< Endpoint > endpoint, const std::variant< data::AmSend, data::AmReceive > requestData, const bool enablePythonFuture, RequestCallbackUserFunction callbackFunction, RequestCallbackUserData callbackData)ucxx::Workerfriend
createWorker(std::shared_ptr< Context > context, const bool enableDelayedSubmission, const bool enableFuture)ucxx::Workerfriend
flush(const bool enablePythonFuture=false, RequestCallbackUserFunction callbackFunction=nullptr, RequestCallbackUserData callbackData=nullptr)ucxx::Worker
getAddress()ucxx::Worker
getEpollFileDescriptor()ucxx::Worker
getFuture()ucxx::Workervirtual
getHandle()ucxx::Worker
getInfo()ucxx::Worker
getParent() constucxx::Component
getProgressThreadId()ucxx::Worker
initBlockingProgressMode()ucxx::Worker
isDelayedRequestSubmissionEnabled() constucxx::Worker
isFutureEnabled() constucxx::Worker
isProgressThreadRunning()ucxx::Worker
operator=(Worker const &)=delete (defined in ucxx::Worker)ucxx::Worker
operator=(Worker &&o)=delete (defined in ucxx::Worker)ucxx::Worker
populateFuturesPool()ucxx::Workervirtual
progress()ucxx::Worker
progressOnce()ucxx::Worker
progressWorkerEvent(const int epollTimeout=-1)ucxx::Worker
registerAmAllocator(ucs_memory_type_t memoryType, AmAllocatorType allocator)ucxx::Worker
registerAmReceiverCallback(AmReceiverCallbackInfo info, AmReceiverCallbackType callback)ucxx::Worker
registerDelayedSubmission(std::shared_ptr< Request > request, DelayedSubmissionCallbackType callback)ucxx::Worker
registerGenericPost(DelayedSubmissionCallbackType callback, uint64_t period=0)ucxx::Worker
registerGenericPre(DelayedSubmissionCallbackType callback, uint64_t period=0)ucxx::Worker
removeInflightRequest(const Request *const request)ucxx::Worker
runRequestNotifier()ucxx::Workervirtual
scheduleRequestCancel(TrackedRequestsPtr trackedRequests)ucxx::Worker
setParent(std::shared_ptr< Component > parent)ucxx::Component
setProgressThreadStartCallback(std::function< void(void *)> callback, void *callbackArg)ucxx::Worker
signal()ucxx::Worker
startProgressThread(const bool pollingMode=false, const int epollTimeout=1)ucxx::Worker
stopProgressThread()ucxx::Worker
stopRequestNotifierThread()ucxx::Workervirtual
tagProbe(const Tag tag)ucxx::Worker
tagRecv(void *buffer, size_t length, Tag tag, TagMask tagMask, const bool enableFuture=false, RequestCallbackUserFunction callbackFunction=nullptr, RequestCallbackUserData callbackData=nullptr)ucxx::Worker
waitProgress()ucxx::Worker
waitRequestNotifier(uint64_t periodNs)ucxx::Workervirtual
Worker(std::shared_ptr< Context > context, const bool enableDelayedSubmission=false, const bool enableFuture=false)ucxx::Workerexplicitprotected
Worker()=delete (defined in ucxx::Worker)ucxx::Worker
Worker(const Worker &)=delete (defined in ucxx::Worker)ucxx::Worker
Worker(Worker &&o)=delete (defined in ucxx::Worker)ucxx::Worker
~Component() (defined in ucxx::Component)ucxx::Componentvirtual
~Worker()ucxx::Workervirtual