// Copyright (c) 2005-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:+
−
//+
−
+
−
/**+
−
 @file+
−
 @internalTechnology+
−
*/+
−
+
−
#ifndef AVCTP_H+
−
#define AVCTP_H+
−
+
−
#include <es_prot.h>+
−
#include <bluetoothav.h>+
−
#include <e32hashtab.h>+
−
#include "btsockettimer.h"+
−
#include "avctpcommon.h"+
−
#include <es_prot_internal.h>+
−
+
−
namespace SymbianAvctp+
−
{+
−
+
−
const static TUint KServiceInfo =+
−
	KSIConnectionLess | KSIReliable | KSIInOrder | +
−
	KSIDatagram | KSIGracefulClose;+
−
+
−
const static TInt KServiceTypeInfo = +
−
	ESocketSupport | ECantProcessMBufChains | EUseCanSend;+
−
+
−
const static TInt KMaxNumSocketsInProtocol = 10;+
−
} // end of namespace SymbianAvctp+
−
+
−
+
−
// ok to not have in namespace+
−
const static TL2CAPPort KAvctpSecondChannelPSM = 0x1b;+
−
const TInt KAvctpSecondaryChannelOutboundMTU = 0xffff;+
−
const TInt KAvctpSecondaryChannelInboundMTU = 0xffff;+
−
+
−
// forward declarations+
−
class CAvctpSap;+
−
class CAvctpTransport;+
−
class CAvctpMuxerStateFactory;+
−
class CAvctpConnection;+
−
class CAvctpPacketMgr;+
−
class HAvctpIncomingSdu;+
−
class HAvctpOutgoingSdu;+
−
class CAvctpSubConDeviceErrorEvent;+
−
class CAvctpSubConEventConnectCfm;+
−
class CAvctpSubConEventConnectInd;+
−
class CAvctpSubConEventDiscCfm;+
−
class CAvctpSubConEventDiscInd;+
−
class MAvctpSDUSender;+
−
+
−
NONSHARABLE_CLASS(TClientItem)+
−
	{+
−
public:+
−
	TClientItem(TUint16 aClientId);+
−
	void AttachPrimaryChannel(MSocketNotify& aNotify);+
−
	void AttachSecondaryChannel(MSocketNotify& aNotify);+
−
	void DetachSecondaryChannel();+
−
	TUint16 ClientId() const;+
−
	MSocketNotify* PrimaryChannel() const;+
−
	MSocketNotify* SecondaryChannel() const;+
−
	TBool IsSecondaryChannelAttached() const;+
−
private:+
−
	TUint16					iClientId;+
−
	MSocketNotify*			iPrimaryChannel;+
−
	MSocketNotify*			iSecondaryChannel;+
−
	TBool					iIsSecondaryChannelAttached;+
−
	TInt					iRefCount;+
−
	};+
−
+
−
/**+
−
The AVCTP Protocol object.  Used by BT_v2.prt to create a CProtocolBase object+
−
for ESOCK, so ESOCK can create AVCTP sockets.+
−
+
−
This is the object created by ESock to give access to AVCTP services+
−
+
−
  @internalAll+
−
  @see CProtocolBase+
−
*/+
−
+
−
NONSHARABLE_CLASS(CAvctpProtocol) : public CBluetoothProtocolBase+
−
    {+
−
public:+
−
	// Factory functions+
−
    static CAvctpProtocol* NewL(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);+
−
    static CAvctpProtocol* NewLC(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);+
−
	+
−
	// Functions from CProtocolBase+
−
	virtual void InitL(TDesC& aTag);				// need to get a state factory+
−
	virtual void StartL();							// check we're bound+
−
	virtual void BindToL(CProtocolBase* aProtocol);	// bind to lower protocol (L2CAP)+
−
	virtual void CloseNow();+
−
	virtual void Open();+
−
	virtual void Close();+
−
	virtual void Identify(TServerProtocolDesc* aProtocolDesc) const;+
−
	virtual CServProviderBase* NewSAPL(TUint aSockType);+
−
	+
−
	// Functions  from CBluetoothProtocolBase+
−
	virtual TInt BearerConnectComplete(const TBTDevAddr& aAddr, CServProviderBase* aSSP);+
−
	virtual TInt ControlPlaneMessage(TBTControlPlaneMessage aMessage, TAny* aParam);+
−
+
−
	// Other general protocol functions	+
−
	TInt StartProtocolListening();+
−
	void DoStartAvctpListeningL();+
−
	static void ProtocolIdentity(TServerProtocolDesc* aDesc); // Static query function used by Identify+
−
	TInt SetPreauthorisation(const TBTDevAddr& aPreauthoriseAddress, TBool aSetPreauthorisation);+
−
+
−
	// AVCTP specific functions+
−
	CAvctpMuxerStateFactory& MuxerStateFactory() const;+
−
+
−
	// Interface to the muxer+
−
	TInt ProvideTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId, MSocketNotify& aControlSocket);+
−
	TInt ActiveExtendTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket);+
−
	void AwaitForExtendedTransport(TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket);+
−
	void PrimaryChannelRefuseAttach(const TBTDevAddr& aRemoteAddr, TUint16 aClientId);+
