[picodrive.git] / platform / uiq3 / engine / polledas.cpp

/*******************************************************************\r
 *\r
 *	File:		PolledAS.cpp\r
 *\r
 *	Author:		Peter van Sebille (peter@yipton.net)\r
 *\r
 *	(c) Copyright 2002, Peter van Sebille\r
 *	All Rights Reserved\r
 *\r
 *******************************************************************/\r
\r
/*\r
 * Oh Lord, forgive me for I have sinned.\r
 * In their infinite wisdom, Symbian Engineers have decided that\r
 * the Active Scheduler's queue of Active Objects is private\r
 * and no getters are provided... sigh.\r
 * This mere mortal will have to excercise the power of C pre-processor \r
 * once more to circumvent the will of the gods.\r
 */\r
\r
\r
#include <e32std.h>\r
\r
// from e32base.h\r
class CBase\r
	{\r
public:\r
	/**\r
	Default constructor\r
	*/\r
	inline CBase()	{}\r
	IMPORT_C virtual ~CBase();\r
	inline TAny* operator new(TUint aSize, TAny* aBase) __NO_THROW { Mem::FillZ(aBase, aSize); return aBase; }\r
	inline TAny* operator new(TUint aSize) __NO_THROW { return User::AllocZ(aSize); }\r
	inline TAny* operator new(TUint aSize, TLeave) { return User::AllocZL(aSize); }\r
	inline TAny* operator new(TUint aSize, TUint aExtraSize) { return User::AllocZ(aSize + aExtraSize); }\r
	inline TAny* operator new(TUint aSize, TLeave, TUint aExtraSize) { return User::AllocZL(aSize + aExtraSize); }\r
	IMPORT_C static void Delete(CBase* aPtr);\r
protected:\r
	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny*& a0, TAny* a1);\r
private:\r
	CBase(const CBase&);\r
	CBase& operator=(const CBase&);\r
private:\r
	};\r
\r
\r
class TRequestStatusFaked\r
	{\r
public:\r
	inline TRequestStatusFaked() : iFlags(0) {};\r
	inline TRequestStatusFaked(TInt aVal) : iStatus(aVal), iFlags(aVal==KRequestPending ? TRequestStatusFaked::ERequestPending : 0) {}\r
/*	inline TInt operator=(TInt aVal);\r
	inline TBool operator==(TInt aVal) const;\r
*/\r
	inline TBool operator!=(TInt aVal) const {return(iStatus!=aVal);}\r
/*\r
	inline TBool operator>=(TInt aVal) const;\r
	inline TBool operator<=(TInt aVal) const;\r
	inline TBool operator>(TInt aVal) const;\r
	inline TBool operator<(TInt aVal) const;\r
	inline TInt Int() const;\r
private:\r
*/\r
	enum\r
		{\r
		EActive				= 1,  //bit0\r
		ERequestPending		= 2,  //bit1\r
		};\r
	TInt iStatus;\r
	TUint iFlags;\r
	friend class CActive;\r
	friend class CActiveScheduler;\r
	friend class CServer2;\r
	};\r
\r
\r
class CActive : public CBase\r
	{\r
public:\r
enum TPriority\r
	{\r
	EPriorityIdle=-100,\r
	EPriorityLow=-20,\r
	EPriorityStandard=0,\r
	EPriorityUserInput=10,\r
	EPriorityHigh=20,\r
	};\r
public:\r
	IMPORT_C ~CActive();\r
	IMPORT_C void Cancel();\r
	IMPORT_C void Deque();\r
	IMPORT_C void SetPriority(TInt aPriority);\r
	inline TBool IsActive() const {return(iStatus.iFlags&TRequestStatus::EActive);}\r
	inline TBool IsAdded() const {return(iLink.iNext!=NULL);}\r
	inline TInt Priority() const {return iLink.iPriority;}\r
protected:\r
	IMPORT_C CActive(TInt aPriority);\r
	IMPORT_C void SetActive();\r
	virtual void DoCancel() =0;\r
	virtual void RunL() =0;\r
	IMPORT_C virtual TInt RunError(TInt aError);\r
protected:\r
	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny*& a0, TAny* a1);\r
public:\r
	TRequestStatusFaked iStatus; // hope this will work\r
private:\r
//	TBool iActive;\r
	TPriQueLink iLink;\r
	TAny* iSpare;\r
	friend class CActiveScheduler;\r
	friend class CServer;\r
	friend class CServer2;\r
	friend class CPrivatePolledActiveScheduler; // added\r
	};\r
