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

//

/**

 @file

 @internalTechnology

*/

#ifndef SYMBIAN_SS_CONNECTIONSESSION_H

#define SYMBIAN_SS_CONNECTIONSESSION_H

#include <comms-infras/ss_metaconnprov.h>

#include <comms-infras/ss_connselect.h>

#include <comms-infras/ss_common.h>

#include <elements/sd_std.h>

#include <comms-infras/es_availability.h>

#include <es_prot.h>

#include <comms-infras/es_connectionservparameterbundle.h>

namespace ESock

{

const TUint KMaxNotificationQueueLength = 8; // seems to be a popular value round these parts

const TUint ETierStatusActivity = 1;

const TUint ETierNotificationActivity = 2;

/**

Server side representation of RConnectionServ.

@class CConnectionSession

@internalTechnology

*/

NONSHARABLE_CLASS(CConnectionSession) : public Den::CWorkerSession, public MProvdSecurityChecker, public Messages::ASimpleNodeIdBase

	{

public:

	static CConnectionSession* NewL(TProcessId aProcessId, TUidType aUid, Den::TSessionUniqueId aSessionUniqueId);

	virtual ~CConnectionSession();

protected:

	CConnectionSession(TUidType aUid, Den::TSessionUniqueId aSessionUniqueId);

protected:

	void CompleteMessage(const RMessage2& aMessage, TInt aResult);

protected:

	void Error(TInt aError);

	virtual void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage);

	void ProviderUp(const Messages::TNodeId& aProvider);

private:

    // Client message implementations

	void StartAttachToTierManager(const RMessage2& aMessage);

	void EnumerateConnectionsL();

	void GetConnectionInfoL();

	// Availability

	void RegisterForAvailabilityL();

	void CancelAvailability(TInt aReason = KErrCancel);

	void ProcessAvailabilityL(Messages::TSignatureBase& aCFMessage);

	void ProcessError(TUint16 aActId, Messages::TSignatureBase& aCFMessage);

	void ProcessError(TUint16 aActId, TInt aErrCode);

	// Availability helpers

	void PopAvailabilityQueue();

	const Messages::TNodeId& ServiceProvider() const

	{

    	return iTierManager;

	}

	inline const Messages::TNodeId& ServiceProviderL() const

		{

		const Messages::TNodeId& sp = ServiceProvider();

		if(sp.IsNull())

			{

			// must be attached to something!

			//  log something here

			User::Leave(KErrNotReady);

			}

		return sp;

		}

	void LeaveServiceProvider();

    void HandleTierStatus(const Messages::TSignatureBase& aCFMessage);

    void HandleTierNotification(const Messages::TSignatureBase& aCFMessage);

	void AttachToTierManager(const Messages::TNodeId& aTierManager);

	virtual void CommsApiExtBindIfaceL(const RMessage2& aMessage);

	virtual void CommsApiExtIfaceSendReceiveL(const RMessage2& aMessage);

	virtual void CloseExtensionInterface(const RMessage2& aMessage);

	virtual void CancelAndCloseAllClientExtIfaces();

	void PanicClient(TESockPanic aPanic);

	static void PanicClient(const RMessage2& aMessage,TESockPanic aPanic);

	virtual void ServiceL(const RMessage2& aMessage);

public:

	// Methods implementing MProvdSecurityChecker methods

	virtual TInt CheckPolicy(const TSecurityPolicy& aPolicy, const char *aDiagnostic);

private:

	TUint iTierId;

	Messages::TNodeId iTierManager; // associated tier manager (if any)

	RMessage2 iAttachMessage;

	RMessage2 iStatusMessage;

	CRefCountOwnedParameterBundle* iStatusBundle;

	TBool iNotificationActive;

	RMessage2 iNotificationMessage;

	RPointerArray<CRefCountOwnedParameterBundle> iNotificationQueue; // queue of availability events received

	};

} // namespace ESock

#endif

//SYMBIAN_SS_CONNECTIONSESSION_H