My first commit on the Symbian Hg repository. Testng how branches are working.
/*
* 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