1 /*

     2 * Copyright (c) 2009-2010 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html."

     8 * Initial Contributors:

     9 * Nokia Corporation - initial contribution.

    10 * Contributors:

    11 *

    12 * Description:

    13 * MSRP Implementation

    14 *

    15 */

    16 

    17 #ifndef CMSRPCONNECTION_H

    18 #define CMSRPCONNECTION_H

    19 

    20 // INCLUDES

    21 

    22 #include "MMSRPConnector.h"

    23 #include "MMSRPConnection.h"

    24 #include "MMSRPReader.h"

    25 #include "MMSRPReaderObserver.h"

    26 #include "MMSRPParser.h"

    27 #include "MMSRPWriter.h"

    28 #include "MMSRPConnectionObserver.h"

    29 #include "MMSRPTimeOutObserver.h"

    30 #include "CMSRPTimeOutTimer.h"

    31 

    32 // FORWARD DECLARATIONS

    33 class CMSRPMessageHandler;

    34 class MMSRPConnection;

    35 class MMSRPConnectionObserver;

    36 class MMSRPReaderObserver;

    37 class MMSRPWriterObserver;

    38 class MMSRPReader;

    39 class MMSRPConnectionManager;

    40 

    41 // CLASS DECLARATION

    42 

    43 /**

    44 *  MSRP Connection Manager

    45 */

    46 class CMSRPConnection : public CBase, public MMSRPConnection, public MMSRPConnectorObserver, 

    47 							 public MMSRPReaderObserver, public MMSRPParserObserver, 

    48 							 public MMSRPWriterErrorObserver, public MMSRPTimeOutObserver

    49     {

    50 	public:

    51 

    52 	    // Constructors and destructor

    53 	    

    54 	    static MMSRPConnection* NewL( TInetAddr& aRemoteAddr, MMSRPConnectionManager& aConnMngr);

    55 	    

    56         virtual ~CMSRPConnection();

    57 

    58     public: // Functions from base classes

    59 

    60 		// From MMSRPConnection

    61         virtual TBool CheckConnection(TInetAddr& aRemoteAddr, TBool aOnlyListen);

    62            

    63         virtual TInt ConnectL(MMSRPConnectionObserver& aSubsession);

    64         

    65         virtual TInt ListenL(MMSRPConnectionObserver& aSubsession);

    66 

    67         virtual void ReleaseConnection(MMSRPConnectionObserver& aSubsession);

    68                                     

    69         virtual void SendL( MMSRPWriterObserver& aMsg /*, MMSRPConnectionObserver& aSubsession*/  );

    70                                                              

    71         virtual void ConnectionEstablishedL( TInt aNewState, RSocket* aSocket, TInt aStatus );

    72 

    73 		virtual TInt getConnectionState();

    74         

    75         //from MMSRPConnectorObserver 

    76         

    77         //virtual void ConnectionEstablishedL( TInt aNewState, RSocket* aDataSocket, TInt aStatus );

    78         

    79         //from MMSRPReaderObserver

    80 

    81         virtual void ReadStatusL(RMsrpBuf& aBuf, TInt aStatus);

    82         

    83         //from MMSRPParserObserver

    84         virtual void ParseStatusL (CMSRPMessageHandler* aMsg, TInt aStatus);

    85                                         

    86         //from MMSRPWriterErrorObserver

    87         virtual void WriteSocketError(TInt aError);

    88         

    89         //from timeout

    90         void TimerExpiredL();

    91         

    92 

    93 	private: // constructor

    94 

    95         CMSRPConnection(TInetAddr& aRemoteAddr, MMSRPConnectionManager& aConnMngr );

    96 

    97         void ConstructL( );

    98         

    99         void Remove(MMSRPConnectionObserver* aSubsession);

   100         

   101         void NotifyAllL(TInt aNewState, TInt aStatus );

   102         

   103         void CloseConnection( );

   104 

   105 

   106 	private: // data

   107 		

   108 		TInetAddr iHostAddress;

   109 		

   110 		MMSRPConnectionManager& iConnMngr;

   111 		

   112 		TInt iConnectionState;

   113 		

   114 		RPointerArray<MMSRPConnectionObserver> iSubsessions;

   115 		

   116 		MMSRPConnector* iConnector; 

   117 		

   118 		MMSRPReader* iReader;

   119 		

   120 		MMSRPParser* iParser;

   121 		

   122 		MMSRPWriter* iWriter;

   123 		

   124 		CMSRPBufPool iBufPool;

   125 										

   126 		RSocket* iSocket;

   127 		

   128 		CMSRPTimeOutTimer*  iListenTimer;

   129 

   130     };

   131 

   132 #endif      // CMSRPCONNECTION_H

   133 

   134 // End of File