// Copyright (c) 2007-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:

// policycheckrequestqueue.h

// This file provides the interface for the policy check request

// queue and its associated elements.

// @internalComponent

// @prototype

// 

//

#ifndef NETUPS_PCR_QUEUE_H

#define NETUPS_PCR_QUEUE_H

#include <e32base.h>		// defines CBase, CActive

#include <e32std.h>			// defines TSglQueLink

#include "netupstypes.h"	

#include <comms-infras/commsdebugutility.h> // defines the comms debug logging utility

namespace NetUps

{

class CSubSession;

class MPolicyCheckRequestOriginator;

NONSHARABLE_CLASS (CPolicyCheckRequestData) : public CBase

	{

public:

	static CPolicyCheckRequestData* NewL(const TPolicyCheckRequestData& PolicyCheckRequestData);

	~CPolicyCheckRequestData();	

private:	

	void ConstructL(const TDesC& 								aDestinationName,

					const TDesC& 								aAccessPointName);

	CPolicyCheckRequestData(const TPolicyCheckRequestData& aPolicyCheckRequestData) :

							iProcessId(aPolicyCheckRequestData.iProcessId),

							iThreadId(aPolicyCheckRequestData.iThreadId),

							iServiceId(aPolicyCheckRequestData.iServiceId),

							iPlatSecCheckResult(aPolicyCheckRequestData.iPlatSecCheckResult),

							iCommsId(aPolicyCheckRequestData.iCommsId),

							iPolicyCheckRequestOriginator(aPolicyCheckRequestData.iPolicyCheckRequestOriginator)

							{						

							}			

public:

	TProcessId 										iProcessId;

	TThreadId 										iThreadId;

	TInt32 			  								iServiceId;

	TBool 		   									iPlatSecCheckResult;

	RBuf											iDestinationName;

	RBuf 											iAccessPointName;

	Messages::TNodeId	 								iCommsId;

	MPolicyCheckRequestOriginator&					iPolicyCheckRequestOriginator;	

private:

	__FLOG_DECLARATION_MEMBER;

	};

NONSHARABLE_CLASS (CQueuedPolicyCheckRequest) : public CBase

	{

	friend class CPolicyCheckRequestQueue; // needs iLink

public:

	static CQueuedPolicyCheckRequest* NewL(const TPolicyCheckRequestData& aPolicyCheckRequestData, const TRequestId& aRequestId);

	~CQueuedPolicyCheckRequest();

	CPolicyCheckRequestData& PolicyCheckRequestData() { return *iPolicyCheckRequestData; }

	const TRequestId& RequestId();

private:

	void ConstructL(const TPolicyCheckRequestData& PolicyCheckRequestData);						

	CQueuedPolicyCheckRequest(const TRequestId& aRequestId);

private:

	TRequestId					iRequestId;

	CPolicyCheckRequestData* 	iPolicyCheckRequestData;

	TSglQueLink iLink;

	};

NONSHARABLE_CLASS (CPolicyCheckRequestQueue) : public CBase

	{

public:

	static CPolicyCheckRequestQueue* NewL(CSubSession&);

	~CPolicyCheckRequestQueue();

	TBool IsEmpty() const;

	CPolicyCheckRequestData& GetNextRequest();  // used by the subSession to get 1st entry on queue.

	void DeleteCurrentEntry();

	TBool OutStandingRequestToProcess();		// used by the subSession to get entries other than the 1st entry in order

												// to reply outstanding requests when entering a Session State

												// (other than 1st entry for which are reply has already been received from the UPS Server).

	CPolicyCheckRequestData& GetOutStandingRequestToProcess();

	void DeleteOutStandingRequest();

	void SendRequestL(const TPolicyCheckRequestData& aPolicyCheckRequestData, const TRequestId& aRequestId);

	TInt CancelRequest(const Messages::TNodeId& aCommsId, const TRequestId& aRequestId);

	void CancelAllRequests(TInt aError);

private:

	void ConstructL();

	void DoCancel();

	CPolicyCheckRequestQueue(CSubSession& aSubsession);

	void PostFirstRequestOnQueueToUpsServer();			

private:

	TSglQue<CQueuedPolicyCheckRequest> iRequestQueue;	

	CSubSession& iSubSession;

	__FLOG_DECLARATION_MEMBER;		

	};

} // end namespace NetUps

#endif // NETUPS_PCR_QUEUE_H