--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/datacommsserver/esockserver/inc/ss_connLegacy.h	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,223 @@
+// Copyright (c) 1997-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
+ @internalComponent
+*/
+
+#ifndef __SS_CONNLEGACY_H__
+#define __SS_CONNLEGACY_H__
+
+#include <e32def.h>
+#include <elements/factorynotify.h>
+#include <es_sock.h> //TNifProgressBuf & co
+#include <es_prot.h> //TConnStartType &co
+#include <ss_std.h>
+#include <comms-infras/ss_nodemessages_legacy.h>
+#include <comms-infras/ss_nodemessages_legacy_internal.h>
+#include <comms-infras/ss_legacyinterfaces.h>
+
+class TSockOpt;
+class CActivityTimer;
+
+const TInt KNifEMCompatibilityLayerEntireSubConnectionUid = 0;
+const TInt KNifEMCompatibilityLayerFakeSubConnectionId = 1;
+
+namespace ConnStates
+{
+class TProcessEnumResponse;
+class TNoTagOrCancelAllInterfaceWorker;
+class TCancelAllInterfaceNotificationWorker;
+}
+
+namespace AllInterfaceNotificationActivity
+{
+class TEnqueueNotification;
+}
+
+namespace EnumerateConnectionsActivity
+{
+class TQueryTierStatus;
+class TCacheConnectionInfo;
+class TCompleteClient;
+}
+
+namespace ESock
+{
+class ADataMonitoringProvider;
+class CSubConnection;
+class CConnManager;
+class CConnectionProviderBase;
+class CActivityTimer;
+class TSelectionPrefs;
+class TLegacyConnectionEnumRequest;
+class CLegacySubConnectionActiveResponder;
+
+/**
+Server side class representing an RConnection legacy API
+@internalComponent
+*/
+NONSHARABLE_CLASS(AConnectionLegacy)
+	{
+	friend class CConnection;
+	friend class CSockSession;
+	friend class Factories::TFactoryNotify<AConnectionLegacy>;
+	friend class CActivityTimer;
+	friend class ConnStates::TProcessEnumResponse;
+	friend class TLegacyConnectionEnumRequest;
+	friend class EnumerateConnectionsActivity::TQueryTierStatus;
+	friend class EnumerateConnectionsActivity::TCacheConnectionInfo;
+	friend class EnumerateConnectionsActivity::TCompleteClient;
+	friend class AllInterfaceNotificationActivity::TEnqueueNotification;
+	friend class ConnStates::TNoTagOrCancelAllInterfaceWorker;
+	friend class ConnStates::TCancelAllInterfaceNotificationWorker;
+
+public: //So that friends of CConnection (transitions) can access it
+	void CompleteAttachL(TSelectionPrefs& aPrefs);
+	void CancelServiceChangeNotification(const Den::RSafeMessage& aMessage);
+    void SubConnectionEvent(const TSubConnectionEvent& aSubConnectionEvent);
+
+protected:
+    AConnectionLegacy(CConnection& aConnection) :
+        iConnection(aConnection)
+            {
+            iServiceChangeNotificationPending = EFalse;
+            }
+
+    ~AConnectionLegacy();
+	TInt ProcessMessageL(const RMessage2& aMessage);
+	void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage); //Only called from CConnection::ReceivedL
+
+private:
+	// Underlying implementations of individual RConnection methods
+	void StopL(const RMessage2& aMessage);
+
+	void GetIntSettingL(const Den::RSafeMessage& aMessage);
+	void GetBoolSettingL(const Den::RSafeMessage& aMessage);
+	void GetDes8SettingL(const Den::RSafeMessage& aMessage);
+	void GetDes16SettingL(const Den::RSafeMessage& aMessage);
+	void GetLongDesSettingL(const Den::RSafeMessage& aMessage);
+	void GetConnectionInfoL(const RMessage2& aMessage);
+
+	void AllInterfaceNotificationL(const RMessage2& aMessage);
+	void CompleteAllInterfaceNotificationL(TInt aError);
+	void CancelAllInterfaceNotification();
+
+	void DataTransferredL(const Den::RSafeMessage& aMessage);
+	void DataSentNotificationRequestL(const Den::RSafeMessage& aMessage);
+	void DataSentNotificationCancel(const Den::RSafeMessage& aMessage);
+	void DataReceivedNotificationRequestL(const Den::RSafeMessage& aMessage);
+	void DataReceivedNotificationCancel(const Den::RSafeMessage& aMessage);
+	void DataMonitoringNotificationRequestL(const Den::RSafeMessage& aMessage, TDataMonitoringDirection aDirection);
+	void DataMonitoringNotificationCancel(const Den::RSafeMessage& aMessage, TDataMonitoringDirection aDirection);
+
+	void IsSubConnectionActiveRequestL(const Den::RSafeMessage& aMessage);
+	void IsSubConnectionActiveCancel(const Den::RSafeMessage& aMessage);
+
+	void ExtractEnumInfoL(RBuf8& aBuffer, TUint aCount, TInt aSize, TUint aIndex, TDes8& aPckg);
+	void EnumerateConnectionClientsL();
+	void GetConnectionClientInfoL();
+	void RequestDataPlaneEnumerationL(TLegacyConnEnumClients aClientType);
+	void EnumerateConnectionSocketsL();
+	void CompleteDataPlaneEnumeration(const Messages::TNodeId& aPeer, TInt aCount, HBufC8* aInfo, TInt aError);
+	void GetConnectionSocketInfoL();
+    void ServiceChangeNotification(TUint32 aId, const TDesC& aType);
+	void FinalCompleteAllBlockedMessages(TInt aResult);
+	void CancelProviderRequests();
+
+
+#ifndef AVAILABILITY_READY
+	void EnumerateConnectionsL(const RMessage2& aMessage);
+#endif
+
+	// SubConnection-oriented RConnection method support
+	void EnumerateSubConnectionsL(const Den::RSafeMessage& aMessage);
+	void GetSubConnectionInfoL(const Den::RSafeMessage& aMessage);
+
+	static TBool DoesConnectionInfoExist(const TDesC8& aInfoBuf, const TConnectionClientInfo& aInfo);
+protected:
+	ADataMonitoringProvider* FetchConnDataMonitoringProvider() const;
+	ADataMonitoringProvider* FetchSubConnDataMonitoringProvider() const;
+
+	//global notifications
+	void InterfaceStateChangeNotification(TDesC8& aInfo);
+	void RequestServiceChangeNotificationL(const Den::RSafeMessage& aMessage);
+    void ControlL(TUint aOptionName, TUint aMessageId);
+
+	// Underlying implementations of individual RConnection methods relating to subconnections
+    void AllSubConnectionNotificationL();
+    void CancelAllSubConnectionNotification();
+
+private:
+	RMessage2 iAllSubConnectionNotificationMessage;
+
+	TInterfaceChangeQueue iInterfaceChangeQueue;	// queue of interface notifications received
+
+	TUint iConnectionInfoCount;
+	TUint iConnectionClientCount;
+	RBuf8 iConnectionClientBuf;
+	TUint iConnectionSocketCount;
+	RBuf8 iConnectionSocketBuf;
+	Den::RSafeMessage iEnumConnMsg;	//< During a Data plane enum holds blocked client msg
+	TUint* iDPEnumCount;					//< During a Data plane enum points to count recipient
+	RBuf8* iDPEnumBuf;				//< During a Data plane enum points to data buf
+	RArray<Messages::TNodeId> iEnumConnSockCandidateSCPRs;	//< During a Data plane enum is list of SCPRs for connection
+
+    RMessage2* iMessage; //current message valid only within ProcessMessageL call
+    CConnection& iConnection;
+
+	RPointerArray<CSubConnection> iSubConnections; //client classes servicing sub-connection
+	                //related functionality requested via legacy RConnection API. sub-connections
+	                //objects are owned by AConnectionLegacy instance and don't have RSubConnection
+	                //client side.
+	CConnManager* iConnManager; //client class servicing connection manager
+	                //related functionality requested via legacy RConnection API. CConnManager
+	                //object is owned by AConnectionLegacy instance and does't have RConnManager
+	                //client side.
+	// Flags for pending RConnection requests
+	TBool iServiceChangeNotificationPending;
+
+	// IsSubConnectionActive support
+	ADataMonitoringProvider* iConnActivityDataMonProv;
+	ESock::CActivityTimer* iActivityTimer;
+	TBool iClientsSubConnectionActiveState;
+	TUint iInitialSentDataVolume;
+	TUint iInitialReceivedDataVolume;
+	TUint iRequestedClientActivityTimerPeriod;
+	TBool iOutstandingIsSubConnectionActiveRequest;
+	RMessage2 iOutstandingIsSubConnectionActiveMessage;
+
+	TBool iDeferredSubConnectionNotificationEnable;
+	TSubConnectionEventQueue iSubConnectionEventQueue; // queue of subconnection events received
+
+	// EnumerateConnection and GetConnectionInfo use this.
+	RPointerArray<TSourcedConnectionInfo> iConnectionInfoPtrArray;
+
+	// AllInterfaceNotification support
+	RMessage2 iAllInterfaceNotificationMessage;
+	TInterfaceChangeQueue iNotificationQueue;
+  	Messages::TNodeId iAllInterfaceNotificationWorker;
+  	
+protected:
+	static const TAnyFn iInterfaceVTableF[];
+	};
+
+
+} //namespace ESock
+
+#endif
+// __SS_CONNLEGACY_H__
+