diff -r 000000000000 -r f5a58ecadc66 servicediscoveryandcontrol/pnp/test/upnp/Server/ControlPoint/inc/upnpctrlscpractivities.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/servicediscoveryandcontrol/pnp/test/upnp/Server/ControlPoint/inc/upnpctrlscpractivities.h	Tue Feb 02 01:12:20 2010 +0200
@@ -0,0 +1,329 @@
+// 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 __UPNPCONTROLSCPRACTIVITIES_H
+#define __UPNPCONTROLSCPRACTIVITIES_H
+
+#include <comms-infras/corescpractivities.h>
+#include <comms-infras/ss_nodemessages.h>
+#include <comms-infras/ss_corepractivities.h>
+#include <http/thttptable.h>
+
+#include "upnpctrlscpr.h"
+#include "upnp_cf_msgs.h"
+
+
+using namespace ESock;
+using namespace MeshMachine;
+
+namespace UPnPControlSCprActivities
+	{	
+	DECLARE_ACTIVITY_MAP ( activityMap )
+	}
+
+class CUPnPActivityBase : public CNodeParallelActivityBase
+	{
+protected:
+	CUPnPActivityBase ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
+		:CNodeParallelActivityBase ( aActivitySig, aNode, aActivitiesCount )	
+		{ }
+	
+	~CUPnPActivityBase ( ); 	
+ 	virtual TBool Next ( TNodeContextBase& aContext );
+ 
+ public:
+ 	TNodeId iFlowId;
+ 	CUPnPRequestParamSetBase* iRequestParamSet;
+ 
+ public:
+ 	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+ 	
+ 	//States
+	DECLARE_SMELEMENT_HEADER ( TStopCurrentActivities, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPActivityBase::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TStopCurrentActivities)    
+   
+	//TState Forks
+	DECLARE_SMELEMENT_HEADER ( TStopActivityOrStopDataClient, TStateFork<TContext>, NetStateMachine::MStateFork, CUPnPActivityBase::TContext )
+		virtual TInt TransitionTag ( );
+	DECLARE_SMELEMENT_FOOTER ( TStopActivityOrStopDataClient )	
+
+	//Transitions
+	DECLARE_SMELEMENT_HEADER ( TAwaitingResponseToStopActivities, TState<TContext>, NetStateMachine::MState, CUPnPActivityBase::TContext )
+		virtual TBool Accept ( );
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingResponseToStopActivities )
+
+    DECLARE_AGGREGATED_TRANSITION2(
+       TProcessClientLeave,
+       TRemoveClient,
+       CoreNetStates::TSendLeaveCompleteIfRequest
+	   )
+	};
+//---------------------------------------Control Point Search Request Activity-------------------------------------
+class CUPnPSearchActivity: public CUPnPActivityBase							 
+	{
+public:	    
+	static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUPnPSearchActivity ( );
+     
+private:
+	CUPnPSearchActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
+		:CUPnPActivityBase ( aActivitySig, aNode, aActivitiesCount )
+	  	{	  	
+	  	}		
+		
+public:
+ 	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+ 
+	//States
+	typedef TAwaitingMessageState<TUpnpMessage::TSearchRequest> TAwaitingSearchRequest;
+
+	DECLARE_SMELEMENT_HEADER ( TAwaitingReceiveSearchResponse, TState<TContext>, NetStateMachine::MState, CUPnPSearchActivity::TContext )
+	virtual TBool Accept ( );
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingReceiveSearchResponse )
+	
+	typedef TAwaiting2MessagesState<TUpnpMessage::TCancelled, TUpnpMessage::TUPnPSearchResponse> TAwaitingDataClientStopResponse;
+
+	//Transitions
+    DECLARE_SMELEMENT_HEADER ( TSendSearchRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TSendSearchRequest )    
+	
+	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TProcessResponse )    
+
+	DECLARE_SMELEMENT_HEADER ( TCleanupActivity, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
+    	virtual void DoL ( );    	
+	DECLARE_SMELEMENT_FOOTER ( TCleanupActivity)    
+
+	DECLARE_SMELEMENT_HEADER ( TCancelSearchRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPSearchActivity::TContext )
+    	virtual void DoL ( );
+	DECLARE_SMELEMENT_FOOTER ( TCancelSearchRequest )
+ 	};
+
+//---------------------------------------Control Point Register Notify Request Activity-------------------------------------
+class CUPnPRegisterNotifyActivity: public CUPnPActivityBase							 
+	{
+public:	    
+	static CNodeActivityBase* NewL ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUPnPRegisterNotifyActivity ( );
+     
+private:
+	CUPnPRegisterNotifyActivity ( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivitiesCount )
+		:CUPnPActivityBase ( aActivitySig, aNode, aActivitiesCount )
+	  	{	  	
+	  	}		
+		
+public:
+	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+ 
+	//States
+	typedef TAwaitingMessageState<TUpnpMessage::TRegisterNotifyRequest> TAwaitingRegisterNotifyRequest;
+
+	DECLARE_SMELEMENT_HEADER ( TAwaitingReceiveNotifivation, TState<TContext>, NetStateMachine::MState, CUPnPRegisterNotifyActivity::TContext )
+	virtual TBool Accept ( );
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingReceiveNotifivation )
+	
+	typedef TAwaitingMessageState<TCFDataClient::TStarted> TAwaitingServerStarted;
+	typedef TAwaiting2MessagesState<TUpnpMessage::TCancelled, TUpnpMessage::TUPnPSearchResponse> TAwaitingDataClientStopResponse;
+	
+	//Transitions        
+    DECLARE_SMELEMENT_HEADER ( TStartServer, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
+    	virtual void DoL ( );
+    DECLARE_SMELEMENT_FOOTER ( TStartServer )    
+
+	DECLARE_SMELEMENT_HEADER ( TSendRegisterRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TSendRegisterRequest )    
+
+	DECLARE_SMELEMENT_HEADER ( TProcessNotification, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TProcessNotification )    
+
+	DECLARE_SMELEMENT_HEADER ( TCancelRegisterRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
+    	virtual void DoL ( );    	
+    DECLARE_SMELEMENT_FOOTER ( TCancelRegisterRequest )    
+
+ 	DECLARE_SMELEMENT_HEADER ( TCleanupActivity, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUPnPRegisterNotifyActivity::TContext )
+    	virtual void DoL ( );    	
+	DECLARE_SMELEMENT_FOOTER ( TCleanupActivity )
+	};
+
+//---------------------------------------Control Point Describe Request Activity-------------------------------------
+class CUpnpDescribeActivity: public CUPnPActivityBase
+	{
+public:
+	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUpnpDescribeActivity();
+	
+private:
+	CUpnpDescribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
+		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
+		{ }
+		
+public:
+	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+ 
+ 	// States
+	typedef TAwaitingMessageState<TUpnpMessage::TDescribeRequest> TAwaitingDescribeRequest;
+	
+	DECLARE_SMELEMENT_HEADER( TAwaitingErrorOrResponseOrCancel, TState<TContext>, NetStateMachine::MState, CUpnpDescribeActivity::TContext )
+		TBool Accept();
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingErrorOrResponseOrCancel )
+
+	DECLARE_SMELEMENT_HEADER ( TAwaitingDataClientStopResponse, TState<TContext>, NetStateMachine::MState, CUPnPRegisterNotifyActivity::TContext )
+		virtual TBool Accept ( );
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingDataClientStopResponse )
+
+	// Transitions
+	DECLARE_SMELEMENT_HEADER ( TSendDescribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TSendDescribeRequest )
+
+	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
+		void DoL();
+		void Error( TInt aError );
+	DECLARE_SMELEMENT_FOOTER ( TProcessResponse )
+
+	DECLARE_SMELEMENT_HEADER ( TReportError, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TReportError )
+
+	DECLARE_SMELEMENT_HEADER ( TCleanupActivity, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TCleanupActivity )
+
+	DECLARE_SMELEMENT_HEADER ( TDataClientStop, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpDescribeActivity::TContext )
+    	virtual void DoL ( );    	
+	DECLARE_SMELEMENT_FOOTER ( TDataClientStop)    
+	};
+
+
+//---------------------------------------Control Point Subscribe Request Activity-------------------------------------
+class CUpnpSubscribeActivity: public CUPnPActivityBase
+	{
+public:
+	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUpnpSubscribeActivity();
+	
+private:
+	CUpnpSubscribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
+		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
+		{ }
+	
+public :
+	CSubscriptionInfo*  iSubscriptionInfo; // Not owned
+	
+public: // States	
+	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+ 
+	typedef TAwaitingMessageState<TUpnpMessage::TSubscribeRequest> TAwaitingSubscribeRequest;
+			
+	DECLARE_SMELEMENT_HEADER ( TAwaitingErrorOrResponseOrCancel, TState<TContext>, NetStateMachine::MState, CUpnpSubscribeActivity::TContext )
+		TBool Accept();
+	DECLARE_SMELEMENT_FOOTER ( TAwaitingErrorOrResponseOrCancel )
+
+public: // Transitions
+	DECLARE_SMELEMENT_HEADER ( TSendSubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TSendSubscribeRequest )
+
+	DECLARE_SMELEMENT_HEADER ( TProcessSubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
+		void DoL();
+		void Error( TInt aError );
+	DECLARE_SMELEMENT_FOOTER ( ProcessSubscribeResponse )
+
+	DECLARE_SMELEMENT_HEADER ( TReportError, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TReportError )
+	
+	DECLARE_SMELEMENT_HEADER ( TSendUnsubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TSendUnsubscribeRequest )
+	
+	DECLARE_SMELEMENT_HEADER ( TProcessUnsubscribeResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpSubscribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER ( TProcessUnsubscribeResponse )
+	};
+
+class CUpnpUnSubscribeActivity: public CUPnPActivityBase
+	{
+public:
+	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUpnpUnSubscribeActivity();
+		
+private:
+	CUpnpUnSubscribeActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount )
+		:CUPnPActivityBase ( aActivitySig, aNode, aActivityCount )
+		{ }
+	
+private:
+	CSubscriptionInfo*  iSubscriptionInfo; // Not Owned
+	
+public:
+	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+
+	// States
+	DECLARE_SMELEMENT_HEADER ( TAwaitingUnSubscribeRequest, TState<TContext>, NetStateMachine::MState, CUpnpUnSubscribeActivity::TContext )
+		TBool Accept();
+	DECLARE_SMELEMENT_FOOTER( TAwaitingUnSubscribeRequest )
+	
+	typedef TAwaiting2MessagesState<TEBase::TError, TUpnpMessage::TResponse> TAwaitingErrorOrResponse;
+
+public: // Transitions				
+	DECLARE_SMELEMENT_HEADER ( TSendUnSubscribeRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpUnSubscribeActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TSendUnSubscribeRequest )
+
+	DECLARE_SMELEMENT_HEADER ( TProcessResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpUnSubscribeActivity::TContext )
+		void DoL();		
+	DECLARE_SMELEMENT_FOOTER ( TProcessResponse )
+	};
+
+	
+class CUpnpNotificationActivity: public CNodeParallelActivityBase
+	{
+public:
+	static CNodeActivityBase* NewL( const TNodeActivity& aActivitySig, AMMNodeBase& aNode );
+	~CUpnpNotificationActivity();
+	
+private:
+	CUpnpNotificationActivity( const TNodeActivity& aActivitySig, AMMNodeBase& aNode, TUint aActivityCount );
+	
+private:
+	RBuf8	   iBodyBuf;
+	TPtrC8	   iPublisherUrl;
+	CTransaction* iTransaction;
+	TInt		iResponseStatus;
+	
+private: // Context
+	typedef TNodeContext<CUPnPControlSubConnectionProvider, CoreStates::TContext> TContext;
+
+public: 
+	// Transitions
+	DECLARE_SMELEMENT_HEADER ( TProcessNotifyRequest, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpNotificationActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TProcessNotifyRequest )
+
+	DECLARE_SMELEMENT_HEADER ( TSendResponse, TStateTransition<TContext>, NetStateMachine::MStateTransition, CUpnpNotificationActivity::TContext )
+		void DoL();
+	DECLARE_SMELEMENT_FOOTER( TSendResponse )	
+	};	
+ 
+#endif // UPNPCONTROLSCPRACTIVITIES_H