io_completion_object.h

Go to the documentation of this file.

 
#pragma once
 
#include <memory>
#include <mutex>
#include <queue>
 
#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>
 
namespace rex::kernel {

struct IONotification {
  u32 key;         
  u32 apc_context; 
  u32 status;      
  u32 num_bytes;
};
 
struct IOCompletionObject {
  static constexpr u32 kMaxNotifications = 1024;
 
  REX_KERNEL_API IOCompletionObject();
 
  std::mutex notification_lock;
  std::queue<IONotification> notifications;
  std::unique_ptr<rex::platform::Semaphore> notification_semaphore;

  REX_KERNEL_API void Queue(const IONotification& notification);

  REX_KERNEL_API bool Wait(u64 wait_ticks, IONotification* out_notification);
};
 
}  // namespace rex::kernel