// 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