−
	void SecondaryChannelRefuseAttach(const TBTDevAddr& aRemoteAddr, TUint16 aClientId);	+
−
	TInt AttachInboundConnectionToTransport(const TBTDevAddr& aRemoteAddr, CServProviderBase* aL2CAPConSAP);+
−
	TInt GetChannelMtu(TInt aChannel, const TBTDevAddr& aAddr, TInt& aMtu);+
−
	TInt ReleaseTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId);+
−
	TInt ReleaseExtendedTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId);+
−
	void PrimaryChannelIncomingRemoteDisconnection(const TBTDevAddr& aRemoteAddr);+
−
	MAvctpSDUSender* GetSDUSender(const TBTDevAddr& aRemoteAddr, TInt aChannel);+
−
	CAvctpTransport* FindTransport(const TBTDevAddr& aDevAddr);+
−
	void AwaitTransport(TUint16 aClientId, MSocketNotify& aControlSocket);+
−
	TInt PrimaryChannelAgreeAttachment(TUint16 aClientId, const TBTDevAddr& aRemoteAddr);+
−
	TInt SecondaryChannelAgreeAttachment(TUint16 aClientId, const TBTDevAddr& aRemoteAddr);+
−
	// Interface to all Saps provided for the muxers+
−
	TBool SapsHaveDataFor(const TBTDevAddr& aRemoteAddr);+
−
	void  SignalCanSendToSaps(CAvctpPacketMgr& aPacketMgr);+
−
	void  SignalNewDataToSaps(HAvctpIncomingSdu* aSdu, TInt aChannel);+
−
	void  SignalMuxerDownToSaps(const TBTDevAddr& aRemoteAddr);+
−
	+
−
	// Que Management+
−
	TInt AddSap(CAvctpSap& aSap);+
−
	void RemoveSap(CAvctpSap& aSap);+
−
	CAvctpSap* FindSap(TUint16 aClientId);+
−
	TInt AddTransport(CAvctpTransport& aMuxer);+
−
	void RemoveTransport(CAvctpTransport& aMuxer);+
−
	CAvctpTransport* FindOrCreateTransport(const TBTDevAddr& aDevAddr, TInt aChannel, CServProviderBase* aL2CAPConSAP = NULL);+
−
	void SetSecondChannelCtrlNotify(TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket);+
−
	void NotifyLinkUp(const TBTDevAddr& aAddr, TBool aIsSecondChannel);+
−
private:+
−
	CAvctpProtocol(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan);+
−
	void ConstructL();+
−
	~CAvctpProtocol();+
−
+
−
	// Close Functions+
−
	void CheckForIdle();+
−
	TBool IsIdle();+
−
	void QueIdleTimer();+
−
	void DequeIdleTimer();+
−
	const TClientItem* AddClientItem(TUint16 aClientId, MSocketNotify& aNotify);+
−
	const TClientItem* ClientItem(TUint16 aClientId) const;+
−
	static TInt TryToClose(TAny* aProtocol);+
−
	+
−
	// Ipid Response Callback functions+
−
	static TInt IpidAsyncCallBack(TAny* aProtocol);+
−
	inline void StartSendIpidAsyncCallBack();+
−
	inline void CancelIpidAsyncCallBack();+
−
	+
−
#ifdef __FLOG_ACTIVE+
−
	void LogSaps();+
−
	void LogMuxers();+
−
#endif+
−
	+
−
private:+
−
	/** The state factory for the lightweight AVCTP SAP states */+
−
	CAvctpMuxerStateFactory*		iMuxerStateFactory;+
−
+
−
	// Queues+
−
	/** All AVCTP Service Access Providers are owned by esock. +
−
	    This queue is for Saps that have been assigned a PID +
−
	    to allow us to enforce the 1 SAP / PID rule */+
−
	TDblQue<CAvctpSap> iSaps;+
−
	/** All AVCTP transports are owned by the protocol.+
−
	    This queue is for Muxers that have been assigned a remote address+
−
	    to allow us to enforce the 1 Muxer / remote address rule */+
−
	TDblQue<CAvctpTransport> iTransports;+
−
	/** This is a Que of IPID responses to remote devices +
−
		These are owned by the protocol */+
−
	TDblQue<HAvctpOutgoingSdu> iIpidResponses;+
−
+
−
	// Stuff for close callbacks, etc.+
−
	/** Whether we are about to die */+
−
	TBool					iClosePending;+
−
+
−
	/** An entry in the BT protocol family delta timer queue+
−
		The idle timer is something that runs to prevent the protocol going down and +
−
		then being brought up again immediately because this is costly. Instead we +
−
		stay alive for a small amount of time to try and smooth out the Opening and+
−
		closing */+
−
	TDeltaTimerEntry		iIdleTimerEntry;+
−
	TBool			iIdleTimerQueued;+
−
	+
−
	CAsyncCallBack*	iIpidResponseAsyncCallBack;+
−
	CIncomingConnectionListener*	iSecondChannelListener;+
−
	RHashMap<TInt, TClientItem>		iClientItems;+
−
	};+
−
+
−
#include "avctp.inl"+
−
+
−
#endif // AVCTP_H+
−
 +
−