--- /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