sl@0: /*
sl@0: * Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: * All rights reserved.
sl@0: * This component and the accompanying materials are made available
sl@0: * under the terms of the License "Eclipse Public License v1.0"
sl@0: * which accompanies this distribution, and is available
sl@0: * at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: *
sl@0: * Initial Contributors:
sl@0: * Nokia Corporation - initial contribution.
sl@0: *
sl@0: * Contributors:
sl@0: *
sl@0: * Description:
sl@0: * e32\personality\example\personality_int.h
sl@0: * Internal header file for example RTOS personality.
sl@0: * This will be included by the personality layer source files.
sl@0: * 
sl@0: * WARNING: This file contains some APIs which are internal and are subject
sl@0: *          to change without notice. Such APIs should therefore not be used
sl@0: *          outside the Kernel and Hardware Services package.
sl@0: *
sl@0: */
sl@0: 
sl@0: 
sl@0: 
sl@0: /**
sl@0:  @file
sl@0:  @internalComponent
sl@0: */
sl@0: 
sl@0: #ifndef __PERSONALITY_INT_H__
sl@0: #define __PERSONALITY_INT_H__
sl@0: 
sl@0: // NThreadBase member data
sl@0: #define __INCLUDE_NTHREADBASE_DEFINES__
sl@0: 
sl@0: #include <personality/example/personality.h>
sl@0: #include <kernel/kern_priv.h>
sl@0: 
sl@0: // dummy constructor
sl@0: inline NThreadBase::NThreadBase()
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: class PThread : public NThread
sl@0: 	{
sl@0: public:
sl@0: 	enum PThreadState
sl@0: 		{
sl@0: 		EWaitMsgQ = NThreadBase::ENumNStates,
sl@0: 		EWaitSemaphore
sl@0: 		};
sl@0: public:
sl@0: 	static TInt Create(PThread*& aThread, const taskinfo* aInfo);
sl@0: 	static void CreateAll(const taskinfo* aInfo);
sl@0: 	static void MsgQIDfcFn(TAny*);
sl@0: 	static void StateHandler(NThread* aThread, TInt aOp, TInt aParam);
sl@0: 	static void ExceptionHandler(TAny* aContext, NThread* aThread);
sl@0: public:
sl@0: 	inline PThread() : iMsgQIDfc(0,0) {}	// dummy constructor
sl@0: 	void ISRPost(msghdr* aM);
sl@0: 	void Post(msghdr* aFirst, msghdr* aLast);
sl@0: 	msghdr* GetMsg();
sl@0: 	void HandleSuspend();
sl@0: 	void HandleResume();
sl@0: 	void HandleRelease(TInt aReturnCode);
sl@0: 	void HandlePriorityChange(TInt aNewPriority);
sl@0: 	void HandleTimeout();
sl@0: public:
sl@0: 	TInt	iTaskId;
sl@0: 	TInt	iSetPriority;
sl@0: 	msghdr*	iFirstMsg;
sl@0: 	msghdr* iLastMsg;
sl@0: 	TDfc	iMsgQIDfc;
sl@0: 	msghdr* iISRFirstMsg;
sl@0: 	msghdr* iISRLastMsg;
sl@0: public:
sl@0: 	static TInt NumTasks;
sl@0: 	static TInt MaxTaskId;
sl@0: 	static PThread** TaskTable;
sl@0: 	static const TUint8 NThreadPriorityTable[MAX_TASK_PRIORITY+1];
sl@0: 	static const SNThreadHandlers Handlers;
sl@0: 	};
sl@0: 
sl@0: class PMemPool;
sl@0: struct SMemBlock
sl@0: 	{
sl@0: 	PMemPool*	iPool;
sl@0: 	SMemBlock*	iNext;		// only if free block
sl@0: 	};
sl@0: 
sl@0: class PMemPool
sl@0: 	{
sl@0: public:
sl@0: 	TInt Create(const poolinfo* aInfo);
sl@0: 	void* Alloc();
sl@0: 	void Free(void* aBlock);
sl@0: public:
sl@0: 	SMemBlock*	iFirstFree;
sl@0: 	size_t		iBlockSize;
sl@0: 	};
sl@0: 
sl@0: class PMemMgr
sl@0: 	{
sl@0: public:
sl@0: 	static void Create(const poolinfo* aInfo);
sl@0: 	static void* Alloc(size_t aSize);
sl@0: 	static void Free(void* aBlock);
sl@0: public:
sl@0: 	TInt iPoolCount;
sl@0: 	PMemPool iPools[1];		// extend
sl@0: public:
sl@0: 	static PMemMgr* TheMgr;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: class PTimer : public NTimer
sl@0: 	{
sl@0: public:
sl@0: 	PTimer();
sl@0: 	static void CreateAll();
sl@0: 	static void NTimerExpired(TAny*);
sl@0: public:
sl@0: 	TInt		iPeriod;	// 0 if single shot
sl@0: 	TAny*		iCookie;
sl@0: 	PThread*	iThread;
sl@0: 	TUint		iExpiryCount;
sl@0: public:
sl@0: 	static TInt NumTimers;
sl@0: 	static PTimer* TimerTable;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: class PSemaphore
sl@0: 	{
sl@0: public:
sl@0: 	static void CreateAll();
sl@0: public:
sl@0: 	PSemaphore();
sl@0: 	void WaitCancel(PThread* aThread);
sl@0: 	void SuspendWaitingThread(PThread* aThread);
sl@0: 	void ResumeWaitingThread(PThread* aThread);
sl@0: 	void ChangeWaitingThreadPriority(PThread* aThread, TInt aNewPriority);
sl@0: 	void Signal();
sl@0: 	void ISRSignal();
sl@0: 	static void IDfcFn(TAny*);
sl@0: public:
sl@0: 	TInt iCount;
sl@0: 	TInt iISRCount;
sl@0: 	TDfc iIDfc;
sl@0: 	SDblQue iSuspendedQ;
sl@0: 	TPriList<PThread, KNumPriorities> iWaitQ;
sl@0: public:
sl@0: 	static TInt NumSemaphores;
sl@0: 	static PSemaphore* SemaphoreTable;
sl@0: 	};
sl@0: 
sl@0: class TPMsgQ : public TDfc
sl@0: 	{
sl@0: public:
sl@0: 	TPMsgQ(TDfcFn aFunction, TAny* aPtr, TDfcQue* aDfcQ, TInt aPriority);
sl@0: 	void Receive();
sl@0: 	msghdr* Get();
sl@0: 	void CancelReceive();
sl@0: public:
sl@0: 	msghdr* iFirstMsg;
sl@0: 	msghdr* iLastMsg;
sl@0: 	TBool iReady;
sl@0: public:
sl@0: 	static TPMsgQ* ThePMsgQ;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: #endif