This is the complete list of members for ucxx::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() | ucxx::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 | |
| createRequestAm(std::shared_ptr< Endpoint > endpoint, const std::variant< data::AmSend, data::AmReceive > requestData, const bool enablePythonFuture, RequestCallbackUserFunction callbackFunction, RequestCallbackUserData callbackData) | ucxx::Worker | friend |
| createWorker(std::shared_ptr< Context > context, const bool enableDelayedSubmission, const bool enableFuture) | ucxx::Worker | friend |
| flush(const bool enablePythonFuture=false, RequestCallbackUserFunction callbackFunction=nullptr, RequestCallbackUserData callbackData=nullptr) | ucxx::Worker | |
| getAddress() | ucxx::Worker | |
| getEpollFileDescriptor() | ucxx::Worker | |
| getFuture() | ucxx::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::Worker) | ucxx::Worker | |
| operator=(Worker &&o)=delete (defined in ucxx::Worker) | ucxx::Worker | |
| populateFuturesPool() | ucxx::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() | ucxx::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() | ucxx::Worker | virtual |
| 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::Worker | virtual |
| Worker(std::shared_ptr< Context > context, const bool enableDelayedSubmission=false, const bool enableFuture=false) | ucxx::Worker | explicitprotected |
| 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::Component | virtual |
| ~Worker() | ucxx::Worker | virtual |
1.9.1
