notifier.h

 
#pragma once
 
#include <chrono>
#include <memory>
 
#include <ucp/api/ucp.h>
 
namespace ucxx {
 
enum class RequestNotifierThreadState { NotRunning = 0, Running, Stopping };
 
enum class RequestNotifierWaitState { Ready = 0, Timeout, Shutdown };
 
class Future;
 
class Notifier {
 protected:
  Notifier() = default;
 
 public:
  Notifier(const Notifier&)            = delete;
  Notifier& operator=(Notifier const&) = delete;
  Notifier(Notifier&& o)               = delete;
  Notifier& operator=(Notifier&& o)    = delete;
 
  virtual ~Notifier() {}
 
  virtual void scheduleFutureNotify(std::shared_ptr<Future> future, ucs_status_t status) = 0;
 
  virtual RequestNotifierWaitState waitRequestNotifier(uint64_t period) = 0;
 
  virtual void runRequestNotifier() = 0;
 
  virtual void stopRequestNotifierThread() = 0;
 
  [[nodiscard]] virtual bool isRunning() const = 0;
};
 
}  // namespace ucxx