This is the complete list of members for ucxx::python::Worker, including all inherited members.
_amData | ucxx::Worker | protected |
_enableFuture | ucxx::Worker | protected |
_futuresPool | ucxx::Worker | protected |
_futuresPoolMutex | ucxx::Worker | protected |
_notifier | ucxx::Worker | protected |
_parent | ucxx::Component | protected |
amProbe(const ucp_ep_h endpointHandle) const | ucxx::Worker | |
arm() | ucxx::Worker | |
cancelInflightRequests(uint64_t period=0, uint64_t maxAttempts=1) | ucxx::Worker | |
clearFuturesPool() override | ucxx::python::Worker | virtual |
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 | |
createWorker(std::shared_ptr< Context > context, const bool enableDelayedSubmission, const bool enableFuture) | ucxx::python::Worker | friend |
flush(const bool enablePythonFuture=false, RequestCallbackUserFunction callbackFunction=nullptr, RequestCallbackUserData callbackData=nullptr) | ucxx::Worker | |
getAddress() | ucxx::Worker | |
getEpollFileDescriptor() | ucxx::Worker | |
getFuture() override | ucxx::python::Worker | virtual |
getHandle() | ucxx::Worker | |
getInfo() | ucxx::Worker | |
getParent() const | ucxx::Component | |
getProgressThreadId() | ucxx::Worker | |
initBlockingProgressMode() | ucxx::Worker | |
isDelayedRequestSubmissionEnabled() const | ucxx::Worker | |
isFutureEnabled() const | ucxx::Worker | |
isProgressThreadRunning() | ucxx::Worker | |
operator=(Worker const &)=delete (defined in ucxx::python::Worker) | ucxx::python::Worker | |
operator=(Worker &&o)=delete (defined in ucxx::python::Worker) | ucxx::python::Worker | |
operator=(Worker const &)=delete (defined in ucxx::Worker) | ucxx::Worker | |
operator=(Worker &&o)=delete (defined in ucxx::Worker) | ucxx::Worker | |
populateFuturesPool() override | ucxx::python::Worker | virtual |
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() override | ucxx::python::Worker | virtual |
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() override | ucxx::python::Worker | virtual |
tagProbe(const Tag tag, const TagMask tagMask=TagMaskFull) | 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) override | ucxx::python::Worker | virtual |
Worker()=delete (defined in ucxx::python::Worker) | ucxx::python::Worker | |
Worker(const Worker &)=delete (defined in ucxx::python::Worker) | ucxx::python::Worker | |
Worker(Worker &&o)=delete (defined in ucxx::python::Worker) | ucxx::python::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::Component | virtual |
~Worker() | ucxx::Worker | virtual |