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

// Defines the avdtp protocol class

// 

//

/**

 @file

 @internalComponent

*/

#ifndef AVDTP_H

#define AVDTP_H

#include <es_prot.h>

#include <bt_sock.h>

#include <bluetoothav.h>

#include "secman.h"

#include "notification.h"

#include "bt.h"

#include "avdtpTransportSession.h"

#include "avdtpSEPCache.h"

#include "avdtpStream.h"

#include "avdtpLocalSEP.h"

#include "avdtpAllocators.h"

#include <es_prot_internal.h>

// Stream and Datagram I/f's are muturally exclusive. You can't have some sockets one

// time and some the other -- esock will always give presidence to stream.

// don't support graceful close

const TUint KAvdtpServiceInfo = KSIInOrder|

								KSIDatagram|

								KSICanReconnect;

#ifdef _OOM_TEST

const TInt KAvdtpIdleTimeout = 1000;

#undef __ASSERT_DEBUG

#define __ASSERT_DEBUG(c,p) 

#else

const TInt KAvdtpIdleTimeout = 5000000;

#endif

const TUid KAvdtpUID = {0x100095FE};

class CBTProtocolFamily;

class CLinkMgrProtocol;

class CBTInquiryMgr;

class CTransportChannel;

class CSignallingChannel;

class CAvdtpSAP;

class CLogicalChannelFactory;

class CAVStream;

class CRemoteSEPCache;

class CAVStreamStateFactory;

NONSHARABLE_CLASS(CAvdtpProtocol) : public CBluetoothProtocolBase

	{

friend class CAvdtpSAP;

public:

	// export for protocol

	static CAvdtpProtocol* NewL(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);

	static CAvdtpProtocol* NewLC(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);

	// From CProtocolBase

	// Factories

	CServProviderBase* NewSAPL(TUint aSockType);

	void Close();

	void Open();

	void CloseNow();

    // From ProtocolManager before all binding.

	void InitL(TDesC &aTag);

	// From Protocol Manager - after all binding

	void StartL();	

	// From higher protocol

	void BindL(CProtocolBase* aProtocol, TUint aId);

	void BindToL(CProtocolBase* aProtocol);	// From Protocol Manager

	// Query functions

	void Identify(TServerProtocolDesc* aDesc) const;	

	static void ProtocolIdentity(TServerProtocolDesc* aDesc);	

	// bluetooth protocol overridden functions

	TInt StartProtocolListening();

	// Get a factory for the logical channels

	inline CLogicalChannelFactory& LogicalChannelFactory() const;

	TInt SetPreauthorisation(const TBTDevAddr& aPreauthoriseAddress, TBool aSetPreauthorisation);

	void StreamCreated(CAVStream& aStream);

	CAVStream* FindStream(const TAvdtpSockAddr& aAddr);

	void RemoveStream(CAVStream& aStream);

	inline const CAVStreamStateFactory& StreamStateFactory() const;

	CTransportChannel* GetTransportChannel(const TAvdtpSockAddr& aSockAddr, TBool aUseMux, 

											TTCID aRemotelyAssignedTTCID=KInvalidTCID);

	CTransportChannel* FindMuxChannel(TTCID aTCID);

	CSignallingChannel* GetSignallingChannel(const TBTDevAddr& aDevAddr);

	CSignallingChannel* FindSignallingChannel(const TBTDevAddr& aDevAddr);

	CSignallingChannel* FindListeningSignallingChannel();

	CSignallingChannel* CreateSignallingChannelForListening();

	void ConnectSignallingListeners(CSignallingChannel& aConnectedSignallingChannel);

	CUserPlaneTransportSession* CreateUserPlaneSessionL(CAvdtpSAP& aSAP,

														CAVStream& aStream,

														TAvdtpTransportSessionType aType);

	virtual TInt BearerConnectComplete(const TBTDevAddr& aAddr, CServProviderBase* aSAP);

	void TransportChannelDown(CTransportChannel& aTransportChannel);

	void TransportChannelClosing(CTransportChannel& aTransportChannel);

	void SignallingChannelDown(CSignallingChannel& aSignallingChannel);

	inline CRemoteSEPCache& RemoteSEPCache() const;

	inline TSEIDManager& SEIDManager();

	// secondary SAP management

	void AddSecondarySAP(CAvdtpSAP& aSecondarySAP);

	CAvdtpSAP* GetSecondarySAP();

	virtual TInt ControlPlaneMessage(TBTControlPlaneMessage aMessage, TAny* aParam);

private:

	CAvdtpProtocol(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);

	~CAvdtpProtocol();

	void ConstructL();

	CTransportChannel* CreateTransportChannelL(const TBTDevAddr& aAddr, TBool aMuxed);

	void QueIdleTimerEntry();

	void RemoveIdleTimerEntry();

	TBool ShouldClose();

	static TInt TryToClose(TAny* aProtocol);

	void DestroySecondarySAPs();

	void DoStartAvdtpListeningL();

private:	

	// Singleton objects

	CLogicalChannelFactory*	iLogicalChannelFactory;

	CAVStreamStateFactory*	iStreamStateFactory;

	CRemoteSEPCache*		iRemoteSEPCache;

	TDeltaTimerEntry		iIdleTimerEntry;

	TBool					iIdleEntryQueued;

	// List of TransportChannels (Direct and Mux)

	TDblQue<CTransportChannel>	iTransportChannels;

	TDblQue<CTransportChannel>	iClosingTransportChannels;

	TDblQue<CSignallingChannel>	iSignallingChannels;

	// no closing signalling channel tracking as they perform immediate shutdowns

	TDblQue<CAVStream>			iStreams;	// to allow for U-plane sessions to find the stream they belong to

	TSEIDManager				iSEIDManager;

	// Q of SAPs waiting for a transport channel to attach to

	TSglQue<CAvdtpSAP>  		iSecondarySAPs;

	TBool						iClosePending;

	};

inline CLogicalChannelFactory& CAvdtpProtocol::LogicalChannelFactory() const

	{

	return *iLogicalChannelFactory;

	}

inline CRemoteSEPCache& CAvdtpProtocol::RemoteSEPCache() const

	{

	return *iRemoteSEPCache;

	}

inline TSEIDManager& CAvdtpProtocol::SEIDManager()

	{

	return iSEIDManager;

	}

inline const CAVStreamStateFactory& CAvdtpProtocol::StreamStateFactory() const

	{

	return *iStreamStateFactory;

	}

#endif