diff -r 000000000000 -r f5a58ecadc66 servicediscoveryandcontrol/pnp/test/upnp/Server/ServicePoint/inc/upnpservicescpractivities.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Server/ServicePoint/inc/upnpservicescpractivities.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,242 @@
+// Copyright (c) 2008-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 __UPNPSERVICESCPRACTIVITIES_H
+#define __UPNPSERVICESCPRACTIVITIES_H
+
+// System Include
+#include <comms-infras/corescpractivities.h>
+
+// User Include
+#include "upnpservicescpr.h"
+
+using namespace ESock;
+using namespace MeshMachine;
+
+namespace UPnPServiceSCprActivities
+	{
+	DECLARE_ACTIVITY_MAP(activityMap)
+	
+		
+	//-------------------New Service Registration using SCRP----------------------------
+	class CUpnpServiceRegistrationActivity: public CNodeActivityBase
+		{
+	public:
+		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+		~CUpnpServiceRegistrationActivity ( );
+				
+	private:
+		CUpnpServiceRegistrationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );			
+		
+		void GenerateServiceIdL ( CStringPoolManager& aStringPoolMgr, const TDesC8& aUri, RBuf8& aServiceId );
+		void CreateRelativeUrlL ( const TDesC8& aServiceId, const TDesC8& aUri, RBuf8& aResultUrl );
+		
+	private:
+		CUPnPServiceRegisterParamSet*	iParamSet;
+		CUPnPServiceInfo*				iServiceInfo; // Dont delete ownership will be passed to CPR		
+		
+	public:			
+		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
+	
+		// States
+		typedef TAwaitingMessageState<TUpnpMessage::TServiceRegistration> TAwaitingServiceRegistration;
+				
+		
+		//Transitions
+		DECLARE_SMELEMENT_HEADER ( TRequestServiceJoin, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TRequestServiceJoin )
+		
+		DECLARE_SMELEMENT_HEADER ( TBuildPublishAndServiceInfo, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TBuildPublishAndServiceInfo )
+		
+		DECLARE_SMELEMENT_HEADER ( TRegisterServiceInfoWithCPR, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TRegisterServiceInfoWithCPR )
+		
+		DECLARE_SMELEMENT_HEADER ( TSendPublishRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TSendPublishRequest )
+		
+		DECLARE_SMELEMENT_HEADER ( TRegisterSsdpInfoWithServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TRegisterSsdpInfoWithServer )
+				
+		DECLARE_SMELEMENT_HEADER ( TInitiateTcpFlowCreation, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TInitiateTcpFlowCreation )
+				
+		};
+			
+	
+	//-------------------New Device Registration using SCRP----------------------------
+	class CUpnpDeviceRegistrationActivity: public CNodeActivityBase			
+		{
+	public:
+		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+		~CUpnpDeviceRegistrationActivity ( );
+				
+	private:
+		CUpnpDeviceRegistrationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );		
+
+	private:
+		CUPnPDeviceRegisterParamSet *iParamSet;
+		CUPnPDevice*				iDeviceInfo; // Dont delete ownership will be passed to CPR
+		RBuf8						iIconUrl;
+		TInt						iIconUrlIdx;
+	public:
+		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
+	
+		// States 		
+		typedef TAwaitingMessageState<TUpnpMessage::TDeviceRegistration> TAwaitingDeviceRegistration;
+		
+		// Transitions
+		DECLARE_SMELEMENT_HEADER ( TRequestDeviceJoin, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TRequestDeviceJoin )
+		
+		DECLARE_SMELEMENT_HEADER ( TBuildPublishAndDeviceInfo, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TBuildPublishAndDeviceInfo )
+		
+		DECLARE_SMELEMENT_HEADER ( TRegisterDeviceInfoWithCPR, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TRegisterDeviceInfoWithCPR )
+		
+		DECLARE_SMELEMENT_HEADER ( TSendPublishRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TSendPublishRequest )
+		
+		DECLARE_SMELEMENT_HEADER ( TRegisterSsdpInfoWithServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+			void RegisterForMSearchL ( const TDesC8& aSearchTarget );
+		DECLARE_SMELEMENT_FOOTER ( TRegisterSsdpInfoWithServer )	
+		
+		DECLARE_SMELEMENT_HEADER ( TCreateIconFlow, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ();
+		DECLARE_SMELEMENT_FOOTER ( TCreateIconFlow )
+				
+		// StateForks
+		DECLARE_SMELEMENT_HEADER ( TIconCreateOrNoTag, TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
+			TInt TransitionTag ();
+		DECLARE_SMELEMENT_FOOTER ( TIconCreateOrNoTag )
+		
+		DECLARE_SMELEMENT_HEADER ( TIconOrNoTag, TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
+			TInt TransitionTag ();
+		DECLARE_SMELEMENT_FOOTER ( TIconOrNoTag )
+		};
+							
+	
+	//-------------------TCP ( Get/Subscribe/UnSubscribe ) Response Activity----------------------------
+	class CUpnpSPRequestInfoActivity: public CNodeActivityBase
+		{
+	public:
+		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+		
+		~CUpnpSPRequestInfoActivity ( );
+			
+	private:
+		CUpnpSPRequestInfoActivity::CUpnpSPRequestInfoActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode )
+		: CNodeActivityBase ( aActivitySig, aNode )
+		{  }
+				
+		TInt HandleSubscribeRequestL ( CRequest& aRequest, TSubsribeResponseInfo& aSubscribeResponse, CUPnPPublishInfoElement& aPublishInfo );
+		void ProcessCallBackUrlL ( const TDesC8& aUrl, CUPnPSubscribeInfoElement* aSubscribeElement );
+		
+		TInt HandleResubscribeRequestL ( CRequest& aRequest, TSubsribeResponseInfo& aSubscribeResponse, CUPnPPublishInfoElement& aPublishInfo );			
+		TInt GetHeaderValue ( CRequest& aRequest, TInt aFieldIndex, THTTPHdrVal& aFieldVal, const TStringTable& aTable );
+			
+	private: // Context
+		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;								
+
+	public: // Transitions
+		
+		DECLARE_SMELEMENT_HEADER ( TSendDescribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TSendDescribeResponse )
+
+		DECLARE_SMELEMENT_HEADER ( TSendSubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+			TBool IsFirstSubscription ( );		
+		DECLARE_SMELEMENT_FOOTER ( TSendSubscribeResponse )
+		
+		DECLARE_SMELEMENT_HEADER ( TSendUnsubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
+			void DoL ( );
+			TBool IsLastSubscription ( );		
+		DECLARE_SMELEMENT_FOOTER ( TSendUnsubscribeResponse )				
+		};
+		
+		
+	class CNotifyFlowFinder: public CNodeParallelActivityBase
+		{
+	public:
+		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+		~CNotifyFlowFinder ( );
+		
+	private:
+		CNotifyFlowFinder ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
+		
+	private:
+		CUPnPSubscribeInfoElement*	iSubscribeInfo; // don't delete, not owned
+	
+		// Context
+		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
+	
+	public:
+		// States
+		typedef TAwaitingMessageState<TUpnpMessage::TCreateNotifyFlow> TAwaitingFlowCreationRequest;
+	
+		// Transitions
+		DECLARE_SMELEMENT_HEADER ( TFindOrCreateFlow, TStateTransition<TContext>, NetStateMachine::MStateTransition, CNotifyFlowFinder::TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TFindOrCreateFlow )
+	
+		DECLARE_SMELEMENT_HEADER ( TProcessDataClient, TStateTransition<TContext>, NetStateMachine::MStateTransition, CNotifyFlowFinder::TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TProcessDataClient )
+		};
+		
+		
+	class CUpnpEventNotificationActivity: public CNodeParallelActivityBase
+		{
+	public:
+		static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+		~CUpnpEventNotificationActivity ( ) 
+		{ }
+		
+	private:
+		CUpnpEventNotificationActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
+		
+	private:		
+		// Context
+		typedef TNodeContext<CUPnPServiceSubConnectionProvider, CoreStates::TContext> TContext;
+		
+	public: 
+		// States
+		typedef TAwaitingMessageState<TUpnpMessage::TNotifyRequest> TAwaitingNotifyRequest;
+		typedef TAwaiting2MessagesState<TEBase::TError, TUpnpMessage::TResponse> TAwaitingErrorOrResponse;
+			
+		// Transitions		
+		DECLARE_SMELEMENT_HEADER ( TSendRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpEventNotificationActivity::TContext )
+			void DoL ( );
+		DECLARE_SMELEMENT_FOOTER ( TSendRequest )			
+		};	
+	}
+
+#endif // UPNPSERVICESCPRACTIVITIES_H