--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/inc/ss_connectionsession.h	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,137 @@
+// 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
+