/*
* 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 CMSRPCONNECTION_H
#define CMSRPCONNECTION_H

// INCLUDES

#include "MMSRPConnector.h"
#include "MMSRPConnection.h"
#include "MMSRPReader.h"
#include "MMSRPReaderObserver.h"
#include "MMSRPParser.h"
#include "MMSRPWriter.h"
#include "MMSRPConnectionObserver.h"
#include "MMSRPTimeOutObserver.h"
#include "CMSRPTimeOutTimer.h"

// FORWARD DECLARATIONS
class CMSRPMessageHandler;
class MMSRPConnection;
class MMSRPConnectionObserver;
class MMSRPReaderObserver;
class MMSRPWriterObserver;
class MMSRPReader;
class MMSRPConnectionManager;

// CLASS DECLARATION

/**
*  MSRP Connection Manager
*/
class CMSRPConnection : public CBase, public MMSRPConnection, public MMSRPConnectorObserver, 
							 public MMSRPReaderObserver, public MMSRPParserObserver, 
							 public MMSRPWriterErrorObserver, public MMSRPTimeOutObserver
    {
	public:

	    // Constructors and destructor
	    
	    static MMSRPConnection* NewL( TInetAddr& aRemoteAddr, MMSRPConnectionManager& aConnMngr);
	    
        virtual ~CMSRPConnection();

    public: // Functions from base classes

		// From MMSRPConnection
        virtual TBool CheckConnection(TInetAddr& aRemoteAddr, TBool aOnlyListen);
           
        virtual TInt ConnectL(MMSRPConnectionObserver& aSubsession);
        
        virtual TInt ListenL(MMSRPConnectionObserver& aSubsession);

        virtual void ReleaseConnection(MMSRPConnectionObserver& aSubsession);
                                    
        void SendL( MMSRPWriterObserver& aMsg );
   
        void ContinueSendingL( MMSRPWriterObserver& aMsg );
   
        void CancelSendingL( const MMSRPWriterObserver* aMsg );
   
        virtual void ConnectionEstablishedL( TInt aNewState, RSocket* aSocket, TInt aStatus );

		virtual TInt getConnectionState();
        
        //from MMSRPConnectorObserver 
        
        //virtual void ConnectionEstablishedL( TInt aNewState, RSocket* aDataSocket, TInt aStatus );
        
	public: //from MMSRPReaderObserver

        virtual void ReadStatusL(RMsrpBuf& aBuf, TInt aStatus);
        
   public: //from MMSRPParserObserver
        TInt ParseStatusL ( CMSRPMessageHandler* aMsg, TInt aStatus );
        void ReportReceiveprogressL(  CMSRPMessageHandler* aMsg ); 
                                        
        //from MMSRPWriterErrorObserver
        virtual void WriteSocketError(TInt aError);
        
        //from timeout
        void TimerExpiredL();
        

	private: // constructor

        CMSRPConnection(TInetAddr& aRemoteAddr, MMSRPConnectionManager& aConnMngr );

        void ConstructL( );
        
        void Remove(MMSRPConnectionObserver* aSubsession);
        
        void NotifyAllL(TInt aNewState, TInt aStatus );
        
        void CloseConnection( );


	private: // data
		
		TInetAddr iHostAddress;
		
		MMSRPConnectionManager& iConnMngr;
		
		TInt iConnectionState;
		
		RPointerArray<MMSRPConnectionObserver> iSubsessions;
		
		MMSRPConnector* iConnector; 
		
		MMSRPReader* iReader;
		
		MMSRPParser* iParser;
		
		MMSRPWriter* iWriter;
		
		CMSRPBufPool iBufPool;
										
		RSocket* iSocket;
		
		CMSRPTimeOutTimer*  iListenTimer;

    };

#endif      // CMSRPCONNECTION_H

// End of File