\r
\r
\r
class CActiveScheduler : public CBase\r
	{\r
	friend class CActiveSchedulerWait;\r
public:\r
	struct TLoop;\r
	typedef TLoop* TLoopOwner;\r
public:\r
	IMPORT_C CActiveScheduler();\r
	IMPORT_C ~CActiveScheduler();\r
	IMPORT_C static void Install(CActiveScheduler* aScheduler);\r
	IMPORT_C static CActiveScheduler* Current();\r
	IMPORT_C static void Add(CActive* aActive);\r
	IMPORT_C static void Start();\r
	IMPORT_C static void Stop();\r
	IMPORT_C static TBool RunIfReady(TInt& aError, TInt aMinimumPriority);\r
	IMPORT_C static CActiveScheduler* Replace(CActiveScheduler* aNewActiveScheduler);\r
	IMPORT_C virtual void WaitForAnyRequest();\r
	IMPORT_C virtual void Error(TInt aError) const;\r
	IMPORT_C void Halt(TInt aExitCode) const;\r
	IMPORT_C TInt StackDepth() const;\r
private:\r
	static void Start(TLoopOwner* aOwner);\r
	IMPORT_C virtual void OnStarting();\r
	IMPORT_C virtual void OnStopping();\r
	IMPORT_C virtual void Reserved_1();\r
	IMPORT_C virtual void Reserved_2();\r
	void Run(TLoopOwner* const volatile& aLoop);\r
	void DoRunL(TLoopOwner* const volatile& aLoop, CActive* volatile & aCurrentObj);\r
	friend class CPrivatePolledActiveScheduler; // added\r
protected:\r
	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny*& a0, TAny* a1);\r
protected:\r
	inline TInt Level() const {return StackDepth();}	// deprecated\r
private:\r
	TLoop* iStack;\r
	TPriQue<CActive> iActiveQ;\r
	TAny* iSpare;\r
	};\r
\r
\r
\r
class TCleanupItem;\r
class CleanupStack\r
	{\r
public:\r
	IMPORT_C static void PushL(TAny* aPtr);\r
	IMPORT_C static void PushL(CBase* aPtr);\r
	IMPORT_C static void PushL(TCleanupItem anItem);\r
	IMPORT_C static void Pop();\r
	IMPORT_C static void Pop(TInt aCount);\r
	IMPORT_C static void PopAndDestroy();\r
	IMPORT_C static void PopAndDestroy(TInt aCount);\r
	IMPORT_C static void Check(TAny* aExpectedItem);\r
	inline static void Pop(TAny* aExpectedItem);\r
	inline static void Pop(TInt aCount, TAny* aLastExpectedItem);\r
	inline static void PopAndDestroy(TAny* aExpectedItem);\r
	inline static void PopAndDestroy(TInt aCount, TAny* aLastExpectedItem);\r
	};\r
\r
\r
/*\r
 * This will declare CPrivatePolledActiveScheduler as a friend\r
 * of all classes that define a friend. CPrivatePolledActiveScheduler needs to\r
 * be a friend of CActive\r
 */\r
//#define friend friend class CPrivatePolledActiveScheduler; friend\r
\r
\r
/*\r
 * This will change the:\r
 *		 void DoStart();\r
 * method in CActiveScheduler to:\r
 *		 void DoStart(); friend class CPrivatePolledActiveScheduler;\r
 * We need this to access the private datamembers in CActiveScheduler.\r
 */\r
