// Copyright (c) 2004-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:

//

#ifndef PANAGTINCOMING_H

#define PANAGTINCOMING_H

/**

@file

PAN agent incoming connection listener definition

@internalComponent

*/

#include <comms-infras/eintsock.h>

#include "pancommon.h"	// for KBnepPsm

class RInternalSocket;

namespace PanAgent

/**

@internalComponent

@released

@since v8.1

*/

{

const TUint KIncomingSockQueueSize = 8;

const TUint KPriorityIncomingListenerAo = CActive::EPriorityStandard;

/** Minimum time between attempts to reopen the listening and/or accepting socket(s) */

const TInt KMinSocketReopenAttemptInterval = 30*1000*1000;	// 30 secs

/** Maximum time between attempts to reopen the listening and/or accepting socket(s) */

const TInt KMaxSocketReopenAttemptInterval = 6*60*1000*1000;	// 6 mins 

class CPanIncomingSocketDelayedOpenHelper;

class MIncomingConnectionAcceptor;

NONSHARABLE_CLASS(CPanIncomingConnectionListener) : public CActive

/**

Listen for incoming connections from other Bluetooth devices

*/

	{

	friend class CPanIncomingSocketDelayedOpenHelper;

public:

	static CPanIncomingConnectionListener* NewL(MIncomingConnectionAcceptor& aAcceptor);

	~CPanIncomingConnectionListener();

	// CActive methods

	void RunL();

	void DoCancel();

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

    void RestartIncomingConnectionListener(TInt aError);

#endif	

	inline TBool IsListeningSocketOpen() const;

private:

	CPanIncomingConnectionListener(MIncomingConnectionAcceptor& aAcceptor);

	void ConstructL();

	void OpenListeningSocketL();

	TBool IsAcceptingSocketOpen() const;

public:

private:

	::RInternalSocket iListeningSocket;	//< The listening socket

	::RInternalSocket iAcceptingSocket;	//< The current accepting socket

	CPanIncomingSocketDelayedOpenHelper* iDelayedOpenHelper;

	MIncomingConnectionAcceptor& iAcceptor;	//< The class to signal when a new connection is accepted

	TBool iListeningSocketIsOpen;

	};

inline TBool CPanIncomingConnectionListener::IsListeningSocketOpen() const

	{

	return iListeningSocketIsOpen;

	}

class MIncomingConnectionAcceptor

/**

An interface to allow the socket listener class to hand off new connections to a channel manager

*/

	{

public:

	virtual void CreateNewConnectionFromIncomingL(RInternalSocket& aConnectedSocket) = 0;

protected:

	virtual ~MIncomingConnectionAcceptor(){};

	};

NONSHARABLE_CLASS(CPanIncomingSocketDelayedOpenHelper) : public CTimer

/**

If it is not possible to reopen the listening or accepting sockets for any reason,

this class will perform a retry at regular intervals to attempt to recover.

@note This class uses an exponential backoff in the case of failure

*/

	{

public:

	static CPanIncomingSocketDelayedOpenHelper* NewL(CPanIncomingConnectionListener& aIncomingConnectionListener);

	~CPanIncomingSocketDelayedOpenHelper();

	// general methods

	void SocketOpenFailed();

	// CTimer (well, CActive actually) methods

	virtual void RunL();

private:

	CPanIncomingSocketDelayedOpenHelper(CPanIncomingConnectionListener& aIncomingConnectionListener);

	void ConstructL();

	void SetNewTimerPeriod();

public:

private:

	TTimeIntervalMicroSeconds32 iCurrentTimerPeriod;

	CPanIncomingConnectionListener& iIncomingConnectionListener;

	};

}	// PanAgent

#endif // PANINCOMING_H