--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Msrp/MsrpClient/src/RMSRPSession.cpp	Sat Jun 12 14:30:11 2010 +0530
@@ -0,0 +1,226 @@
+/*
+* 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 RMSRPSESSION_CPP_
+#define RMSRPSESSION_CPP_
+
+
+//  Include Files
+#include "MsrpCommon.h"
+#include "RMSRPSession.h"
+#include "RMSRP.h"
+
+
+//  Member Functions
+
+RMSRPSession::RMSRPSession() :
+    RSubSessionBase()
+    {
+    MSRPLOG("RMSRP Session.. Ctor");
+    }
+
+
+TInt RMSRPSession::CreateServerSubSession( RMSRP& aRMSRP, const TUint32 aIapId )
+    {
+    MSRPLOG("RMSRP Session.. Create client-server SubSession");
+    
+    return CreateSubSession( aRMSRP, EMSRPCreateSubSession, TIpcArgs( aIapId ) );
+    }
+
+
+void RMSRPSession::CloseServerSubSession( )
+    {
+    MSRPLOG("RMSRP Session.. Close client-server SubSession");
+    CloseSubSession(EMSRPCloseSubSession);
+    }
+
+
+void RMSRPSession::GetLocalPathL( TDes8 &aLocalHost, TDes8 &aSessionID )
+    {
+    MSRPLOG("RMSRP Session.. GetLocalPath");
+    
+    User::LeaveIfError( SendReceive(EMSRPLocalPath, TIpcArgs( &iLocalPathMSRPDataPckg )) );
+    
+    aLocalHost = iLocalPathMSRPDataPckg().iLocalHost;
+    aSessionID = iLocalPathMSRPDataPckg().iSessionID;    
+    }
+
+
+void RMSRPSession::Connect( const TDesC8& aRemoteHost,
+                            const TUint aRemotePort,
+                            const TDesC8& aRemoteSessionID,
+                            TRequestStatus& aStatus )
+    {
+    MSRPLOG("RMSRP Session.. Connect");
+    
+    iConnectMSRPDataPckg().iRemoteHost = aRemoteHost;
+    iConnectMSRPDataPckg().iRemotePort = aRemotePort;
+    iConnectMSRPDataPckg().iRemoteSessionID = aRemoteSessionID;
+    
+    SendReceive( EMSRPConnect, TIpcArgs( &iConnectMSRPDataPckg ), aStatus );    
+    }
+
+
+void RMSRPSession::ListenConnections( const TDesC8& aRemoteHost,
+                                      const TUint aRemotePort,
+                                      const TDesC8& aRemoteSessionID,
+                                      TBool aIsMessage,
+                                      TRequestStatus& aStatus )
+    {
+    MSRPLOG("RMSRP Session.. Listen for incoming connections");
+    
+    iListenMSRPDataPckg().iRemoteHost = aRemoteHost;
+    iListenMSRPDataPckg().iRemotePort = aRemotePort;
+    iListenMSRPDataPckg().iRemoteSessionID = aRemoteSessionID;
+    iListenMSRPDataPckg().iIsMessage = aIsMessage;
+        
+    SendReceive( EMSRPListenConnections, TIpcArgs( &iListenMSRPDataPckg ), aStatus );    
+    }
+
+
+void RMSRPSession::ListenMessages( TBool aIsMessage,
+                                   TRequestStatus& aStatus )
+    {
+    MSRPLOG("RMSRP Session.. Listen for incoming messages");
+    
+    iListenMSRPDataPckg().iIsMessage = aIsMessage;
+    
+    SendReceive( EMSRPListenMessages, TIpcArgs( &iListenMSRPDataPckg ), aStatus );    
+    }
+
+
+void RMSRPSession::ListenSendResult( const TDesC8& aSessionID, TRequestStatus& aStatus )
+    {
+    MSRPLOG("RMSRP Session.. ListenSendResult");
+    
+    iSendResultListenMSRPDataPckg().iSessionID = aSessionID;
+    
+    SendReceive( EMSRPListenSendResult, TIpcArgs( &iSendResultListenMSRPDataPckg ), aStatus );    
+    }
+
+
+TInt RMSRPSession::SendMessage( TDesC8& aMessageBuffer )
+    {
+    MSRPLOG("RMSRP Session.. SendMessage");
+    
+    iSendMSRPDataPckg().iExtMessageBuffer = aMessageBuffer;
+
+    return SendReceive( EMSRPSendMessage, TIpcArgs( &iSendMSRPDataPckg ) );
+    }
+
+
+TInt RMSRPSession::CancelSending( TDesC8& aMessageId )
+    {
+    MSRPLOG("RMSRP Session.. CancelSending");
+    return SendReceive( EMSRPCancelSending, TIpcArgs( &aMessageId ) );
+    }
+
+
+void RMSRPSession::CancelReceiving( )
+    {
+    MSRPLOG("RMSRP Session.. CancelReceiving Entered");
+    SendReceive( EMSRPCancelReceiving );
+    MSRPLOG("RMSRP Session.. CancelReceiving Done ");
+    }
+    
+
+void RMSRPSession::CancelSendResultListening( )
+    {
+    MSRPLOG("RMSRP Session.. CancelSendRespListening");
+    SendReceive( EMSRPCancelSendRespListening );
+    }
+
+
+const TDesC8& RMSRPSession::GetMessageIdOfSentMessage() const
+    {
+    MSRPLOG("RMSRP Session.. GetMessageIdOfSentMessage");
+    return iSendResultListenMSRPDataPckg().iMessageId;
+    }
+    
+
+TInt RMSRPSession::GetStatusOfSentMessage() const
+    {
+    MSRPLOG("RMSRP Session.. GetStatusOfSentMessage");
+    return iSendResultListenMSRPDataPckg().iStatus;
+    }
+    
+
+TInt RMSRPSession::GetStatusOfReceivedMessage() const
+    {
+    MSRPLOG("RMSRP Session.. GetStatusOfReceivedMessage");
+    return iListenMSRPDataPckg().iStatus;
+    }
+
+
+const TDesC8& RMSRPSession::GetReceivedMessage() const
+    {
+    MSRPLOG("RMSRP Session.. GetReceivedMessage");
+    return iListenMSRPDataPckg().iExtMessageBuffer;
+    }
+
+TBool RMSRPSession::GetListenProgress() const
+    {
+    MSRPLOG("RMSRP Session.. GetListenProgress");
+    return iListenMSRPDataPckg().iIsProgress;
+    }
+
+TInt RMSRPSession::GetBytesReceived() const
+    {
+    MSRPLOG("RMSRP Session.. GetBytesReceived");
+    return iListenMSRPDataPckg().iBytesRecvd;
+    }
+
+TInt RMSRPSession::GetTotalBytesReceived() const
+    {
+    MSRPLOG("RMSRP Session.. GetTotalBytesReceived");
+    return iListenMSRPDataPckg().iTotalBytes;
+    }
+
+TBool RMSRPSession::GetSendProgress() const
+    {
+    MSRPLOG("RMSRP Session.. GetSendProgress");
+    return iSendResultListenMSRPDataPckg().iIsProgress;
+    }
+
+TInt RMSRPSession::GetBytesSent() const
+    {
+    MSRPLOG("RMSRP Session.. GetBytesSent");
+    return iSendResultListenMSRPDataPckg().iBytesSent;
+    }
+
+TInt RMSRPSession::GetTotalBytes() const
+    {
+    MSRPLOG("RMSRP Session.. GetTotalBytes");
+    return iSendResultListenMSRPDataPckg().iTotalBytes;
+    }
+
+
+TInt RMSRPSession::SendFileL(TDesC8& aFileParamBuffer)
+    {
+    /* Send File Params to the sub-session */
+    MSRPLOG("RMSRP Session.. SendFileParams");
+    iSendMSRPDataPckg().iExtMessageBuffer = aFileParamBuffer;
+    return SendReceive( EMSRPSendFile, TIpcArgs( &iSendMSRPDataPckg ) );
+    }
+
+TInt RMSRPSession::ReceiveFileL(TDesC8& aFileParamBuffer)
+    {
+    /* Send File Params to the sub-session */
+    MSRPLOG("RMSRP Session.. SendFileParams");
+    iSendMSRPDataPckg().iExtMessageBuffer = aFileParamBuffer;
+    return SendReceive( EMSRPReceiveFile, TIpcArgs( &iSendMSRPDataPckg ) );
+    }
+#endif /* RMSRPSESSION_CPP_ */