diff -r 000000000000 -r 2e3d3ce01487 appfw/viewserver/inc/VWSQUEUE.H --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/appfw/viewserver/inc/VWSQUEUE.H Tue Feb 02 10:12:00 2010 +0200 @@ -0,0 +1,115 @@ +// Copyright (c) 1999-2009 Nokia Corporation and/or its subsidiary(-ies). +// All rights reserved. +// This component and the accompanying materials are made available +// under the terms of "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: +// + + +#ifndef __VWSQUEUE_H__ +#define __VWSQUEUE_H__ + +#include +#include + +#include "VWSDEBUG.H" +#include "VWSERVER.H" + + +// +// Constants. +// + +const TInt KQueueSize=16; + + +// +// Forward declarations. +// + +class CVwsEvent; +class CVwsServer; + + +/** + * The CVwsEventQueue class implements an event queue for processing server and session events. + */ +class CVwsEventQueue : public CBase + { +public: + CVwsEventQueue(); + +#ifdef __DO_LOGGING__ + CVwsEventQueue(const TDesC& aName); + void SetName(const TDesC& aName); +#endif + ~CVwsEventQueue(); + void ProcessEventL(CVwsEvent* aEvent); + void HandleEventProcessed(); + CVwsEvent* Head() const; + CVwsEvent* Tail() const; + TInt Count() const; + void HandleSessionRemoval(const TThreadId& aClientThreadId); + void KickStart(); +private: + void DeleteHead(); + TInt AddToTail(CVwsEvent*& aEvent); + TInt RemoveHead(); + TInt DoAddToTail(CVwsEvent* aEvent); + TInt AddToTailIfNotPair(CVwsEvent*& aEvent); + CVwsEvent* At(TInt aIndex); +private: + enum TState + { + EEmpty, + EProcessing + }; +private: + CVwsEvent* iQueue[KQueueSize]; + TInt iQueueStart; + TInt iQueueEnd; + TInt iQueueSize; + TState iState; +#ifdef __DO_LOGGING__ + TBuf<64> iQueueName; +#endif + }; + + +/** + * The CVwsEvent class is the base class for events which can be processed by the server and session event queues + */ +class CVwsEvent : public CBase + { +public: + enum TType + { + ENormal, + ERejectPairs + }; +public: + CVwsEvent(TType aType,CVwsEventQueue& aQueue); + ~CVwsEvent(); + TType Type(); + void ReportEventProcessed(); +private: + friend class CVwsEventQueue; + virtual void ProcessEventL()=0; + virtual void HandleAddedToQueue(); + virtual void HandleLastOnQueue(); + virtual void HandleSessionRemoval(const TThreadId& aClientThreadId); +private: + TType iType; + CVwsEventQueue& iQueue; + }; + + +#endif