//#define DoStart() DoStart(); friend class CPrivatePolledActiveScheduler;\r
//#include <e32base.h>\r
#include "PolledAS.h"\r
\r
\r
class CPrivatePolledActiveScheduler : public CActiveScheduler\r
{\r
public:\r
	void Schedule();\r
};\r
\r
\r
void CPrivatePolledActiveScheduler::Schedule()\r
{\r
	TDblQueIter<CActive> q(iActiveQ);\r
	q.SetToFirst();\r
	FOREVER\r
	{\r
		CActive *pR=q++;\r
		if (pR)\r
		{\r
			//TRequestStatus::EActive				= 1,  //bit0\r
			//TRequestStatus::ERequestPending		= 2,  //bit1\r
			if (pR->IsActive() && pR->iStatus!=KRequestPending)\r
			{\r
//				pR->iActive=EFalse; // won't this cause trouble?\r
				pR->iStatus.iFlags&=~TRequestStatusFaked::EActive;\r
				//debugPrintFile(_L("as: %08x"), pR);\r
				TRAPD(r,pR->RunL());\r
				//pR->iStatus=TRequestStatus::ERequestPending;\r
				break;\r
			}\r
		}\r
		else\r
			break;\r
	}\r
}\r
\r
\r
static CPolledActiveScheduler* sPolledActiveScheduler = NULL;\r
\r
CPolledActiveScheduler::~CPolledActiveScheduler()\r
{\r
	sPolledActiveScheduler = NULL;\r
	delete iPrivatePolledActiveScheduler;\r
}\r
\r
CPolledActiveScheduler* CPolledActiveScheduler::NewL()\r
{\r
	// if (sPolledActiveScheduler == NULL)\r
	{\r
		sPolledActiveScheduler = new(ELeave)CPolledActiveScheduler;\r
		CleanupStack::PushL(sPolledActiveScheduler);\r
		sPolledActiveScheduler->ConstructL();\r
		CleanupStack::Pop();\r
	}\r
	return sPolledActiveScheduler;\r
}\r
\r
void CPolledActiveScheduler::ConstructL()\r
{\r
	iPrivatePolledActiveScheduler = new(ELeave) CPrivatePolledActiveScheduler;\r
	iPrivatePolledActiveScheduler->Install(iPrivatePolledActiveScheduler);\r
}\r
\r
\r
void CPolledActiveScheduler::Schedule()\r
{\r
	iPrivatePolledActiveScheduler->Schedule();\r
}\r
\r
CPolledActiveScheduler* CPolledActiveScheduler::Instance()\r
{\r
//	return (CPolledActiveScheduler*) CActiveScheduler::Current();\r
	return sPolledActiveScheduler;\r
}\r
Commit	Line	Data
	1	/*******************************************************************\r
	2	*\r
	3	* File: PolledAS.cpp\r
	4	*\r
	5	* Author: Peter van Sebille (peter@yipton.net)\r
	6	*\r
	7	* (c) Copyright 2002, Peter van Sebille\r
	8	* All Rights Reserved\r
	9	*\r
	10	*******************************************************************/\r
	11	\r
	12	/*\r
	13	* Oh Lord, forgive me for I have sinned.\r
	14	* In their infinite wisdom, Symbian Engineers have decided that\r
	15	* the Active Scheduler's queue of Active Objects is private\r
	16	* and no getters are provided... sigh.\r
	17	* This mere mortal will have to excercise the power of C pre-processor \r
	18	* once more to circumvent the will of the gods.\r
	19	*/\r
	20	\r
	21	\r
	22	#include <e32std.h>\r
	23	\r
	24	// from e32base.h\r
	25	class CBase\r
	26	{\r
	27	public:\r
	28	/**\r
	29	Default constructor\r
	30	*/\r
	31	inline CBase() {}\r
	32	IMPORT_C virtual ~CBase();\r
	33	inline TAny* operator new(TUint aSize, TAny* aBase) __NO_THROW { Mem::FillZ(aBase, aSize); return aBase; }\r
	34	inline TAny* operator new(TUint aSize) __NO_THROW { return User::AllocZ(aSize); }\r
	35	inline TAny* operator new(TUint aSize, TLeave) { return User::AllocZL(aSize); }\r
	36	inline TAny* operator new(TUint aSize, TUint aExtraSize) { return User::AllocZ(aSize + aExtraSize); }\r
	37	inline TAny* operator new(TUint aSize, TLeave, TUint aExtraSize) { return User::AllocZL(aSize + aExtraSize); }\r
	38	IMPORT_C static void Delete(CBase* aPtr);\r
	39	protected:\r
	40	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny& a0, TAny a1);\r
	41	private:\r
	42	CBase(const CBase&);\r
	43	CBase& operator=(const CBase&);\r
	44	private:\r
	45	};\r
	46	\r
	47	\r
	48	class TRequestStatusFaked\r
	49	{\r
	50	public:\r
	51	inline TRequestStatusFaked() : iFlags(0) {};\r
	52	inline TRequestStatusFaked(TInt aVal) : iStatus(aVal), iFlags(aVal==KRequestPending ? TRequestStatusFaked::ERequestPending : 0) {}\r
	53	/* inline TInt operator=(TInt aVal);\r
	54	inline TBool operator==(TInt aVal) const;\r
	55	*/\r
	56	inline TBool operator!=(TInt aVal) const {return(iStatus!=aVal);}\r
	57	/*\r
	58	inline TBool operator>=(TInt aVal) const;\r
	59	inline TBool operator<=(TInt aVal) const;\r
	60	inline TBool operator>(TInt aVal) const;\r
	61	inline TBool operator<(TInt aVal) const;\r
	62	inline TInt Int() const;\r
	63	private:\r
	64	*/\r
	65	enum\r
	66	{\r
	67	EActive = 1, //bit0\r
	68	ERequestPending = 2, //bit1\r
	69	};\r
	70	TInt iStatus;\r
	71	TUint iFlags;\r
	72	friend class CActive;\r
	73	friend class CActiveScheduler;\r
	74	friend class CServer2;\r
	75	};\r
	76	\r
	77	\r
	78	class CActive : public CBase\r
	79	{\r
	80	public:\r
	81	enum TPriority\r
	82	{\r
	83	EPriorityIdle=-100,\r
	84	EPriorityLow=-20,\r
	85	EPriorityStandard=0,\r
	86	EPriorityUserInput=10,\r
	87	EPriorityHigh=20,\r
	88	};\r
	89	public:\r
	90	IMPORT_C ~CActive();\r
	91	IMPORT_C void Cancel();\r
	92	IMPORT_C void Deque();\r
	93	IMPORT_C void SetPriority(TInt aPriority);\r
	94	inline TBool IsActive() const {return(iStatus.iFlags&TRequestStatus::EActive);}\r
	95	inline TBool IsAdded() const {return(iLink.iNext!=NULL);}\r
	96	inline TInt Priority() const {return iLink.iPriority;}\r
	97	protected:\r
	98	IMPORT_C CActive(TInt aPriority);\r
	99	IMPORT_C void SetActive();\r
	100	virtual void DoCancel() =0;\r
	101	virtual void RunL() =0;\r
	102	IMPORT_C virtual TInt RunError(TInt aError);\r
	103	protected:\r
	104	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny& a0, TAny a1);\r
	105	public:\r
	106	TRequestStatusFaked iStatus; // hope this will work\r
	107	private:\r
	108	// TBool iActive;\r
	109	TPriQueLink iLink;\r
	110	TAny* iSpare;\r
	111	friend class CActiveScheduler;\r
	112	friend class CServer;\r
	113	friend class CServer2;\r
	114	friend class CPrivatePolledActiveScheduler; // added\r
	115	};\r
	116	\r
	117	\r
	118	\r
	119	class CActiveScheduler : public CBase\r
	120	{\r
	121	friend class CActiveSchedulerWait;\r
	122	public:\r
	123	struct TLoop;\r
	124	typedef TLoop* TLoopOwner;\r
	125	public:\r
	126	IMPORT_C CActiveScheduler();\r
	127	IMPORT_C ~CActiveScheduler();\r
	128	IMPORT_C static void Install(CActiveScheduler* aScheduler);\r
	129	IMPORT_C static CActiveScheduler* Current();\r
	130	IMPORT_C static void Add(CActive* aActive);\r
	131	IMPORT_C static void Start();\r
	132	IMPORT_C static void Stop();\r
	133	IMPORT_C static TBool RunIfReady(TInt& aError, TInt aMinimumPriority);\r
	134	IMPORT_C static CActiveScheduler* Replace(CActiveScheduler* aNewActiveScheduler);\r
	135	IMPORT_C virtual void WaitForAnyRequest();\r
	136	IMPORT_C virtual void Error(TInt aError) const;\r
	137	IMPORT_C void Halt(TInt aExitCode) const;\r
	138	IMPORT_C TInt StackDepth() const;\r
	139	private:\r
	140	static void Start(TLoopOwner* aOwner);\r
	141	IMPORT_C virtual void OnStarting();\r
	142	IMPORT_C virtual void OnStopping();\r
	143	IMPORT_C virtual void Reserved_1();\r
	144	IMPORT_C virtual void Reserved_2();\r
	145	void Run(TLoopOwner* const volatile& aLoop);\r
	146	void DoRunL(TLoopOwner* const volatile& aLoop, CActive* volatile & aCurrentObj);\r
	147	friend class CPrivatePolledActiveScheduler; // added\r
	148	protected:\r
	149	IMPORT_C virtual TInt Extension_(TUint aExtensionId, TAny& a0, TAny a1);\r
	150	protected:\r
	151	inline TInt Level() const {return StackDepth();} // deprecated\r
	152	private:\r
	153	TLoop* iStack;\r
	154	TPriQue<CActive> iActiveQ;\r
	155	TAny* iSpare;\r
	156	};\r
	157	\r
	158	\r
	159	\r
	160	class TCleanupItem;\r
	161	class CleanupStack\r
	162	{\r
	163	public:\r
	164	IMPORT_C static void PushL(TAny* aPtr);\r
	165	IMPORT_C static void PushL(CBase* aPtr);\r
	166	IMPORT_C static void PushL(TCleanupItem anItem);\r
	167	IMPORT_C static void Pop();\r
	168	IMPORT_C static void Pop(TInt aCount);\r
	169	IMPORT_C static void PopAndDestroy();\r
	170	IMPORT_C static void PopAndDestroy(TInt aCount);\r
	171	IMPORT_C static void Check(TAny* aExpectedItem);\r
	172	inline static void Pop(TAny* aExpectedItem);\r
	173	inline static void Pop(TInt aCount, TAny* aLastExpectedItem);\r
	174	inline static void PopAndDestroy(TAny* aExpectedItem);\r
	175	inline static void PopAndDestroy(TInt aCount, TAny* aLastExpectedItem);\r
	176	};\r
	177	\r
	178	\r
	179	/*\r
	180	* This will declare CPrivatePolledActiveScheduler as a friend\r
	181	* of all classes that define a friend. CPrivatePolledActiveScheduler needs to\r
	182	* be a friend of CActive\r
	183	*/\r
	184	//#define friend friend class CPrivatePolledActiveScheduler; friend\r
	185	\r
	186	\r
	187	/*\r
	188	* This will change the:\r
	189	* void DoStart();\r
	190	* method in CActiveScheduler to:\r
	191	* void DoStart(); friend class CPrivatePolledActiveScheduler;\r
	192	* We need this to access the private datamembers in CActiveScheduler.\r
	193	*/\r
	194	//#define DoStart() DoStart(); friend class CPrivatePolledActiveScheduler;\r
	195	//#include <e32base.h>\r
	196	#include "PolledAS.h"\r
	197	\r
	198	\r
	199	class CPrivatePolledActiveScheduler : public CActiveScheduler\r
	200	{\r
	201	public:\r
	202	void Schedule();\r
	203	};\r
	204	\r
	205	\r
	206	void CPrivatePolledActiveScheduler::Schedule()\r
	207	{\r
	208	TDblQueIter<CActive> q(iActiveQ);\r
	209	q.SetToFirst();\r
	210	FOREVER\r
	211	{\r
	212	CActive *pR=q++;\r
	213	if (pR)\r
	214	{\r
	215	//TRequestStatus::EActive = 1, //bit0\r
	216	//TRequestStatus::ERequestPending = 2, //bit1\r
	217	if (pR->IsActive() && pR->iStatus!=KRequestPending)\r
	218	{\r
	219	// pR->iActive=EFalse; // won't this cause trouble?\r
	220	pR->iStatus.iFlags&=~TRequestStatusFaked::EActive;\r
	221	//debugPrintFile(_L("as: %08x"), pR);\r
	222	TRAPD(r,pR->RunL());\r
	223	//pR->iStatus=TRequestStatus::ERequestPending;\r
	224	break;\r
	225	}\r
	226	}\r
	227	else\r
	228	break;\r
	229	}\r
	230	}\r
	231	\r
	232	\r
	233	static CPolledActiveScheduler* sPolledActiveScheduler = NULL;\r
	234	\r
	235	CPolledActiveScheduler::~CPolledActiveScheduler()\r
	236	{\r
	237	sPolledActiveScheduler = NULL;\r
	238	delete iPrivatePolledActiveScheduler;\r
	239	}\r
	240	\r
	241	CPolledActiveScheduler* CPolledActiveScheduler::NewL()\r
	242	{\r
	243	// if (sPolledActiveScheduler == NULL)\r
	244	{\r
	245	sPolledActiveScheduler = new(ELeave)CPolledActiveScheduler;\r
	246	CleanupStack::PushL(sPolledActiveScheduler);\r
	247	sPolledActiveScheduler->ConstructL();\r
	248	CleanupStack::Pop();\r
	249	}\r
	250	return sPolledActiveScheduler;\r
	251	}\r
	252	\r
	253	void CPolledActiveScheduler::ConstructL()\r
	254	{\r
	255	iPrivatePolledActiveScheduler = new(ELeave) CPrivatePolledActiveScheduler;\r
	256	iPrivatePolledActiveScheduler->Install(iPrivatePolledActiveScheduler);\r
	257	}\r
	258	\r
	259	\r
	260	void CPolledActiveScheduler::Schedule()\r
	261	{\r
	262	iPrivatePolledActiveScheduler->Schedule();\r
	263	}\r
	264	\r
	265	CPolledActiveScheduler* CPolledActiveScheduler::Instance()\r
	266	{\r
	267	// return (CPolledActiveScheduler*) CActiveScheduler::Current();\r
	268	return sPolledActiveScheduler;\r
	269	}\r