notify_listener_object.h

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <mutex>
#include <utility>
#include <vector>
 
#include <rex/assert.h>
#include <rex/kernel/object/object.h>
#include <rex/kernel/types/list.h>
#include <rex/kernel/types/memory.h>
#include <rex/kernel/types/status.h>
#include <rex/kernel/types/thread.h>
#include <rex/module.h>
#include <rex/platform.h>
#include <rex/platform/sync.h>
#include <rex/platform/thread.h>
#include <rex/platform/timer.h>
#include <rex/result.h>
#include <rex/types.h>
#include <rex/utility.h>
#include <rex/kernel/object/notification_broadcaster.h>
 
namespace rex::kernel {
 
class INotifyListenerQueue {
 public:
  virtual ~INotifyListenerQueue() = default;

  virtual bool DequeueByID(XNotificationID id, u32* out_data) = 0;

  virtual bool Dequeue(XNotificationID* out_id, u32* out_data) = 0;
};

inline constexpr u32 kNotifyListenerObjectSize = 0x30;
 
struct NotifyListenerObject : INotifyListenerQueue {
  REX_KERNEL_API NotifyListenerObject(u64 mask_in, u32 max_version_in);

  std::unique_ptr<rex::platform::Event> wait_handle;
  std::mutex notifications_lock;
  std::vector<std::pair<XNotificationID, u32>> notifications;
  u64 mask = 0; 
  u32 max_version = 0; 

  REX_KERNEL_API void Enqueue(XNotificationID id, u32 data);
 
  REX_KERNEL_API bool DequeueByID(XNotificationID id, u32* out_data) override;
 
  REX_KERNEL_API bool Dequeue(XNotificationID* out_id, u32* out_data) override;
};
 
}  // namespace rex::kernel