1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/graphics/windowing/windowserver/nonnga/SERVER/EVQUEUE.H Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,215 @@
1.4 +// Copyright (c) 1999-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +// Definition of classes related event queues
1.18 +//
1.19 +//
1.20 +
1.21 +#if !defined(__EVQUEUE_H__)
1.22 +#define __EVQUEUE_H__
1.23 +
1.24 +#include <e32std.h>
1.25 +#include <e32base.h>
1.26 +#include <w32std.h>
1.27 +#include <graphics/wsgraphicdrawerinterface.h>
1.28 +
1.29 +class CWsClient;
1.30 +class CWsWindowRedraw;
1.31 +class CWsGraphicDrawer;
1.32 +
1.33 +enum TEventQueueWalkRet
1.34 + {
1.35 + EEventQueueWalkOk,
1.36 + EEventQueueWalkDeleteEvent,
1.37 + EEventQueueWalkRestart,
1.38 + };
1.39 +class TWsEvent;
1.40 +
1.41 +typedef TEventQueueWalkRet (*EventQueueWalk)(TAny *aPtr, TWsEvent *aEvent);
1.42 +
1.43 +enum TWservEventPriorities
1.44 + {
1.45 + EEventPriorityHigh,
1.46 + EEventPriorityLow,
1.47 + };
1.48 +
1.49 +struct TRedraw
1.50 + {
1.51 + CWsWindowRedraw *iRedraw;
1.52 + TUint iPriority;
1.53 + };
1.54 +
1.55 +class CEventBase : public CBase
1.56 + {
1.57 +private:
1.58 + enum TEventSignalledState
1.59 + {
1.60 + EEventFlagSignalled=0x1,
1.61 + EEventFlagCancelled=0x2
1.62 + };
1.63 +public:
1.64 + CEventBase(CWsClient *aOwner);
1.65 + ~CEventBase();
1.66 + void CancelRead();
1.67 + void EventReadyCheck();
1.68 + virtual void EventReady(const RMessagePtr2& aEventMsg);
1.69 + void GetData(TAny *aData, TInt aLen);
1.70 +protected:
1.71 + void SignalEvent(TInt aCode = KErrNone);
1.72 + inline TBool IsEventCancelled();
1.73 +protected:
1.74 + TInt iEventSignalledState;
1.75 + CWsClient *iWsOwner;
1.76 + RMessagePtr2 iEventMsg;
1.77 + };
1.78 +
1.79 +class CEventQueue : public CEventBase
1.80 + {
1.81 +private:
1.82 + enum {EExtraQueueSize=16};
1.83 + enum {EMaxQueueSize=32};
1.84 + enum {EMinQueueSize=2};
1.85 + enum {EQueueGranularity=4};
1.86 + enum TCompressMode
1.87 + {
1.88 + ECompressNoPurge, // Compress only free space
1.89 + ECompressPurge1, // Purge from only non-foreground queues
1.90 + ECompressPurge2, // Purge from all queues
1.91 + };
1.92 +// Functions
1.93 +public:
1.94 + CEventQueue(CWsClient *aOwner);
1.95 + ~CEventQueue();
1.96 + void ConstructL();
1.97 + TBool QueueEvent(const TWsEvent &event);
1.98 + TBool QueueEvent(const TWsEvent &event, TWservEventPriorities aPriority);
1.99 + TBool QueueEvent(TUint32 aTarget, TInt aEvent);
1.100 + TBool CheckRoom();
1.101 + void GetData();
1.102 + void UpdateLastEvent(const TWsEvent &event);
1.103 + void RemoveEvent(TInt index);
1.104 + void PurgePointerEvents();
1.105 + const TWsEvent *PeekLastEvent();
1.106 + void WalkEventQueue(EventQueueWalk aFunc, TAny *aFuncParam);
1.107 + void MoveToFront();
1.108 + static void Wait();
1.109 + static void Signal();
1.110 + static void InitStaticsL();
1.111 + static void DeleteStaticsL();
1.112 + //void LogUpDownEvents(TChar aChar);
1.113 +public:// from CEventBase
1.114 + void EventReady(const RMessagePtr2& aEventMsg);
1.115 +private:
1.116 + static void EventCopy(TWsEvent *aStart, TWsEvent *aEnd, TInt aNumEvents);
1.117 + static TInt RequiredQueueSize(TInt aNumConnections);
1.118 + void AdjustQueueSizeL(TInt aNewSize);
1.119 + void IncreaseQueueSize(TInt aNumSpaces);
1.120 + TInt FollowingGap() const;
1.121 + void Purge();
1.122 + TInt PurgeInactiveEvents(const TInt& aSizeRequired);
1.123 + void Compress(TCompressMode aCompressMode);
1.124 + void AddQueueL();
1.125 + void RemoveQueue();
1.126 + TBool Expand(TWservEventPriorities aPriority);
1.127 + TBool doExpand(TCompressMode aCompressMode);
1.128 + TInt SqueezeUp();
1.129 + void SqueezeDown();
1.130 + void MoveUp(TInt aMove);
1.131 + void MoveDown(TInt aMove);
1.132 + TBool MoveDownAndExpand(TDblQueIter<CEventQueue> &aIter, TInt aExpand);
1.133 +#if defined(_DEBUG)
1.134 + void CheckQueue();
1.135 + void ZapEvent(TWsEvent *aTarget);
1.136 + void ZapEvents(TWsEvent *aTarget, TInt aLen);
1.137 +#endif
1.138 +private:
1.139 + void QueueActive();
1.140 + TWsEvent *EventPtr(TInt index);
1.141 +// Data
1.142 + TInt iHead;
1.143 + TInt iCount;
1.144 + TInt iQueueSize;
1.145 + TWsEvent *iEventPtr;
1.146 + TDblQueLink iLink;
1.147 + static RMutex iMutex;
1.148 + static TWsEvent iNullEvent;
1.149 + static TDblQue<CEventQueue> iQueueList;
1.150 + static TWsEvent *iGlobalEventQueue;
1.151 + static TInt iGlobalEventQueueSize;
1.152 + static TInt iNumConnections;
1.153 + };
1.154 +
1.155 +class TWsRedrawEvent;
1.156 +
1.157 +class CRedrawQueue : public CEventBase
1.158 + {
1.159 +// Functions
1.160 +public:
1.161 + CRedrawQueue(CWsClient *aOwner);
1.162 + ~CRedrawQueue();
1.163 + void ConstructL();
1.164 + TBool TriggerRedraw();
1.165 + void ReCalcOrder();
1.166 + void AddInvalid(CWsWindowRedraw *redrawWin);
1.167 + void RemoveInvalid(CWsWindowRedraw *redrawWin);
1.168 + void GetData();
1.169 + TUint RedrawPriority(CWsWindowRedraw *aRedrawWin);
1.170 +public:// from CEventBase
1.171 + void EventReady(const RMessagePtr2& aEventMsg);
1.172 +private:
1.173 + void DeleteFromQueue(TInt aIndex);
1.174 + void QueueActive();
1.175 + TBool FindOutstandingRedrawEvent(CWsWindowRedraw& aRedraw, TWsRedrawEvent& aEvent);
1.176 + TBool FindWindowNeedingRedrawEvent(TWsRedrawEvent& aEvent);
1.177 +private:
1.178 +// Data
1.179 + CArrayFixSeg<TRedraw> *iRedraws; // List of windows and their areas that require redraws
1.180 + TBool iAllocError;
1.181 + TBool iRedrawTrigger;
1.182 + TKeyArrayFix *iKeyPriority;
1.183 + TKeyArrayFix *iKeyWindow;
1.184 + static TWsRedrawEvent iNullRedrawEvent;
1.185 + };
1.186 +
1.187 +class CWsGraphicMessageQueue: public CEventBase
1.188 + {
1.189 +public:
1.190 + class CMessage: public CWsMessageData
1.191 + {
1.192 + public:
1.193 + static CMessage* New(const TDesC8& aData);
1.194 + ~CMessage();
1.195 + public: // From CWsMessageData
1.196 + TPtrC8 Data() const;
1.197 + void Release();
1.198 + private:
1.199 + CMessage(const TDesC8& aData);
1.200 + private:
1.201 + TPtr8 iData;
1.202 + };
1.203 +public:
1.204 + CWsGraphicMessageQueue(CWsClient *aOwner);
1.205 + ~CWsGraphicMessageQueue();
1.206 + void GetGraphicMessage();
1.207 + void AbortMessage(TInt aError);
1.208 + void EventReady(const RMessagePtr2& aEventMsg);
1.209 + void Queue(CWsMessageData* aMessage);
1.210 + TInt TopClientHandle() const;
1.211 +private:
1.212 + CWsMessageData* iHead;
1.213 + CWsMessageData* iTail;
1.214 + CWsMessageData* Pop();
1.215 + void GetDataWithHeader(TUint aHeader, const TDesC8& aData, TInt aDataLen);
1.216 + };
1.217 +
1.218 +#endif