// 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 <e32std.h>
#include <e32base.h>

#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