#pragma once

#include "vm.h"
#include "Utilities/cond.h"

#include "Utilities/Atomic.h"

class notifier;

namespace vm
{

	// Get reservation status for further atomic update: last update timestamp
	inline atomic_t<u64>& reservation_acquire(u32 addr, u32 size)
	{
		// Access reservation info: stamp and the lock bit
		return reinterpret_cast<atomic_t<u64>*>(g_reservations)[addr / 128];
	}

	// Update reservation status
	inline void reservation_update(u32 addr, u32 size, bool lsb = false)
	{
		// Update reservation info with new timestamp
		reservation_acquire(addr, size) += 128;
	}

	// Get reservation sync variable
	inline shared_cond& reservation_notifier(u32 addr, u32 size)
	{
		return *reinterpret_cast<shared_cond*>(g_reservations2 + addr / 128 * 8);
	}

	void reservation_lock_internal(atomic_t<u64>&);

	inline atomic_t<u64>& reservation_lock(u32 addr, u32 size)
	{
		auto& res = vm::reservation_acquire(addr, size);

		if (UNLIKELY(res.bts(0)))
		{
			reservation_lock_internal(res);
		}

		return res;
	}

} // namespace vm