realtimenetprots/sipfw/SIP/ConnectionMgr/inc/CTcpListeningPoint.h
author hgs
Fri, 14 May 2010 14:57:35 +0300
changeset 22 f1578314b8da
parent 0 307788aac0a8
permissions -rw-r--r--
201019

/*
* Copyright (c) 2002-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:
* Name          : CTcpListeningPoint.h
* Part of       : ConnectionMgr
* Version       : SIP/4.0 
*
*/




/**
 @internalComponent
*/

#ifndef __CTCPLISTENINGPOINT_H__
#define __CTCPLISTENINGPOINT_H__

#include <in_sock.h>
#include <stringpool.h>
#include "MContext.h"
#include "CTransport.h"
#include "MServerTransportOwner.h"
#include "MListenerOwner.h"

class MTransactionFinder;
class MServerTaFactory;
class MTransportOwner;
class CTransErrorHandler;
class MTimerManager;
class CServerTransport;
class CListener;
class CSIPMessage;
class CSIPConnection;
class CSIPNATTraversalController;


class CTcpListeningPoint : public CTransport,
						   public MServerTransportOwner,
						   public MListenerOwner 
	{
public: // Constructors and destructor

	static CTcpListeningPoint* NewL( RSocketServ& aServer,
				MTransactionFinder& aFinder, 
				MServerTaFactory& aTaFactory,
				MTransportOwner& aTransportOwner,
				MTimerManager& aTimer,
				TUint aPort,
				TUint aTOne,
				CSIPServerResolver& aServerResolver,
				RConnection& aConnection,
				MSigCompController& aSigCompHandler,
				CNetworkInfo& aNetworkInfo,
				COwnerSettingsList& aSettingsList,
				const TSIPTransportParams& aTransportParams,
				CSIPNATTraversalController& aNATTraversal );

	static CTcpListeningPoint* NewLC( RSocketServ& aServer,
				MTransactionFinder& aFinder, 
				MServerTaFactory& aTaFactory,
				MTransportOwner& aTransportOwner,
				MTimerManager& aTimer,
				TUint aPort,
				TUint aTOne,
				CSIPServerResolver& aServerResolver,
				RConnection& aConnection,
				MSigCompController& aSigCompHandler,
				CNetworkInfo& aNetworkInfo,
				COwnerSettingsList& aSettingsList,
				const TSIPTransportParams& aTransportParams,
				CSIPNATTraversalController& aNATTraversal );

    ~CTcpListeningPoint();
				
public:	// From CTransport

	TBool Handle( TUint32 aTransportId );
	TBool HandleMessage( const TSIPTransportParams& aParams,
	                     RStringF aProtocol, 
	                     const TInetAddr& aRemoteAddr,
	                     TUint aLocalPort,
	                     TBool aIsStrict );
	TUint SourcePort(){ return iSourcePort; }
	void SendToNetL( const TSIPTransportParams& aParams,
	                 const TInetAddr& aAddress, 
	                 CSIPMessage& aMessage,
	                 TBool aForceUDP,
					 TUint aOrigTransport, 
					 TRequestStatus &aStatus );
	TBool CancelSend( TRequestStatus& aStatus );
	CTransportErrorHandler& ErrorHandler() { return *iErrorHandler; }
	void WaitL();
	TBool IsWaiting( TUint aProtocol, TUint aPort );
	void CancelAllRequests( CSIPConnection::TState aReason );
	TUint Protocol() { return KProtocolInetTcp; }
	CSocketContainer& GetSocketContainerL( const TInetAddr& aRemoteAddr );
	void InformSendingStatus( const TInetAddr& aRemoteAddr );
	void SetPersistencyL( const TInetAddr& aRemoteAddr, 
	                      TBool aIsPersistent,
	                      MSIPNATBindingObserver* aBindingObserver );
	CSender* Sender( const TSIPTransportParams& aParams,
	                 TUint aProtocol, 
	                 const TInetAddr& aRemoteAddr );
	void Disconnect( const TInetAddr& aRemoteHost );       
	TBool Remove( TUint32 aTransportId );
	TBool Remove( MSIPNATBindingObserver& aSIPNATBindingObserver );
	TBool Shutdown( TUint32 aTransportId,
	                MSIPTransportRemovalObserver* aRemovalObserver );
	TBool AddUserL( const TSIPTransportParams& aParams, TUint aReceivePort );
	
public: // From MServerTransportOwner

	void RemoveL( CServerTransport* aTransport,
				  const TInetAddr& aRemoteAddr,
				  MSIPTransportRemovalObserver* aRemovalObserver );
	void ReceiveL( CSIPMessage* aMessage,
				   const TInetAddr& aRemoteAddr,
				   TInt aError,
				   TBool aCompressed );
	void ReRouteL( COutgoingData* aData );
	MSigCompController* SigCompHandler();
	TUint32 IapId();
	TBool IsReservedTransportOwner() const;
	
public:	// From MListenerOwner

	void AcceptedL();
	void AcceptErrorL( TInt aError );
	void GetLocalAddrL( TInetAddr& aAddr );
	
private: // Private contructors

    void ConstructL();

	CTcpListeningPoint( RSocketServ& aServer,
                    	MTransactionFinder& aFinder, 
                    	MServerTaFactory& aTaFactory,
                    	MTransportOwner& aTransportOwner,
                    	MTimerManager& aTimer,
                    	TUint aPort,
                    	TUint aTOne,
                    	CSIPServerResolver& aServerResolver,
                    	RConnection& aConnection,
                    	MSigCompController& aSigCompHandler,
                    	CNetworkInfo& aNetworkInfo,
                    	COwnerSettingsList& aSettingsList,
                    	const TSIPTransportParams& aTransportParams,
                    	CSIPNATTraversalController& aNATTraversal );

private:

    CServerTransport* FindServerTransport( const TInetAddr& aRemoteAddr );
    TBool IsRemoteAllowed( CServerTransport& aTransport );
    void RemoveWaitingAccept();
    
    void HandleShutdownCompletion( MSIPTransportRemovalObserver* aRemovalObserver,
                                   TUint32 aTransportId );
    TBool RemovalAllowed();
    void RemoveServerTransport( CServerTransport* aServerTransport );
    
private: // Data

	RSocketServ* iSocketServ;
	CTransportErrorHandler* iErrorHandler;
	MTimerManager* iTimer;
	CListener* iListener;
	TUint iSourcePort;
	TUint iTimerOne;
	TBool iErrorOn;
	RConnection* iConnection;
	
	TSglQue<CServerTransport> iList;
	TSglQueIter<CServerTransport> iListIter;
	
	CServerTransport* iWaitingAccept;
	
	RArray<TUint> iTransportUsers;
	
	TInt iShutdownCount;

private:
#ifdef CPPUNIT_TEST
	friend class CTcpTransTest;
	friend class CServerTest;
#endif
	};

#endif // end of __CTCPLISTENINGPOINT_H__

// End of File