/*

 * Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).

 * All rights reserved.

 * This component and the accompanying materials are made available

 * under the terms of the License "Eclipse Public License v1.0"

 * which accompanies this distribution, and is available

 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

 *

 * Initial Contributors:

 * Nokia Corporation - initial contribution.

 *

 * Contributors:

 *

 * Description:

 * e32\personality\example\personality_int.h

 * Internal header file for example RTOS personality.

 * This will be included by the personality layer source files.

 * 

 * WARNING: This file contains some APIs which are internal and are subject

 *          to change without notice. Such APIs should therefore not be used

 *          outside the Kernel and Hardware Services package.

 *

 */

 /**

  @file

  @internalComponent

 */

 #ifndef __PERSONALITY_INT_H__

 #define __PERSONALITY_INT_H__

 // NThreadBase member data

 #define __INCLUDE_NTHREADBASE_DEFINES__

 #include <personality/example/personality.h>

 #include <kernel/kern_priv.h>

 // dummy constructor

 inline NThreadBase::NThreadBase()

 	{

 	}

 class PThread : public NThread

 	{

 public:

 	enum PThreadState

 		{

 		EWaitMsgQ = NThreadBase::ENumNStates,

 		EWaitSemaphore

 		};

 public:

 	static TInt Create(PThread*& aThread, const taskinfo* aInfo);

 	static void CreateAll(const taskinfo* aInfo);

 	static void MsgQIDfcFn(TAny*);

 	static void StateHandler(NThread* aThread, TInt aOp, TInt aParam);

 	static void ExceptionHandler(TAny* aContext, NThread* aThread);

 public:

 	inline PThread() : iMsgQIDfc(0,0) {}	// dummy constructor

 	void ISRPost(msghdr* aM);

 	void Post(msghdr* aFirst, msghdr* aLast);

 	msghdr* GetMsg();

 	void HandleSuspend();

 	void HandleResume();

 	void HandleRelease(TInt aReturnCode);

 	void HandlePriorityChange(TInt aNewPriority);

 	void HandleTimeout();

 public:

 	TInt	iTaskId;

 	TInt	iSetPriority;

 	msghdr*	iFirstMsg;

 	msghdr* iLastMsg;

 	TDfc	iMsgQIDfc;

 	msghdr* iISRFirstMsg;

 	msghdr* iISRLastMsg;

 public:

 	static TInt NumTasks;

 	static TInt MaxTaskId;

 	static PThread** TaskTable;

 	static const TUint8 NThreadPriorityTable[MAX_TASK_PRIORITY+1];

 	static const SNThreadHandlers Handlers;

 	};

 class PMemPool;

 struct SMemBlock

 	{

 	PMemPool*	iPool;

 	SMemBlock*	iNext;		// only if free block

 	};

 class PMemPool

 	{

 public:

 	TInt Create(const poolinfo* aInfo);

 	void* Alloc();

 	void Free(void* aBlock);

 public:

 	SMemBlock*	iFirstFree;

 	size_t		iBlockSize;

 	};

 class PMemMgr

 	{

 public:

 	static void Create(const poolinfo* aInfo);

 	static void* Alloc(size_t aSize);

 	static void Free(void* aBlock);

 public:

 	TInt iPoolCount;

 	PMemPool iPools[1];		// extend

 public:

 	static PMemMgr* TheMgr;

 	};

 class PTimer : public NTimer

 	{

 public:

 	PTimer();

 	static void CreateAll();

 	static void NTimerExpired(TAny*);

 public:

 	TInt		iPeriod;	// 0 if single shot

 	TAny*		iCookie;

 	PThread*	iThread;

 	TUint		iExpiryCount;

 public:

 	static TInt NumTimers;

 	static PTimer* TimerTable;

 	};

 class PSemaphore

 	{

 public:

 	static void CreateAll();

 public:

 	PSemaphore();

 	void WaitCancel(PThread* aThread);

 	void SuspendWaitingThread(PThread* aThread);

 	void ResumeWaitingThread(PThread* aThread);

 	void ChangeWaitingThreadPriority(PThread* aThread, TInt aNewPriority);

 	void Signal();

 	void ISRSignal();

 	static void IDfcFn(TAny*);

 public:

 	TInt iCount;

 	TInt iISRCount;

 	TDfc iIDfc;

 	SDblQue iSuspendedQ;

 	TPriList<PThread, KNumPriorities> iWaitQ;

 public:

 	static TInt NumSemaphores;

 	static PSemaphore* SemaphoreTable;

 	};

 class TPMsgQ : public TDfc

 	{

 public:

 	TPMsgQ(TDfcFn aFunction, TAny* aPtr, TDfcQue* aDfcQ, TInt aPriority);

 	void Receive();

 	msghdr* Get();

 	void CancelReceive();

 public:

 	msghdr* iFirstMsg;

 	msghdr* iLastMsg;

 	TBool iReady;

 public:

 	static TPMsgQ* ThePMsgQ;

 	};

 #endif