1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/graphics/windowing/windowserver/nga/SERVER/EVQUEUE.H Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,244 @@
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 <graphics/WSGRAPHICDRAWERINTERFACE.H>
1.27 +#include "W32STD.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, TInt aIntVal = 0);
1.100 + TBool CheckRoom();
1.101 + void GetData();
1.102 + void UpdateLastEvent(const TWsEvent &event);
1.103 + TBool UpdateLastPointerEvent(const TWsEvent &event);
1.104 + void RemoveEvent(TInt index);
1.105 + void PurgePointerEvents();
1.106 + const TWsEvent* PeekLastEvent();
1.107 + void WalkEventQueue(EventQueueWalk aFunc, TAny* aFuncParam);
1.108 + void MoveToFront();
1.109 + static void Wait();
1.110 + static void Signal();
1.111 + static void InitStaticsL();
1.112 + static void DeleteStaticsL();
1.113 + //void LogUpDownEvents(TChar aChar);
1.114 +public:// from CEventBase
1.115 + void EventReady(const RMessagePtr2& aEventMsg);
1.116 +private:
1.117 + static void EventCopy(TWsEvent* aStart, TWsEvent* aEnd, TInt aNumEvents);
1.118 + static TInt RequiredQueueSize(TInt aNumConnections);
1.119 + void AdjustQueueSizeL(TInt aNewSize);
1.120 + void IncreaseQueueSize(TInt aNumSpaces);
1.121 + TInt FollowingGap() const;
1.122 + void Purge();
1.123 + TInt PurgeInactiveEvents(const TInt& aSizeRequired);
1.124 + void Compress(TCompressMode aCompressMode);
1.125 + void AddQueueL();
1.126 + void RemoveQueue();
1.127 + TBool Expand(TWservEventPriorities aPriority);
1.128 + TBool doExpand(TCompressMode aCompressMode);
1.129 + TInt SqueezeUp();
1.130 + void SqueezeDown();
1.131 + void MoveUp(TInt aMove);
1.132 + void MoveDown(TInt aMove);
1.133 + TBool MoveDownAndExpand(TDblQueIter<CEventQueue> &aIter, TInt aExpand);
1.134 +#if defined(_DEBUG)
1.135 + void CheckQueue();
1.136 + void ZapEvent(TWsEvent* aTarget);
1.137 + void ZapEvents(TWsEvent* aTarget, TInt aLen);
1.138 +#endif
1.139 +private:
1.140 + void QueueActive();
1.141 + TWsEvent* EventPtr(TInt index);
1.142 + void RemoveEvent(TWsEvent* aEvToRemove);
1.143 + inline void IncEventPointer(TWsEvent*& aEventPtr);
1.144 + inline void DecEventPointer(TWsEvent*& aEventPtr);
1.145 + void PurgeEventPairs(TWsEvent* aEventToPurge, TPointerEvent::TType aMatchingType, TPointerEvent::TType aSearchTerminator);
1.146 + TWsEvent* NextPointerEvent(TWsEvent* aBaseEvent);
1.147 + TBool CheckPurgePointerEvent(TWsEvent* aEventToPurge);
1.148 +private:
1.149 + /** Position of head in local queue relative to iEventPtr.
1.150 + First event to send to the Client. */
1.151 + TInt iHead;
1.152 +
1.153 + /** Number of events waiting in local queue */
1.154 + TInt iCount;
1.155 +
1.156 + /** Size of local queue = maximum number of events */
1.157 + TInt iQueueSize;
1.158 +
1.159 + /** Beginning of local queue */
1.160 + TWsEvent* iEventPtr;
1.161 +
1.162 + /** Used by iQueueList to link local queues */
1.163 + TDblQueLink iLink;
1.164 +
1.165 + /** Mutex for operations on global event queue */
1.166 + static RMutex iMutex;
1.167 +
1.168 + /** Always filled with zeros */
1.169 + static TWsEvent iNullEvent;
1.170 +
1.171 + /** List of event queues */
1.172 + static TDblQue<CEventQueue> iQueueList;
1.173 +
1.174 + /** Global queue that keeps all events queues */
1.175 + static TWsEvent* iGlobalEventQueue;
1.176 +
1.177 + /** Size of global queue */
1.178 + static TInt iGlobalEventQueueSize;
1.179 +
1.180 + /** Number of event queues */
1.181 + static TInt iNumConnections;
1.182 + };
1.183 +
1.184 +class TWsRedrawEvent;
1.185 +
1.186 +class CRedrawQueue : public CEventBase
1.187 + {
1.188 +// Functions
1.189 +public:
1.190 + CRedrawQueue(CWsClient *aOwner);
1.191 + ~CRedrawQueue();
1.192 + void ConstructL();
1.193 + TBool TriggerRedraw();
1.194 + void ReCalcOrder();
1.195 + void AddInvalid(CWsWindowRedraw *redrawWin);
1.196 + void RemoveInvalid(CWsWindowRedraw *redrawWin);
1.197 + void GetData();
1.198 + TUint RedrawPriority(CWsWindowRedraw *aRedrawWin);
1.199 +public:// from CEventBase
1.200 + void EventReady(const RMessagePtr2& aEventMsg);
1.201 +private:
1.202 + void DeleteFromQueue(TInt aIndex);
1.203 + void QueueActive();
1.204 + TBool FindOutstandingRedrawEvent(CWsWindowRedraw& aRedraw, TWsRedrawEvent& aEvent);
1.205 + TBool FindWindowNeedingRedrawEvent(TWsRedrawEvent& aEvent);
1.206 +private:
1.207 +// Data
1.208 + CArrayFixSeg<TRedraw> *iRedraws; // List of windows and their areas that require redraws
1.209 + TBool iAllocError;
1.210 + TBool iRedrawTrigger;
1.211 + TKeyArrayFix *iKeyPriority;
1.212 + TKeyArrayFix *iKeyWindow;
1.213 + static TWsRedrawEvent iNullRedrawEvent;
1.214 + };
1.215 +
1.216 +class CWsGraphicMessageQueue: public CEventBase
1.217 + {
1.218 +public:
1.219 + class CMessage: public CWsMessageData
1.220 + {
1.221 + public:
1.222 + static CMessage* New(const TDesC8& aData);
1.223 + ~CMessage();
1.224 + public: // From CWsMessageData
1.225 + TPtrC8 Data() const;
1.226 + void Release();
1.227 + private:
1.228 + CMessage(const TDesC8& aData);
1.229 + private:
1.230 + TPtr8 iData;
1.231 + };
1.232 +public:
1.233 + CWsGraphicMessageQueue(CWsClient *aOwner);
1.234 + ~CWsGraphicMessageQueue();
1.235 + void GetGraphicMessage();
1.236 + void AbortMessage(TInt aError);
1.237 + void EventReady(const RMessagePtr2& aEventMsg);
1.238 + void Queue(CWsMessageData* aMessage);
1.239 + TInt TopClientHandle() const;
1.240 +private:
1.241 + CWsMessageData* iHead;
1.242 + CWsMessageData* iTail;
1.243 + CWsMessageData* Pop();
1.244 + void GetDataWithHeader(TUint aHeader, const TDesC8& aData, TInt aDataLen);
1.245 + };
1.246 +
1.247 +#endif