/*
	Vita Development Suite Libraries
*/

#ifndef _VDSUITE_USER_PAF_THREAD_H
#define _VDSUITE_USER_PAF_THREAD_H

#include <kernel.h>

namespace paf {
	namespace thread {

		class DefaultThreadPriority
		{
		public:

			DefaultThreadPriority();

			static DefaultThreadPriority *Get();

			SceVoid Set();

			SceInt32 priority1;
			SceInt32 priority2;
			SceInt32 priority3;

		};

		class ThreadOpt
		{
		public:

			ThreadOpt();

			SceUInt32 attr;
			SceInt32 cpuAffinityMask;
			SceKernelMemBlockType stackMemoryType;

		};

		class Thread
		{
		public:

			enum Error
			{
				SCE_PAF_ERROR_THREAD_THREAD_ALREADY_STARTED = 0x80AF0702
			};


			Thread(SceInt32 initPriority, SceSize stackSize, const char *pName, const ThreadOpt *opt = SCE_NULL);

			virtual ~Thread();

			virtual SceVoid EntryFunction() = 0;

			static SceInt32 InternalThreadEntry(SceSize argSize, ScePVoid pArgBlock);

			static SceVoid SetMainThreadUID(SceInt32 threadNum = 0);

			static SceUID GetMainThreadUID(SceInt32 threadNum = 0);

			static SceBool IsMainThread(SceInt32 threadNum = 0);

			static SceVoid Sleep(SceUInt32 msec);

			SceInt32 Start();

			SceVoid Join();

			SceVoid ChangePriority(SceInt32 priority);

			SceUID Self();

			SceBool IsStarted();

			//related to unk variable, unk set to SCE_FALSE by default
			//ScePafThread_F95B2895 set unk to SCE_TRUE
			//ScePafThread_4CE6D88B get unk

		private:

			SceUChar8 m_work[0x14];

		};

		class Sema
		{
		public:

			Sema(const char *pName, SceInt32 initCount, SceInt32 maxCount);

			~Sema();

			SceVoid Wait();

			SceVoid Signal();

		private:

			SceUID m_uid;

		};

		class Mutex
		{
		public:

			Mutex(const char *pName, SceBool isFifo);

			~Mutex();

			SceVoid Lock();

			SceBool TryLock();

			SceVoid Unlock();

		private:

			SceInt64 m_work[4];

		};

		class Mutex2
		{
		public:

			Mutex2(const char *pName, SceBool isFifo);

			~Mutex2();

			SceVoid Lock();

			SceBool TryLock();

			SceVoid Unlock();

		private:

			SceInt64 m_work[4];

		};

		class Cond
		{
		public:

			Cond(SceKernelLwMutexWork *pLwMutex, const char *pName, SceBool isFifo);

			~Cond();

			SceBool Wait(SceUInt32 timeoutMsec = 0);

			SceVoid Notify();

			SceVoid NotifyAll();

		private:

			SceInt32 m_work[5];

		};

		class RWLock
		{
		public:

			RWLock(const char *pName);

			~RWLock();

			SceVoid LockShared();

			SceVoid UnlockShared();

			SceVoid LockExclusive();

			SceVoid UnlockExclusive();

		private:

			SceInt32 m_work[0x8];

		};

		class Queue
		{
		public:

			typedef void(*QueueEntryFunction)(void *pArgBlock);

			Queue(const char *pName);

			~Queue();

			static Queue *s_mainThreadQueue;

			SceVoid WaitDone();

			SceVoid Push(const char *pName, QueueEntryFunction entry, ScePVoid pArgBlock);

			SceVoid Execute();

			SceUInt32 Size();

		private:

			SceUChar8 m_work[0x30];

		};

		class SyncCall
		{
		public:

			typedef void(*SyncCallEntryFunction)(void *pArgBlock);

			SyncCall(const char *pName);

			~SyncCall();

			static SyncCall *s_mainThreadSyncCall;

			SceVoid Push(SyncCallEntryFunction entry, ScePVoid pArgBlock);

			SceVoid Execute();

		private:

			SceUChar8 m_work[0x10];

		};
	}
}

#endif /* _VDSUITE_USER_PAF_THREAD_H */