--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/bluetoothcommsprofiles/btpan/panagt/panagtincoming.h	Fri Jan 15 08:13:17 2010 +0200
@@ -0,0 +1,135 @@
+// 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