10 #include <ucp/api/ucp.h>
Notifier for status of futures.
Definition: notifier.h:38
virtual void stopRequestNotifierThread()=0
Make known to the notifier thread that it should stop.
virtual void runRequestNotifier()=0
Notify event loop of all pending completed futures.
virtual void scheduleFutureNotify(std::shared_ptr< Future > future, ucs_status_t status)=0
Schedule notification of completed future.
virtual bool isRunning() const =0
Returns whether the thread is running.
virtual RequestNotifierWaitState waitRequestNotifier(uint64_t period)=0
Wait for a new event with a timeout in nanoseconds.
virtual ~Notifier()
Virtual destructor.
Definition: notifier.h:53
RequestNotifierWaitState
The state with which a wait operation completed.
Definition: notifier.h:26
RequestNotifierThreadState
The state of the notifier thread.
Definition: notifier.h:19