// This code contains NVIDIA Confidential Information and is disclosed to you
// under a form of NVIDIA software license agreement provided separately to you.
//
// Notice
// NVIDIA Corporation and its licensors retain all intellectual property and
// proprietary rights in and to this software and related documentation and
// any modifications thereto. Any use, reproduction, disclosure, or
// distribution of this software and related documentation without an express
// license agreement from NVIDIA Corporation is strictly prohibited.
//
// ALL NVIDIA DESIGN SPECIFICATIONS, CODE ARE PROVIDED "AS IS.". NVIDIA MAKES
// NO WARRANTIES, EXPRESSED, IMPLIED, STATUTORY, OR OTHERWISE WITH RESPECT TO
// THE MATERIALS, AND EXPRESSLY DISCLAIMS ALL IMPLIED WARRANTIES OF NONINFRINGEMENT,
// MERCHANTABILITY, AND FITNESS FOR A PARTICULAR PURPOSE.
//
// Information and code furnished is believed to be accurate and reliable.
// However, NVIDIA Corporation assumes no responsibility for the consequences of use of such
// information or for any infringement of patents or other rights of third parties that may
// result from its use. No license is granted by implication or otherwise under any patent
// or patent rights of NVIDIA Corporation. Details are subject to change without notice.
// This code supersedes and replaces all information previously supplied.
// NVIDIA Corporation products are not authorized for use as critical
// components in life support devices or systems without express written approval of
// NVIDIA Corporation.
//
// Copyright (c) 2008-2018 NVIDIA Corporation. All rights reserved.
// Copyright (c) 2004-2008 AGEIA Technologies, Inc. All rights reserved.
// Copyright (c) 2001-2004 NovodeX AG. All rights reserved.

#ifndef PSFOUNDATION_PSMUTEX_H
#define PSFOUNDATION_PSMUTEX_H

#include "PsAllocator.h"

/*
 * This <new> inclusion is a best known fix for gcc 4.4.1 error:
 * Creating object file for apex/src/PsAllocator.cpp ...
 * In file included from apex/include/PsFoundation.h:30,
 *                from apex/src/PsAllocator.cpp:26:
 * apex/include/PsMutex.h: In constructor  'physx::shdfnd::MutexT<Alloc>::MutexT(const Alloc&)':
 * apex/include/PsMutex.h:92: error: no matching function for call to 'operator new(unsigned int,
 * physx::shdfnd::MutexImpl*&)'
 * <built-in>:0: note: candidates are: void* operator new(unsigned int)
 */
#include <new>

namespace physx
{
namespace shdfnd
{
class PX_FOUNDATION_API MutexImpl
{
  public:
	/**
	The constructor for Mutex creates a mutex. It is initially unlocked.
	*/
	MutexImpl();

	/**
	The destructor for Mutex deletes the mutex.
	*/
	~MutexImpl();

	/**
	Acquire (lock) the mutex. If the mutex is already locked
	by another thread, this method blocks until the mutex is
	unlocked.
	*/
	void lock();

	/**
	Acquire (lock) the mutex. If the mutex is already locked
	by another thread, this method returns false without blocking.
	*/
	bool trylock();

	/**
	Release (unlock) the mutex.
	*/
	void unlock();

	/**
	Size of this class.
	*/
	static uint32_t getSize();
};

template <typename Alloc = ReflectionAllocator<MutexImpl> >
class MutexT : protected Alloc
{
	PX_NOCOPY(MutexT)
  public:
	class ScopedLock
	{
		MutexT<Alloc>& mMutex;
		PX_NOCOPY(ScopedLock)
	  public:
		PX_INLINE ScopedLock(MutexT<Alloc>& mutex) : mMutex(mutex)
		{
			mMutex.lock();
		}
		PX_INLINE ~ScopedLock()
		{
			mMutex.unlock();
		}
	};

	/**
	The constructor for Mutex creates a mutex. It is initially unlocked.
	*/
	MutexT(const Alloc& alloc = Alloc()) : Alloc(alloc)
	{
		mImpl = reinterpret_cast<MutexImpl*>(Alloc::allocate(MutexImpl::getSize(), __FILE__, __LINE__));
		PX_PLACEMENT_NEW(mImpl, MutexImpl)();
	}

