// 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          : CListener.cpp
// Part of       : ConnectionMgr
// Version       : SIP/4.0 
//




#include "CListener.h"
#include "MListenerOwner.h"
#include "CommonConsts.h"
#include "siperr.h"


// -----------------------------------------------------------------------------
// CListener::NewL
// -----------------------------------------------------------------------------
//
CListener* CListener::NewL(MListenerOwner& aContext,
						   RSocketServ& aServer,
						   TUint aPort)
	{
	CListener* self = NewLC(aContext, aServer, aPort);
	CleanupStack::Pop();
	return self;
	}

// -----------------------------------------------------------------------------
// CListener::NewLC
// -----------------------------------------------------------------------------
//
CListener* CListener::NewLC(MListenerOwner& aContext,
							RSocketServ& aServer,
							TUint aPort)
	{
	CListener* self = new (ELeave) CListener();
	CleanupStack::PushL(self);
	self->ConstructL(aContext, aServer, aPort);
	return self;
	}

// -----------------------------------------------------------------------------
// CListener::ConstructL
// -----------------------------------------------------------------------------
//
void CListener::ConstructL(MListenerOwner& aContext,
						   RSocketServ& aServer,
						   TUint aPort)
	{
	iContext = &aContext;
	iServer = &aServer;
	iPort = aPort;
	CActiveScheduler::Add(this);
	User::LeaveIfError(iListen.Open(*iServer, KAfInet, KSockStream,
									KProtocolInetTcp));

    iListen.SetOpt(KSoReuseAddr, KSolInetIp, 1);
    
	TInetAddr address;
	iContext->GetLocalAddrL(address);
	address.SetPort(iPort);
	address.SetFamily(0);
	TInt err = iListen.Bind(address);
	if(err == KErrInUse)
		{
		User::Leave(KErrSIPTransportFailure);
		}
	else
		{
		User::LeaveIfError(err);
		}
	iListen.Listen(5);
	}

// -----------------------------------------------------------------------------
// CListener::NewL
// -----------------------------------------------------------------------------
//
CListener* CListener::NewL(MListenerOwner& aContext,
						   RSocketServ& aServer,
						   TUint aPort,
						   RConnection& aConnection)
	{
	CListener* self = NewLC(aContext, aServer, aPort, aConnection);
	CleanupStack::Pop();
	return self;
	}

// -----------------------------------------------------------------------------
// CListener::NewLC
// -----------------------------------------------------------------------------
//
CListener* CListener::NewLC(MListenerOwner& aContext,
							RSocketServ& aServer,
							TUint aPort,
							RConnection& aConnection)
	{
	CListener* self = new (ELeave) CListener();
	CleanupStack::PushL(self);
	self->ConstructL(aContext, aServer, aPort, aConnection);
	return self;
	}

// -----------------------------------------------------------------------------
// CListener::ConstructL
// -----------------------------------------------------------------------------
//
void CListener::ConstructL(MListenerOwner& aContext,
						   RSocketServ& aServer,
						   TUint aPort,
						   RConnection& aConnection)
	{
	iContext = &aContext;
	iServer = &aServer;
	iPort = aPort;

	iConnection = &aConnection;

	CActiveScheduler::Add(this);
	User::LeaveIfError(iListen.Open(*iServer, KAfInet, KSockStream,
									KProtocolInetTcp, *iConnection));
	if(aPort == KDefaultSipPort)
		{
		iListen.SetOpt(KSoReuseAddr, KSolInetIp, 1);
		}
	TInetAddr address;
	iContext->GetLocalAddrL(address);
	address.SetPort(iPort);
	address.SetFamily(0);
	TInt err = iListen.Bind(address);
	if(err == KErrInUse)
		{
		User::Leave(KErrSIPTransportFailure);
		}
	else
		{
		User::LeaveIfError(err);
		}
	iListen.Listen(5);
	}

// -----------------------------------------------------------------------------
// CListener::RunL
// -----------------------------------------------------------------------------
//
void CListener::RunL()
	{
	if(iStatus == KErrNone)
		{
		iContext->AcceptedL();
		}
	else
		{
		iContext->AcceptErrorL(iStatus.Int());
		}
	}

// -----------------------------------------------------------------------------
// CListener::DoCancel
// -----------------------------------------------------------------------------
//
void CListener::DoCancel()
	{
	iListen.CancelAccept();
	}

// -----------------------------------------------------------------------------
// CListener::RunError
// -----------------------------------------------------------------------------
//
TInt CListener::RunError(TInt aError)
	{
	if(aError != KErrNoMemory)
		{
		return KErrNone;
		}
	return aError;
	}

// -----------------------------------------------------------------------------
// CListener::Accept
// -----------------------------------------------------------------------------
//
void CListener::Accept(RSocket& aSocket)
	{
	if(!IsActive())
		{
		iListen.Accept(aSocket, iStatus);
		SetActive();
		}
	}

// -----------------------------------------------------------------------------
// CListener::~CListener
// -----------------------------------------------------------------------------
//
CListener::~CListener()
	{
	Cancel();
	iListen.Close();
	}

// -----------------------------------------------------------------------------
// CListener::CListener
// -----------------------------------------------------------------------------
//
CListener::CListener() : CActive(CActive::EPriorityStandard)
	{
	}