--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Msrp/MsrpServer/inc/TStates.h	Sat Jun 12 14:30:11 2010 +0530
@@ -0,0 +1,159 @@
+/*
+* Copyright (c) 2009-2010 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:
+* MSRP Implementation
+*
+*/
+
+#ifndef TSTATES_H_
+#define TSTATES_H_
+
+#include "MSRPServerCommon.h"
+
+class TStateBase;
+class CMSRPServerSubSession;
+class CMSRPMessageHandler;
+
+enum TStates
+{
+    EIdle = 0,
+    EConnecting,    
+    EWaitForClient,    
+    EActive,
+    EActiveSend,
+    EFileShare,
+	EError,
+    EEndLine
+};
+
+
+class TStateBase
+{ 
+public:
+    virtual TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext)=0;
+    virtual TStateBase* HandleStateErrorL(CMSRPServerSubSession *aContext);
+    virtual TStateBase * processIncommingMessageL(CMSRPServerSubSession *aContext, CMSRPMessageHandler* incommingMsg = NULL);
+    TStateBase * processPendingMessageQL( CMSRPServerSubSession *aContext );
+    virtual TStateBase * handlesResponseL(CMSRPServerSubSession *aContext,
+                    CMSRPMessageHandler *incommingMsgHandler);
+
+    virtual TStateBase* handleRequestsL(CMSRPServerSubSession *aContext,
+                    CMSRPMessageHandler *incommingMsgHandler);
+    
+    TStateBase* handleClientListnerCancelL(CMSRPServerSubSession * aContext, 
+                                        TMSRPFSMEvent aEvent);
+    TStateBase* handleConnectionStateChangedL(CMSRPServerSubSession *aContext);
+    TStateBase* handleQueuesL(CMSRPServerSubSession *aContext);
+	TStateBase* handleConnectionErrorsL(CMSRPServerSubSession *aContext);
+    virtual TStates identity()=0;
+    TStateBase* handleInCommingMessagesL(CMSRPServerSubSession *aContext);
+    TStateBase* handleSendFileL(CMSRPServerSubSession *aContext);
+    TStateBase* handleReceiveFileL(CMSRPServerSubSession *aContext);
+};
+
+
+class TStateIdle : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();
+    
+private:    
+    TStateBase* handleLocalMSRPPathRequestL( CMSRPServerSubSession *aContext);
+    TStateBase* handleConnectRequestL(CMSRPServerSubSession *aContext);
+    TStateBase* handleListenRequestL(CMSRPServerSubSession *aContext);
+
+    TBool initializeConnectionL(CMSRPServerSubSession *aContext);    
+    
+};
+
+
+class TStateConnecting : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();    
+
+};
+
+
+class TStateWaitForClient : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();
+    
+private:
+    TStateBase* fileSendCompleteL(CMSRPServerSubSession *aContext);
+    TStateBase * handleResponseSentL( CMSRPServerSubSession *aContext);
+    
+};
+
+
+class TStateActive : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();
+
+private:
+    TStateBase* handleSendDataL(CMSRPServerSubSession *aContext);
+    
+};
+
+
+class TStateFileShare : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();
+
+private:
+    TStateBase * processIncommingMessageL(CMSRPServerSubSession *aContext, CMSRPMessageHandler* incommingMsg = NULL);
+    
+    TStateBase* fileSendCompleteL(CMSRPServerSubSession *aContext);
+    TStateBase * handlesResponseL(CMSRPServerSubSession *aContext,
+                          CMSRPMessageHandler *incommingMsgHandler);
+    
+    TStateBase* handleRequestsL(CMSRPServerSubSession *aContext,
+                    CMSRPMessageHandler *incommingMsgHandler);
+    TStateBase * handleResponseSentL( CMSRPServerSubSession *aContext);
+    
+    TStateBase * handleSendProgressL( CMSRPServerSubSession *aContext);
+    
+    TStateBase * handleReceiveProgressL( CMSRPServerSubSession *aContext);
+    
+};
+
+
+class TStateActiveSend : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();
+    
+private:    
+    TStateBase * MessageSendCompleteL(CMSRPServerSubSession *aContext); 
+    
+};
+
+
+class TStateError : public TStateBase
+{
+public:
+    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);
+    TStates identity();    
+
+};
+
+
+#endif /* TSTATES_HPP_ */