	/**
	The destructor for Mutex deletes the mutex.
	*/
	~MutexT()
	{
		mImpl->~MutexImpl();
		Alloc::deallocate(mImpl);
	}

	/**
	Acquire (lock) the mutex. If the mutex is already locked
	by another thread, this method blocks until the mutex is
	unlocked.
	*/
	void lock() const
	{
		mImpl->lock();
	}

	/**
	Acquire (lock) the mutex. If the mutex is already locked
	by another thread, this method returns false without blocking,
	returns true if lock is successfully acquired
	*/
	bool trylock() const
	{
		return mImpl->trylock();
	}

	/**
	Release (unlock) the mutex, the calling thread must have
	previously called lock() or method will error
	*/
	void unlock() const
	{
		mImpl->unlock();
	}

  private:
	MutexImpl* mImpl;
};

class PX_FOUNDATION_API ReadWriteLock
{
	PX_NOCOPY(ReadWriteLock)
  public:
	ReadWriteLock();
	~ReadWriteLock();

	// "takeLock" can only be false if the thread already holds the mutex, e.g. if it already acquired the write lock
	void lockReader(bool takeLock=true);
	void lockWriter();

	void unlockReader();
	void unlockWriter();

  private:
	class ReadWriteLockImpl* mImpl;
};

typedef MutexT<> Mutex;




// PT: the following classes aren't used in PhysX but might still be used in APEX.

class ScopedReadLock
{
	PX_NOCOPY(ScopedReadLock)
public:
	PX_INLINE ScopedReadLock(ReadWriteLock& lock) : mLock(lock)
	{
		mLock.lockReader();
	}
	PX_INLINE ~ScopedReadLock()
	{
		mLock.unlockReader();
	}

private:
	ReadWriteLock& mLock;
};

class ScopedWriteLock
{
	PX_NOCOPY(ScopedWriteLock)
public:
	PX_INLINE ScopedWriteLock(ReadWriteLock& lock) : mLock(lock)
	{
		mLock.lockWriter();
	}
	PX_INLINE ~ScopedWriteLock()
	{
		mLock.unlockWriter();
	}

private:
	ReadWriteLock& mLock;
};

/*
* Use this type of lock for mutex behaviour that must operate on SPU and PPU
* On non-PS3 platforms, it is implemented using Mutex
*/
class AtomicLock
{
	Mutex mMutex;
	PX_NOCOPY(AtomicLock)

public:
	AtomicLock()
	{
	}

	bool lock()
	{
		mMutex.lock();
		return true;
	}

	bool trylock()
	{
		return mMutex.trylock();
	}

	bool unlock()
	{
		mMutex.unlock();
		return true;
	}
};

class AtomicLockCopy
{
	AtomicLock* pLock;

public:
	AtomicLockCopy() : pLock(NULL)
	{
	}

	AtomicLockCopy& operator=(AtomicLock& lock)
	{
		pLock = &lock;
		return *this;
	}

	bool lock()
	{
		return pLock->lock();
	}

	bool trylock()
	{
		return pLock->trylock();
	}

	bool unlock()
	{
		return pLock->unlock();
	}
};

class AtomicRwLock
{
	ReadWriteLock m_Lock;
	PX_NOCOPY(AtomicRwLock)

public:
	AtomicRwLock()
	{
	}

	void lockReader()
	{
		m_Lock.lockReader();
	}
	void lockWriter()
	{
		m_Lock.lockWriter();
	}

	bool tryLockReader()
	{
		// Todo - implement this
		m_Lock.lockReader();
		return true;
	}

	void unlockReader()
	{
		m_Lock.unlockReader();
	}
	void unlockWriter()
	{
		m_Lock.unlockWriter();
	}
};

class ScopedAtomicLock
{
	PX_INLINE ScopedAtomicLock(AtomicLock& lock) : mLock(lock)
	{
		mLock.lock();
	}
	PX_INLINE ~ScopedAtomicLock()
	{
		mLock.unlock();
	}

	PX_NOCOPY(ScopedAtomicLock)
private:
	AtomicLock& mLock;
};









} // namespace shdfnd
} // namespace physx

#endif // #ifndef PSFOUNDATION_PSMUTEX_H