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