mutant_object.h

Go to the documentation of this file.

 
#pragma once
 
#include <atomic>
#include <memory>
#include <mutex>
 
#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 X_KMUTANT {
  X_DISPATCH_HEADER header;
  X_LIST_ENTRY mutant_list_entry;
  be_u32 owner_thread;
  u8 abandoned;
  u8 reserved[3];
};
REX_STATIC_ASSERT_SIZE(X_KMUTANT, 0x20);
 
struct MutantObject {
  MutantObject() = default;

  REX_KERNEL_API explicit MutantObject(bool initial_owner, u32 guest_mutant_in = 0);
 
  PublishedPtr<rex::platform::Mutant> mutant; 
  std::atomic<u32> owner_thread_id{0};
  std::atomic<i32> hold_count{0}; 
  std::atomic<bool> abandoned{false};
  u32 guest_mutant = 0;
  std::mutex state_mutex;

  REX_KERNEL_API X_STATUS Release(bool abandon, i32* previous_state = nullptr);

  REX_KERNEL_API bool OnAcquired(const rex::platform::WaitHandle* waited);

  REX_KERNEL_API void Adopt(MutantObject& fresh);
};
 
}  // namespace rex::kernel