/**

  * vim: set ts=4 :

  * =============================================================================

  * SourceMod

  * Copyright (C) 2004-2007 AlliedModders LLC.  All rights reserved.

  * =============================================================================

  *

  * This program is free software; you can redistribute it and/or modify it under

  * the terms of the GNU General Public License, version 3.0, as published by the

  * Free Software Foundation.

  * 

  * This program is distributed in the hope that it will be useful, but WITHOUT

  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS

  * FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more

  * details.

  *

  * You should have received a copy of the GNU General Public License along with

  * this program.  If not, see <http://www.gnu.org/licenses/>.

  *

  * As a special exception, AlliedModders LLC gives you permission to link the

  * code of this program (as well as its derivative works) to "Half-Life 2," the

  * "Source Engine," the "SourcePawn JIT," and any Game MODs that run on software

  * by the Valve Corporation.  You must obey the GNU General Public License in

  * all respects for all other code used.  Additionally, AlliedModders LLC grants

  * this exception to all derivative works.  AlliedModders LLC defines further

  * exceptions, found in LICENSE.txt (as of this writing, version JULY-31-2007),

  * or <http://www.sourcemod.net/license.php>.

  *

  * Version: $Id$

  */

 #ifndef _INCLUDE_POSIXTHREADS_H_

 #define _INCLUDE_POSIXTHREADS_H_

 #include <pthread.h>

 #include "IThreader.h"

 using namespace SourceMod;

 void *Posix_ThreadGate(void *param);

 class PosixThreader : public IThreader

 {

 public:

 	class ThreadHandle : public IThreadHandle

 	{

 		friend class PosixThreader;

 		friend void *Posix_ThreadGate(void *param);

 	public:

 		ThreadHandle(IThreader *parent, IThread *run, const ThreadParams *params);

 		virtual ~ThreadHandle();

 	public:

 		virtual bool WaitForThread();

 		virtual void DestroyThis();

 		virtual IThreadCreator *Parent();

 		virtual void GetParams(ThreadParams *ptparams);

 		virtual ThreadPriority GetPriority();

 		virtual bool SetPriority(ThreadPriority prio);

 		virtual ThreadState GetState();

 		virtual bool Unpause();

 	protected:

 		IThreader *m_parent;		//Parent handle

 		pthread_t m_thread;			//Windows HANDLE	

 		ThreadParams m_params;		//Current Parameters

 		IThread *m_run;	//Runnable context

 		pthread_mutex_t m_statelock;

 		pthread_mutex_t m_runlock;

 		ThreadState m_state;		//internal state

 	};

 	class PosixMutex : public IMutex

 	{

 	public:

 		PosixMutex(pthread_mutex_t m) : m_mutex(m)

 		{

 		};

 		virtual ~PosixMutex();

 	public:

 		virtual bool TryLock();

 		virtual void Lock();

 		virtual void Unlock();

 		virtual void DestroyThis();

 	protected:

 		pthread_mutex_t m_mutex;

 	};

 	class PosixEventSignal : public IEventSignal

 	{

 	public:

 		PosixEventSignal();

 		virtual ~PosixEventSignal();

 	public:

 		virtual void Wait();

 		virtual void Signal();

 		virtual void DestroyThis();

 	protected:

 		pthread_cond_t m_cond;

 		pthread_mutex_t m_mutex;

 	};

 public:

 	IMutex *MakeMutex();

 	void MakeThread(IThread *pThread);

 	IThreadHandle *MakeThread(IThread *pThread, ThreadFlags flags);

 	IThreadHandle *MakeThread(IThread *pThread, const ThreadParams *params);

 	void GetPriorityBounds(ThreadPriority &max, ThreadPriority &min);

 	void ThreadSleep(unsigned int ms);

 	IEventSignal *MakeEventSignal();

 	IThreadWorker *MakeWorker(IThreadWorkerCallbacks *hooks, bool threaded);

 	void DestroyWorker(IThreadWorker *pWorker);

 };

 #if defined SM_DEFAULT_THREADER && !defined SM_MAIN_THREADER

 #define SM_MAIN_THREADER PosixThreader;

 typedef class PosixThreader MainThreader;

 #endif

 #endif //_INCLUDE_POSIXTHREADS_H_