// 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:+
−
// Implements the AVCTP protocol object+
−
// +
−
//+
−
+
−
/**+
−
 @file+
−
 @internalTechnology+
−
*/+
−
+
−
#include <e32def.h>+
−
#include <bluetooth/logger.h>+
−
#include <bluetoothav.h>+
−
+
−
#include "Avctp.h"+
−
#include "avctpsap.h"+
−
#include "avctpmuxerstates.h"+
−
#include "avctpconstants.h" +
−
#include "IncomingConnListener.h"+
−
#include "avctpPacketMgr.h"+
−
+
−
#ifdef __FLOG_ACTIVE+
−
_LIT8(KLogComponent, LOG_COMPONENT_AVCTP);+
−
#endif+
−
+
−
#ifdef _DEBUG+
−
PANICCATEGORY("avctp");+
−
#endif+
−
+
−
using namespace SymbianAvctp;+
−
+
−
#include "avctpmuxer.h"+
−
+
−
+
−
+
−
#ifdef __FLOG_ACTIVE+
−
#define LOG_SAPS LogSaps();+
−
#define LOG_MUXERS LogMuxers();+
−
#define LOG_SAPLINKSMGRS LogSapLinkMgrs();+
−
#else+
−
#define LOG_SAPS+
−
#define LOG_MUXERS+
−
#define LOG_SAPLINKSMGRS+
−
#endif+
−
+
−
/** +
−
Protocol object constructor.+
−
+
−
@see CBTSecMan+
−
@param aSecMan The Bluetooth security manager+
−
@param aControlPlane the object which the protocol can use to pass control plane messages+
−
@param aCodMan the CoD manager for the protocol+
−
@return A pointer to the AVCTP protocol object+
−
@internalComponent+
−
*/+
−
CAvctpProtocol::CAvctpProtocol(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan)+
−
:	CBluetoothProtocolBase(aSecMan, aControlPlane, aCodMan),+
−
	iSaps(_FOFF(CAvctpSap, iQueLink)),+
−
	iTransports(_FOFF(CAvctpTransport, iQueLink)),+
−
	iIpidResponses(_FOFF(HAvctpOutgoingSdu, iQueLink))+
−
	{+
−
	LOG_FUNC+
−
	+
−
	TCallBack callBack(TryToClose, this);+
−
	iIdleTimerEntry.Set(callBack);+
−
	}+
−
+
−
/** Static protocol object factory function.+
−
+
−
Leaves the protocol object on the cleanup stack.+
−
+
−
@see CBTSecMan+
−
@param aSecMan The Bluetooth security manager+
−
@param aControlPlane the object which the protocol can use to pass control plane messages+
−
@param aCodMan the CoD manager for the protocol+
−
@return A pointer to the AVCTP protocol object+
−
@leave KErrNoMemory if the protocol object could not be created+
−
@internalComponent+
−
*/+
−
CAvctpProtocol* CAvctpProtocol::NewLC(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan)+
−
	{+
−
	CONNECT_LOGGER+
−
	LOG_STATIC_FUNC+
−
	CAvctpProtocol* self = new(ELeave) CAvctpProtocol(aSecMan, aControlPlane, aCodMan);+
−
	CleanupStack::PushL(self);+
−
	self->ConstructL();+
−
	return self;+
−
	}+
−
+
−
/** Static protocol object factory function.+
−
+
−
@see CBTSecMan+
−
@param aSecMan The Bluetooth security manager+
−
@param aControlPlane the object which the protocol can use to pass control plane messages+
−
@param aCodMan the CoD manager for the protocol+
−
@return A pointer to the AVCTP protocol object+
−
@leave KErrNoMemory if the protocol object could not be created+
−
@internalComponent+
−
*/+
−
CAvctpProtocol* CAvctpProtocol::NewL(CBTSecMan& aSecMan, RBTControlPlane& aControlPlane, CBTCodServiceMan& aCodMan)+
−
	{+
−
	LOG_STATIC_FUNC+
−
	CAvctpProtocol* self = CAvctpProtocol::NewLC(aSecMan, aControlPlane, aCodMan);+
−
	CleanupStack::Pop(self);+
−
	return self;+
−
	}+
−
+
−
/** Protocol object second-phase construction.+
−
+
−
@internalComponent+
−
*/+
−
void CAvctpProtocol::ConstructL()+
−
	{+
−
	LOG_FUNC+
−
	iMuxerStateFactory = CAvctpMuxerStateFactory::NewL();+
−
+
−
	TCallBack cb(IpidAsyncCallBack, this);+
−
	iIpidResponseAsyncCallBack = new (ELeave)CAsyncCallBack(cb, EActiveHighPriority);+
−
	+
−
	}+
−
+
−
/** Protocol object destructor.+
−
+
−
We don't clear up the SAPs, or the Muxer Collections as they are owned by ESock+
−
and it is up to it to destroy them.+
−
+
−
 muxers are owned by the protocol and so should be destroyed by it.+
−
+
−
@internalComponent+
−
*/+
−
CAvctpProtocol::~CAvctpProtocol()+
−
	{+
−
	LOG_FUNC+
−
	+
−
	DequeIdleTimer();+
−
+
−
	if (LowerProtocol())+
−
		{+
−
		LowerProtocol()->Close();  // Matches the bind+
−
		}+
−
+
−
	CancelIpidAsyncCallBack();+
−
	delete iIpidResponseAsyncCallBack;+
−
+
−
	TDblQueIter<HAvctpOutgoingSdu> sduIter(iIpidResponses);+
−
	while(sduIter)+
−
		{+
−
		delete sduIter++; // deques sdu+
−
		}				+
−
	TDblQueIter<CAvctpTransport> muxerIter(iTransports);+
−
	while(muxerIter)+
−
		{+
−
		delete muxerIter++; // deques muxer+
−
		}	+
−
+
−
	delete iMuxerStateFactory;+
−
	// iListener is deleted through CBluetoothProtocolBase+
−
	delete iSecondChannelListener;+
−
	iClientItems.Close();+
−
	+
−
	+
−
	}+
−
+
−
/** Pre-binding initialise.+
−
+
−
Alloc any stuff we need. This will only ever be called once during the lifetime of this protocol.+
−
+
−
@internalAll+
−
@leave KErrNoMemory if the state factory cannot be created+
−
@param aTag The strin   g identifier for the protocol from the ESock ini file+
−
*/+
−
void CAvctpProtocol::InitL(TDesC& /*aTag*/)+
−
	{+
−
	LOG_FUNC+
−
	}+
−
+
−
/** Binding complete.+
−
+
−
@internalAll+
−
*/+
−
void CAvctpProtocol::StartL()+
−
	{+
−
	LOG_FUNC+
−
+
−
	// Should check that we're bound now.+
−
	if (!iLowerProtocol)+
−
		{+
−
		User::Leave(ENotBound);+
−
		}+
−
	User::LeaveIfError(IncrementListeners());+
−
	}+
−
+
−
/** Request by Protocol Mgr to bind to the specified protocol. +
−
+
−
We can only be bound to one lower layer protocol, so the function leaves if we are already bound.+
−
+
−
@internalAll+
−
@leave KErrProtocolAlreadyBound if we are already bound, and any other leave from the lower protocol's BindL()+
−
@param aProtocol The protocol we need to bind to.+
−
*/+
−
void CAvctpProtocol::BindToL(CProtocolBase* aProtocol)+
−
	{+
−
	LOG_FUNC+
−
+
−
	if(!iLowerProtocol)+
−
		{+
−
#ifdef _DEBUG+
−
		TServerProtocolDesc prtDesc;+
−
		aProtocol->Identify(&prtDesc);+
−
+
−
		if(prtDesc.iAddrFamily != KBTAddrFamily ||+
−
		   prtDesc.iProtocol != KL2CAP)+
−
			{+
−
			User::Leave(KErrBtEskError);+
−
			}+
−
#endif+
−
+
−
		iLowerProtocol=static_cast<CBluetoothProtocolBase*>(aProtocol);+
−
		iLowerProtocol->BindL(this, 0); // id not used+
−
		iLowerProtocol->Open();+
−
		}+
−
	else+
−
		{+
−
	    User::Leave(KErrProtocolAlreadyBound);+
−
		}+
−
	}+
−
+
−
/** Create a new SAP.+
−
+
−
The SAP returned is owned by the caller -- this protocol will not clean it up.+
−
ESock uses this function to create a new SAP, and ESock will delete when it is+
−
finished with it.+
−
+
−
@internalAll+
−
@leave KErrNotSupported if aSockType is not KSockDatagram, KErrNoMemory if a+
−
     new SAP could not be created+
−
@param aSockType The socket type for the SAP: AVCTP only supports KSockDatagram+
−
@return A pointer to a new SAP+
−
*/+
−
CServProviderBase* CAvctpProtocol::NewSAPL(TUint aSockType)+
−
	{+
−
	LOG_FUNC+
−
+
−
	CBluetoothSAP* sap = NULL;+
−
	+
−
	switch(aSockType)+
−
		{+
−
	case KSockDatagram:    // AVCTP uses datagrams for data SAPs+
−
		sap = CAvctpSap::NewL(*this);+
−
		break;+
−
	case KSockRaw:    // AVCTP uses Raw for control SAPs+
−
		sap = CAvctpControlSAP::NewL(*this);+
−
		break;+
−
	default:+
−
		User::Leave(KErrNotSupported);+
−
		break;+
−
		}+
−
+
−
	return sap;+
−
	}+
−
	+
−
+
−
/** Identify the protocol.+
−
+
−
The descriptor is filled in to identify the protocol to ESock.+
−
+
−
@internalAll+
−
@param aDesc A pointer to the descriptor to be filled in+
−
*/+
−
void CAvctpProtocol::Identify(TServerProtocolDesc* aDesc) const+
−
	{+
−
	LOG_FUNC+
−
+
−
	ProtocolIdentity(aDesc);+
−
	}+
−
+
−
/** Fill in the protocol descriptor.+
−
+
−
This is a static utility function to fill in the protocol details.+
−
+
−
@internalComponent+
−
@param aDesc A pointer to the descriptor to be filled in+
−
*/+
−
void CAvctpProtocol::ProtocolIdentity(TServerProtocolDesc* aDesc)+
−
	{+
−
	LOG_STATIC_FUNC+
−
+
−
	_LIT(KAvctpProtocolName,"AVCTP"); +
−
	aDesc->iName			= KAvctpProtocolName;+
−
	aDesc->iAddrFamily		= KBTAddrFamily;+
−
	aDesc->iSockType		= KUndefinedSockType; // can support datagram AND raw+
−
	aDesc->iProtocol		= KAVCTP;+
−
	aDesc->iVersion			= TVersion(KBTMajor,KBTMinor,KBTBuild);+
−
	aDesc->iByteOrder		= ELittleEndian;+
−
	aDesc->iServiceInfo		= KServiceInfo;+
−
	aDesc->iNamingServices	= NULL;+
−
	aDesc->iSecurity		= KSocketNoSecurity; // cause we do our own+
−
	aDesc->iMessageSize		= KSocketMessageSizeNoLimit; // we can fragment to our heart's content+
−
	aDesc->iServiceTypeInfo	= KServiceTypeInfo;+
−
	aDesc->iNumSockets		= KMaxNumSocketsInProtocol;+
−
	}+
−
+
−
/** Our protocol reference in esock is now zero, so start to close.+
−
+
−
We don't actually close, merely Q a timer for a later close down.+
−
This close can be pre-empted by another open.+
−
+
−
@internalAll+
−
*/+
−
void CAvctpProtocol::CloseNow()+
−
	{+
−
	LOG_FUNC+
−
+
−
	iClosePending = ETrue;+
−
	+
−
	// We can only assert there are no saps cause the sap links mgrs are asynchronously deleted+
−
	// and so may still be around at this point. However they should've been deleted by the+
−
	// time TryToClose is called so we assert IsIdle() there.+
−
	ASSERT_DEBUG(iSaps.IsEmpty());+
−
	+
−
	QueIdleTimer();+
−
	}+
−
+
−
/** Request to open the protocol.+
−
+
−
The protocol may be repeatedly opened and closed.  The order of calls is+
−
InitL, [Open *n , Close * n,  CloseNow] * m etc.+
−
+
−
@internalAll+
−
*/+
−
void CAvctpProtocol::Open()+
−
	{+
−
	LOG_FUNC+
−
+
−
	iClosePending = EFalse;+
−
	DequeIdleTimer();+
−
	CProtocolBase::Open();+
−
	}+
−
+
−
/**+
−
   This is one session closing.+
−
*/+
−
void CAvctpProtocol::Close()+
−
+
−
	{+
−
	LOG_FUNC+
−
	CProtocolBase::Close();+
−
	}+
−
+
−
+
−
/**+
−
Helper to actually start listening. This protocol doesn't use the base class+
−
implementation as it needs to do a bit more.+
−
@internalComponent+
−
*/+
−
void CAvctpProtocol::DoStartAvctpListeningL()+
−
	{	+
−
	LOG_FUNC+
−
+
−
	const TUint KDefaultMtu = 335;+
−
	+
−
	CServProviderBase* sap =iLowerProtocol->NewSAPL(KSockSeqPacket);+
−
	CleanupStack::PushL(sap);+
−
	+
−
	TBTSockAddr localAddr;+
−
	localAddr.SetPort(KAVCTP);+
−
+
−
	// the security settings are:	+
−
	// (though see :Preauthorise() for the authentication exceptions due to avdtp authentication)+
−
	TBTServiceSecurity sec;+
−
	sec.SetAuthentication(KInboundAuthenticationDefault);+
−
	sec.SetAuthorisation(KInboundAuthoristationDefault);+
−
	sec.SetEncryption(KInboundEncryptionDefault);+
−
	sec.SetDenied(EFalse);+
−
	sec.SetUid(KAvctpServiceUid);+
−
	localAddr.SetSecurity(sec);+
−
	+
−
	CleanupStack::Pop(sap);+
−
	iListener = CIncomingConnectionListener::NewL(*this, sap, localAddr, KProtocolListeningQueueSize);										+
−
	+
−
	CServProviderBase* sap2 =iLowerProtocol->NewSAPL(KSockSeqPacket);+
−
	CleanupStack::PushL(sap2);+
−
	+
−
	TPckgBuf<TL2CapConfig> config;+
−
	config().SetMaxTransmitUnitSize(KAvctpSecondaryChannelInboundMTU);+
−
	config().SetMinMTU(KDefaultMtu);+
−
	config().SetMaxReceiveUnitSize(KAvctpSecondaryChannelInboundMTU);+
−
	config().SetMinMRU(KDefaultMtu);+
−
	+
−
	__DEBUG_ONLY(TInt err =) sap2->SetOption(KSolBtL2CAP, KL2CAPUpdateChannelConfig, config); +
−
	__ASSERT_DEBUG(err == KErrNone, Panic(ESetOptionError));+
−
	+
−
	// security for the secondary channel is not required+
−
	sec.SetAuthentication(KSecondaryChannelAuthenticationDefault);+
−
	sec.SetAuthorisation(KSecondaryChannelAuthoristationDefault);+
−
	sec.SetEncryption(KInboundEncryptionDefault);+
−
	sec.SetDenied(EFalse);+
−
	sec.SetUid(KAvctpServiceUid);	+
−
	localAddr.SetSecurity(sec);+
−
	localAddr.SetPort(KAvctpSecondChannelPSM);+
−
	+
−
	CleanupStack::Pop(sap2);+
−
	iSecondChannelListener  = CIncomingConnectionListener::NewL(*this, sap2, localAddr, KProtocolListeningQueueSize);										+
−
	}+
−
+
−
/**+
−
AVCTP connection listener connect complete function (cloned SAP overload).+
−
+
−
Part of the MSocketNotify interface.+
−
+
−
Called by the listening L2CAP SAP when an incoming connection occurs.+
−
+
−
This checks with the protocol to check for an existing muxer - if there+
−
is one, an error is returned and the new L2CAP SAP is shut down (the +
−
remote device should be using the existing muxer). If not, the SAP is+
−
given to the muxer.+
−
+
−
@internalAll+
−
@param aSap The SAP for the new lower layer connection+
−
*/+
−
TInt CAvctpProtocol::BearerConnectComplete(const TBTDevAddr& aAddr, CServProviderBase* aSSP)+
−
	{+
−
	LOG_FUNC+
−
	+
−
	IF_FLOGGING+
−
		(+
−
		TBuf<KBTAddressLength> address; +
−
		aAddr.GetReadable(address);+
−
		)+
−
		+
−
	LOG1(_L("from BT Device 0x%S"), &address);+
−
	+
−
	// NB: If no error occurs, ownership of aSSP passes to the muxer.+
−
	// If an error does occur then the CIncomingConnectionListener will take care of aSSP for us+
−
	TInt err = AttachInboundConnectionToTransport(aAddr, aSSP);+
−
	+
−
	return err;+
−
	}+
−
+
−
+
−
+
−
/**+
−
Control plane message delivery system between protocols+
−
@return error as a result of processing or not consuming the control message+
−
@param aMessage the message+
−
@param aParam arbitrary data for message - knowledge of aMessage allows casting+
−
@see CBTProtocolFamily+
−
@internalComponent+
−
*/+
−
TInt CAvctpProtocol::ControlPlaneMessage(TBTControlPlaneMessage aMessage, TAny* aParam)+
−
	{+
−
	LOG_FUNC+
−
+
−
	// only ones applicable to this protocol at present are +
−
	// for preauthorising a device - must have come from AVCTP, with PID=RCP+
−
	TInt ret = KErrNotSupported;+
−
	+
−
	switch (aMessage)+
−
		{+
−
		case EPreauthoriseDevice:+
−
			{+
−
			__ASSERT_DEBUG(aParam, Panic(EProtocolReceivingBadlyFormedControlMessage));+
−
			const TOverrideAuthorise& override = *reinterpret_cast<const TOverrideAuthorise*>(aParam);+
−
			__ASSERT_DEBUG(override.iAuthorisingProtocol == KAVDTP, Panic(EProtocolReceivingControlFromUnexpectedProtocol));+
−
			+
−
			SetPreauthorisation(override.iPreauthorisedRemoteAddress,+
−
								override.iPreauthorise);+
−
			ret = KErrNone;							+
−
			break;+
−
			}+
−
		default:+
−
			__ASSERT_DEBUG(aParam, Panic(EProtocolReceivingBadlyFormedControlMessage));+
−
		}+
−
	return ret;+
−
	}+
−
+
−
/**+
−
Helper to hide the need to supply the socket level to which preauthorisation pertains+
−
@param aPreauthoriseAddress the address of the device to preauthorise+
−
@param aSetPreauthorisation ETrue if the device is allowed to be authorised for other AVDTP/AVCTP connection, EFalse to cancel+
−
@internalComponent+
−
*/+
−
TInt CAvctpProtocol::SetPreauthorisation(const TBTDevAddr& aPreauthoriseAddress, TBool aSetPreauthorisation)+
−
	{+
−
	LOG_FUNC+
−
+
−
	TInt ret = KErrNone;+
−
	if (IsListening())+
−
		{+
−
		if (aSetPreauthorisation && !Listener().IsPreauthorised(KSolBtL2CAP, aPreauthoriseAddress))+
−
			{+
−
			Listener().SetPreauthorisation(KSolBtL2CAP, aPreauthoriseAddress, ETrue);+
−
+
−
			// tell AVDTP+
−
			TOverrideAuthorise override;+
−
			override.iAuthorisingProtocol = KAVCTP;+
−
			override.iAuthorisingPort = KAvrcpPid;			+
−
			override.iPreauthorise = aSetPreauthorisation;+
−
			override.iPreauthorisedRemoteAddress = aPreauthoriseAddress;+
−
			+
−
			ControlPlane().Preauthorise(KAVDTP, override);+
−
+
−
			}+
−
		else if (!aSetPreauthorisation)+
−
			{+
−
			Listener().SetPreauthorisation(KSolBtL2CAP, aPreauthoriseAddress, EFalse);			+
−
			}+
−
		// else do nothing+
−
		}+
−
	else+
−
		{+
−
		ret = KErrNotReady;+
−
		}+
−
	return ret;+
−
	}+
−
+
−
+
−
+
−
//+
−
// Interface to all Saps provided for the muxers+
−
+
−
/**+
−
  Used by a muxer to tell the saps that it is now in a position to +
−
  send data+
−
	+
−
  @param aRemoteAddr the remote address which they an now send to.+
−
  @internalComponent+
−
*/+
−
void CAvctpProtocol::SignalCanSendToSaps(CAvctpPacketMgr& IF_FLOGGING(aPacketMgr))+
−
	{+
−
	LOG_FUNC+
−
	LOG1(_L("from Packetgr 0x%08x"), &aPacketMgr);+
−
	+
−
	// kick off the ipid sending process.+
−
	StartSendIpidAsyncCallBack();+
−
	+
−
	TDblQueIter<CAvctpSap> sapIter(iSaps);+
−
	CAvctpSap* sap;+
−
	while(sapIter)+
−
		{+
−
		sap = sapIter++;+
−
		sap->CanSend(); +
−
		}	+
−
	}+
−
	 +
−
/**+
−
  Find out whether there are any saps with data for the given remote address+
−
  @param aRemoteAddr the remote device which might have data for it+
−
  @return ETrue if there is such a sap, EFalse otherwise+
−
  @internalComponent+
−
**/	+
−
TBool CAvctpProtocol::SapsHaveDataFor(const TBTDevAddr& aRemoteAddr)+
−
	{+
−
	LOG_FUNC+
−
	IF_FLOGGING+
−
		(+
−
		TBuf<KBTAddressLength> address;+
−
		aRemoteAddr.GetReadable(address);+
−
		)+
−
+
−
	LOG1(_L("from BT Device 0x%S"), &address);+
−
+
−
	TDblQueIter<CAvctpSap> iter(iSaps);+
−
	CAvctpSap* sap;+
−
	TBool ans = EFalse;+
−
	+
−
	while(iter)+
−
		{+
−
		sap = iter++;+
−
		if(sap->HasDataFor(aRemoteAddr))+
−
			{+
−
			ans = ETrue;+
−
			break;+
−
			}+
−
		}+
−
+
−
	LOG1(_L("result %d"), ans);+
−
	return ans;+
−
	}+
−
	+
−
/**+
−
Note the a TAvctpHeaderInfo could be provided as a parameter to this function+
−
but since the HAvctpIncomingSdu data contains this info too, there's a danger+
−
that the TAvctpHeaderInfo would not match the actual sdu. Hence the header+
−
info class isn't provided. This isn't a big cost cause it's quick to pull +
−
the transaction label, PID etc out of the sdu itself.+
−
*/+
−
void CAvctpProtocol::SignalNewDataToSaps(HAvctpIncomingSdu* aSdu, TInt aChannel)+
−
	{+
−
	LOG_FUNC+
−
+
−
	// Give data to each sap in turn to see if they want the PDU+
−
	TDblQueIter<CAvctpSap> iter(iSaps);+
−
	CAvctpSap* sap;+
−
	TBool sapAcceptedData = EFalse;+
−
	while(iter)+
−
		{+
−
		sap = iter++;+
−
		sapAcceptedData = sap->NewData(aSdu, aChannel);+
−
		if (sapAcceptedData)+
−
			{+
−
			break; // Once one accepts it, there's no point giving the data to the others+
−
			}+
−
		}					  	 +
−
+
−
	if (!sapAcceptedData)+
−
		{+
−
		// This is not for a registered PID.  If this is a command we should+
−
		// return an IPID response, if not we just dump it.  Crazy remote!+
−
		TAvctpStartHeaderInfo headerInfo;+
−
		TInt err = CAvctpPacket::ParseHeader(aSdu->Data(), headerInfo);+
−
		+
−
		if(!err && headerInfo.iMsgType == SymbianAvctp::ECommand)+
−
			{+
−
			HAvctpOutgoingSdu* ipidSdu = NULL;+
−
			TRAPD(ret, ipidSdu = HAvctpOutgoingSdu::NewIpidResponseL(*aSdu, aChannel));+
−
			if (ret == KErrNone)+
−
				{+
−
				iIpidResponses.AddLast(*ipidSdu);+
−
				StartSendIpidAsyncCallBack();+
−
				}+
−
			}+
−
		// else - we've OOM & we'll have to break the AVCTP spec & not send an IPID response :(+
−
		// or it's a response that we can't re-respond to.+
−
+
−
		// No one took the data so we need to clean it up+
−
		delete aSdu;+
−
		}+
−
	}+
−
+
−
/**+
−
This function is called when a muxer goes down and is used to inform Saps+
−
of this fact so they can get rid of any packets that are now stale.+
−
*/+
−
void CAvctpProtocol::SignalMuxerDownToSaps(const TBTDevAddr& aRemoteAddr)+
−
	{+
−
	LOG_FUNC+
−
+
−
	IF_FLOGGING+
−
		(+
−
		TBuf<KBTAddressLength> address;+
−
		aRemoteAddr.GetReadable(address);+
−
		)+
−
+
−
	LOG1(_L("from BT Device 0x%S"), &address);+
−
	+
−
	TDblQueIter<CAvctpSap> iter(iSaps);+
−
	CAvctpSap* sap;+
−
	+
−
	while(iter)+
−
		{+
−
		sap = iter++;+
−
		sap->MuxerDown(aRemoteAddr);+
−
		}					  	 +
−
	}+
−
+
−
//+
−
// Que Management Functions	 +
−
+
−
/** +
−
Adds a SAP to their queue.+
−
Ensures that there will only ever be one sap on the Q for each PID+
−
+
−
@internalComponent+
−
@param aSap The SAP to be added+
−
@return KErrInUse if there is already a Sap on aSap's PID, otherwise KErrNone+
−
*/   +
−
TInt CAvctpProtocol::AddSap(CAvctpSap& aSap)+
−
	{+
−
	LOG_FUNC+
−
	LOG2(_L("Adding 0x%08x on Pid 0x%x"), &aSap, aSap.Pid());+
−
	LOG_SAPS+
−
	+
−
	// The given sap must have a valid Pid to be on the protocol's Q+
−
	__ASSERT_DEBUG(aSap.Pid() != 0, Panic(ENullPid));+
−
	+
−
	TInt ret = KErrNone;+
−
	+
−
	CAvctpSap* sap = FindSap(aSap.Pid());+
−
	+
−
	if (!sap && aSap.iChannel == KAvctpSecondaryChannel)+
−
		{+
−
		ret = KErrNotReady;+
−
		}+
−
	else if (sap && aSap.iChannel == KAvctpPrimaryChannel)+
−
		{+
−
		// Bit of a hack to support two SAPs doing one PID+
−
		ret = KErrAlreadyExists;+
−
		}+
−
	else+
−
		{+
−
		// tell the sap that has been inserted in the list. Infact a sap that is not inserted in the+
−
		// list is shutdown from esock. In that process CAvctpProtocol::RemoveSap() is called and +
−
		// would remove the "PID's client" from the iClientItems list. But it has to remove it only if that+
−
		// sap has been inserted in the list.+
−
		aSap.iIsInList = ETrue;+
−
		iSaps.AddFirst(aSap);+
−
		DequeIdleTimer();+
−
		}+
−
	+
−
	return ret;+
−
	}+
−
	+
−
/** +
−
Removes a SAP from their queue.+
−
+
−
@internalComponent+
−
@param aSap The SAP to be removed+
−
*/   	+
−
void CAvctpProtocol::RemoveSap(CAvctpSap& aSap)+
−
	{+
−
	LOG_FUNC+
−
	LOG2(_L("Removing 0x%08x from Pid 0x%x"), &aSap, aSap.Pid());+
−
	LOG_SAPS+
−
+
−
	if (aSap.IsInList())+
−
		{+
−
		aSap.iQueLink.Deque(); // safe to Deque even if it's already been done+
−
		+
−
		TDblQueIter<CAvctpTransport> muxerIter(iTransports);+
−
		CAvctpTransport* transport = NULL;+
−
		+
−
		+
−
		while(muxerIter)+
−
			{+
−
			transport = muxerIter++;+
−
			//Sap pid is used as clientId key to uniquely identify the client RAvctp+
−
			if (transport->HasClient(aSap.Pid()))+
−
				{+
−
				if (aSap.Channel() == KAvctpPrimaryChannel)+
−
					{+
−
					transport->RemovePrimaryChannelRef(aSap.Pid());+
−
					}+
−
				else+
−
					{+
−
					transport->RemoveSecondaryChannelRef(aSap.Pid());+
−
					}+
−
				}+
−
			}+
−
	+
−
		// as we are removing the sap it means the RAvctp for this Pid is being closing+
−
		// so we must remove the TClientItem from the protocol. To avoid removing it twice+
−
		// (it should be safe though) we only remove it for the primary channel sap+
−
				+
−
		if (aSap.Channel() == KAvctpPrimaryChannel)+
−
			{+
−
			__DEBUG_ONLY(TInt err = ) iClientItems.Remove(aSap.Pid());+
−
			__ASSERT_DEBUG(err == KErrNone, Panic(EAvctpClientNotFound));+
−
			}+
−
		+
−
		CheckForIdle();+
−
		}+
−
	}+
−
+
−
/** Find the SAP that is on this PID.+
−
+
−
If no such SAP exists, return NULL. Note this function doesn't transfer ownership.+
−
+
−
There should be no Sap with a zero PID on the Q+
−
+
−
@internalComponent+
−
@param aClientId The client Id to look for+
−
@return The SAP connected on the specified PID, if any, otherwise NULL. +
−
*/+
−
CAvctpSap* CAvctpProtocol::FindSap(TUint16 aClientId)+
−
	{+
−
	LOG_FUNC+
−
+
−
	TDblQueIter<CAvctpSap> iter(iSaps);+
−
	CAvctpSap* sap = NULL;+
−
	CAvctpSap* foundSap = NULL;+
−
+
−
	while (iter)+
−
		{+
−
		sap = iter++;+
−
		__ASSERT_DEBUG(sap->Pid() != 0, Panic(ENullPid));+
−
		if(sap->Pid() == aClientId)+
−
			{+
−
			foundSap = sap;+
−
			break;+
−
			}+
−
		}+
−
+
−
	return foundSap;+
−
	}+
−
	+
−
/** +
−
Adds a Muxer to their queue which has been assigned a remote address. +
−
Does the transfer from the blank muxer Q for the muxer.+
−
+
−
@internalComponent+
−
@param aMuxer The Muxer to be added+
−
@return KErrInUse if there is already a Muxer on aMuxer's BTDevAddr, otherwise KErrNone+
−
*/   +
−
TInt CAvctpProtocol::AddTransport(CAvctpTransport& aTransport)+
−
	{+
−
	LOG_FUNC+
−
+
−
	LOG_MUXERS+
−
	+
−
	// The given muxer must have a valid remote addr to be on the protocol's Q+
−
	__ASSERT_DEBUG(aTransport.DevAddr() != TBTDevAddr(0), Panic(ENullTBTDevAddr));+
−
	+
−
	TInt ret = KErrNone;+
−
	CAvctpTransport* transport = FindTransport(aTransport.DevAddr());+
−
	if (transport)+
−
		{+
−
		ret = KErrInUse;+
−
		}+
−
	else+
−
		{+
−
		iTransports.AddFirst(aTransport);+
−
		}+
−
	+
−
	return ret;+
−
	}+
−
+
−
/** +
−
Removes a Muxer from their queue.+
−
+
−
@internalComponent+
−
@param aMuxer The Muxer to be removed+
−
*/   	 +
−
void CAvctpProtocol::RemoveTransport(CAvctpTransport& aTransport)+
−
	{+
−
	LOG_FUNC+
−
	LOG_MUXERS+
−
	  +
−
	aTransport.iQueLink.Deque(); // safe to Deque even if it's already been done+
−
	}+
−
+
−
/** Find the Muxer that is on this remote address.+
−
If no such Muxer exists, return NULL. Note this function doesn't transfer ownership.+
−
+
−
There should be no Muxer with a zero BTDevAddr on the Q+
−
@internalComponent+
−
@param aDevAddr The remote address to look for+
−
@return The Muxer connected on the specified remote address, if any, otherwise NULL.+
−
*/+
−
CAvctpTransport* CAvctpProtocol::FindTransport(const TBTDevAddr& aDevAddr)+
−
	{+
−
	LOG_FUNC+
−
+
−
	TDblQueIter<CAvctpTransport> iter(iTransports); +
−
	CAvctpTransport* transport = NULL;+
−
	CAvctpTransport* foundTransport = NULL;+
−
+
−
	while (iter)+
−
		{+
−
		transport = iter++;+
−
+
−
		if(transport->DevAddr() == aDevAddr)+
−
			{+
−
			foundTransport = transport;+
−
			break;+
−
			}+
−
		}+
−
+
−
	return foundTransport;+
−
	}+
−
+
−
CAvctpTransport* CAvctpProtocol::FindOrCreateTransport(const TBTDevAddr& aDevAddr, TInt aChannel, CServProviderBase* aL2CAPConSAP)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrNone;+
−
	CAvctpTransport* transport = FindTransport(aDevAddr);+
−
	+
−
	if (!transport)+
−
		{+
−
		// we create the transport but, in this case, we don't have PIDs attached and +
−
		// we cannot notify them+
−
		TRAP(err, transport = CAvctpTransport::NewL(*this));+
−
		if (err == KErrNone)+
−
			{+
−
			iTransports.AddLast(*transport);+
−
			}+
−
		+
−
		if (err == KErrNone)+
−
			{+
−
			if (aL2CAPConSAP)+
−
				{+
−
				err = transport->StartIncoming(aDevAddr, aL2CAPConSAP);+
−
				}+
−
			else+
−
				{+
−
				err = transport->Start(aDevAddr, KUndefinedPid);+
−
				}+
−
			+
−
			if (err == KErrNone)+
−
				{+
−
				// It's possible that the muxer had to synchronously delete itself+
−
				// and wasn't able to return a synchronous error.+
−
				// In this case the muxer will have removed itself from the protocol's Q+
−
				if (!FindTransport(aDevAddr))+
−
					{+
−
					transport = NULL; // since it's already dead+
−
					}+
−
				}+
−
			}+
−
		}+
−
	else if (aChannel == KAvctpSecondaryChannel)	// secondary channel+
−
		{+
−
		if (!transport->HasSecondChannel())+
−
			{+
−
			CServProviderBase* sap = NULL;+
−
			TRAP(err, sap = iLowerProtocol->NewSAPL(KSockSeqPacket));+
−
			if (err == KErrNone)+
−
				{+
−
				err = transport->AddSecondChannel(*sap);+
−
				if (err!=KErrNone)+
−
					{+
−
					delete sap;+
−
					sap = NULL;+
−
					}+
−
				}+
−
			}+
−
		}+
−
	return transport;+
−
	}+
−
+
−
void CAvctpProtocol::AwaitTransport(TUint16 aClientId, MSocketNotify& aControlSocket)+
−
	{+
−
	LOG_FUNC+
−
	AddClientItem(aClientId, aControlSocket);+
−
	}+
−
+
−
/**+
−
 It is submitted by the client saying it is happy to accept an incoming indication (for the primary channel).+
−
 When the client receive an attach indication it can decide to accept or refuse it. +
−
 If accepts it sends back an agree attachment ioctl that results in this call.+
−
 @param aClientId is the RAvctp pid value+
−
 @param aRemoteAddr is the remote device's address which has been connected+
−
 */+
−
TInt CAvctpProtocol::PrimaryChannelAgreeAttachment(TUint16 aClientId, const TBTDevAddr& aRemoteAddr)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrMuxerNotFound;+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	if (transport)+
−
		{+
−
		TClientItem* item = iClientItems.Find(aClientId);+
−
		__ASSERT_DEBUG(item, Panic(EAvctpClientNotFound));+
−
		err = transport->AddPrimaryChannelRef(item); // it returns KErrNone or KErrNoMemory+
−
		}+
−
	return err;+
−
	}+
−
+
−
/**+
−
 It is submitted by the client saying it is happy to accept an incoming indication (for the secondary channel).+
−
 When the client receive an attach indication it can decide to accept or refuse it. +
−
 If accepts it sends back an agree attachment ioctl that results in this call.+
−
 @param aClientId is the RAvctp pid value+
−
 @param aRemoteAddr is the remote device's address which has been connected+
−
 */+
−
TInt CAvctpProtocol::SecondaryChannelAgreeAttachment(TUint16 aClientId, const TBTDevAddr& aRemoteAddr)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrMuxerNotFound;+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	if (transport)+
−
		{+
−
		TClientItem* item = iClientItems.Find(aClientId);+
−
		__ASSERT_DEBUG(item, Panic(EAvctpClientNotFound));+
−
		transport->AddSecondaryChannelRef();+
−
		err = KErrNone;+
−
		}+
−
	return err;+
−
	}+
−
+
−
/**+
−
 If not already present it adds a TClientItem to the hashtable. Despite it was already present or not+
−
 it always calls AttachPrimaryChannel to update the MSocketNotify.+
−
 That is because once the TClientItem is added to the hastable it remains alive until the protocol +
−
 is alive. So we need to update the socket observer because it can be changed. i.e an RAvctp is created+
−
 and used, then it is destroyed, and created again. The "clientId" remains the same, but the +
−
 MSocketNofity passed through it is probably changed. The item will be found (already added to the+
−
 protocol hashtable) but the MSocketNotify& must be updated.+
−
 @param aClientId is the unique identifier of the RAvctp client+
−
 @param aNotify the socket observer for the ioctl messages (the primary channel CAvctpControlSAp)+
−
 */+
−
const TClientItem* CAvctpProtocol::AddClientItem(TUint16 aClientId, MSocketNotify& aNotify) // it doesn't pass the ownership+
−
	{+
−
	LOG_FUNC+
−
	TClientItem* pitem = iClientItems.Find(aClientId);+
−
	if (!pitem)+
−
		{+
−
		// pitem is null so, proceed creating it and inserting in the hashtable+
−
		TClientItem newItem(aClientId);+
−
		newItem.AttachPrimaryChannel(aNotify);+
−
		if (iClientItems.Insert(aClientId, newItem) == KErrNone)+
−
			{+
−
			// insertion succesfully, so we assign the inserted item to pitem+
−
			pitem = iClientItems.Find(aClientId);+
−
			}+
−
		// if an error occurred (out of memory) pitem is still null+
−
		}+
−
	+
−
	if (pitem)	// pitem can be null if the insertion failed +
−
		{+
−
		// we update aNotify anyway, so it is always updated to the correct reference+
−
		pitem->AttachPrimaryChannel(aNotify);+
−
		}+
−
	+
−
	return const_cast<const TClientItem*>(pitem);	// it doesn't pass the ownership+
−
	}+
−
+
−
const TClientItem* CAvctpProtocol::ClientItem(TUint16 aClientId) const // it doesn't pass ownership+
−
	{+
−
	LOG_FUNC+
−
	const TClientItem* pitem = iClientItems.Find(aClientId);+
−
	return pitem;+
−
	}+
−
+
−
void CAvctpProtocol::NotifyLinkUp(const TBTDevAddr& aAddr, TBool aIsSecondChannel)+
−
	{+
−
	LOG_FUNC+
−
	TControlIoctlMessage msg(ELinkUp, aAddr);+
−
	TPckgC<TControlIoctlMessage> pck(msg);+
−
	+
−
	THashMapIter<TInt, TClientItem> iter(iClientItems);+
−
	while(iter.NextKey())+
−
		{+
−
		TClientItem* pitem = iter.CurrentValue();+
−
		MSocketNotify* socket = aIsSecondChannel ? pitem->SecondaryChannel() : pitem->PrimaryChannel();+
−
+
−
		__DEBUG_ONLY+
−
			(+
−
			if (!aIsSecondChannel)+
−
				{+
−
				__ASSERT_DEBUG(socket, Panic(EAvctpInvalidChannelNotify));+
−
				}+
−
			)+
−
+
−
		if (socket)+
−
			{+
−
			socket->IoctlComplete(&pck);+
−
			}+
−
		}+
−
	}+
−
+
−
/** Gets a muxer for the given BT device address, using the L2CAP connection provided.+
−
@internalComponent+
−
*/	+
−
TInt CAvctpProtocol::StartProtocolListening()+
−
	{+
−
	LOG_FUNC+
−
+
−
	// because we do non-default security we override the base class+
−
	// and new the incoming listener ourselves+
−
	TRAPD(err, DoStartAvctpListeningL());+
−
	return err;+
−
	}+
−
	+
−
/** Gets a muxer for the given BT device address.+
−
	+
−
If it finds the muxer or successfully creates a new muxer, it returns +
−
with KErrNone and a valid pointer to the correct muxer. On a failure, +
−
it will return with a standard error, without a pointer to  a muxer.+
−
This flavour of GetMuxer is used when a muxer is being created in response +
−
to a local request to connect to a remote device (i.e. no existing +
−
L2CAP connection exists) or when someone just wants a muxer on the given +
−
address whether or not one exists.+
−
+
−
Note that because a synchronous error could occur during the Start call, +
−
aMuxer might be NULL at the end of this function. Note thought this+
−
depends on whether aMuxer was able to asynchronously delete itself or not.+
−
Note that there could then be two error paths, one via the muxer sending+
−
a ConnectComplete (with error) & the return from this function. If this is+
−
the case, KErrSynchronousMuxerError will be returned which should be voided+
−
so that the client doesn't get two errors.+
−
+
−
@internalComponent+
−
@param aRemoteAddr The remote address for which we want a muxer+
−
@param aMuxer A muxer will be created by this function if one doesn't exist and a connection attempt start. +
−
			  If there is an existing muxer it is returned aMuxer will be not be owned by the caller+
−
@param aLinksMgr a possible control client for the newly created muxer+
−
@return KErrNone if the muxer is successfully returned, +
−
		KErrSynchronousMuxerError if the muxer failed immediately on the address given, or+
−
		KErrNoMemory or+
−
		any other error code from CAvctpTransport::NewL+
−
*/ +
−
TInt CAvctpProtocol::ProvideTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId,+
−
									  MSocketNotify& aControlSocket)+
−
	{+
−
	LOG_FUNC+
−
	IF_FLOGGING+
−
		(+
−
		TBuf<KBTAddressLength> address;+
−
		aRemoteAddr.GetReadable(address);+
−
		)+
−
+
−
	LOG1(_L("from BT Device 0x%S"), &address);+
−
	+
−
	TInt err = KErrNone;+
−
	+
−
	// first of all I add the Client Id to my list and get a pointer to it.+
−
	const TClientItem* item = AddClientItem(aClientId, aControlSocket);+
−
	+
−
	if (item)	// we were able to allocate the memory for it+
−
		{+
−
		CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	+
−
		if (!transport)+
−
			{+
−
			TRAP(err,transport = CAvctpTransport::NewL(*this));+
−
			if (err == KErrNone)+
−
				{+
−
				err = transport->AddPrimaryChannelRef(item);+
−
				if (err == KErrNone)+
−
					{+
−
					iTransports.AddLast(*transport);+
−
					}+
−
				else+
−
					{+
−
					// it is safe to call it on a non-attached clientId and it is the only+
−
					// way we have to ask the transport to destroying itself+
−
					// as we just created the transport we know calling this method will destroy it+
−
					transport->RemovePrimaryChannelRef(aClientId);+
−
					}+
−
				}+
−
			}+
−
		else+
−
			{+
−
			err = transport->AddPrimaryChannelRef(item);+
−
			// in this case we already had the transport, probably with some clients attached.+
−
			// we can't destroy it, and it is working for the attached clients. So, we simply+
−
			// return an error to the client is asking to be attached.+
−
			}+
−
		+
−
		if (err == KErrNone)+
−
			{+
−
			err = transport->Start(aRemoteAddr, aClientId);+
−
	+
−
			if (err == KErrNone)+
−
				{+
−
				// It's possible that the muxer had to synchronously delete itself+
−
				// and wasn't able to return a synchronous error (e.g. if the client+
−
				// tries to connect to itself and the async deletion attempt OOMs)+
−
				// In this case the muxer will have removed itself from the protocol's Q+
−
				if (!FindTransport(aRemoteAddr))+
−
					{+
−
					transport = NULL; // since it's already dead+
−
					err = KErrSynchronousMuxerError;+
−
					}+
−
				}+
−
			}+
−
		}+
−
	else+
−
		{+
−
		err = KErrNoMemory;+
−
		}+
−
	+
−
	return err;+
−
	}+
−
+
−
TInt CAvctpProtocol::ActiveExtendTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket)+
−
	{+
−
	LOG_FUNC+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	TInt err = KErrMuxerNotFound;+
−
	if (transport)+
−
		{+
−
		if (!transport->HasSecondChannel())+
−
			{+
−
			// get a new SAP and ask transport to connect it up+
−
			CServProviderBase* sap = NULL;+
−
			TRAP(err, sap = iLowerProtocol->NewSAPL(KSockSeqPacket));+
−
			err = transport->AddSecondChannel(*sap);+
−
			if (err!=KErrNone)+
−
				{+
−
				delete sap;+
−
				sap = NULL;+
−
				}+
−
			else+
−
				{+
−
				transport->SetSecondChannelCtrlNotify(aClientId, aSecondChannelControlSocket);+
−
				transport->AddSecondaryChannelRef();+
−
				}+
−
			}+
−
		else+
−
			{+
−
			transport->SetSecondChannelCtrlNotify(aClientId, aSecondChannelControlSocket);+
−
			transport->AddSecondaryChannelRef();+
−
			transport->NotifyAttachConfirm(aClientId, KErrNone, ETrue);+
−
			}+
−
		}+
−
	return err;+
−
	}+
−
+
−
void CAvctpProtocol::SetSecondChannelCtrlNotify(TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket)+
−
	{+
−
	LOG_FUNC+
−
	TClientItem* item = iClientItems.Find(aClientId);+
−
	__ASSERT_DEBUG(item, Panic(EAvctpClientNotFound));+
−
	item->AttachSecondaryChannel(aSecondChannelControlSocket);+
−
	}+
−
+
−
void CAvctpProtocol::AwaitForExtendedTransport(TUint16 aClientId, MSocketNotify& aSecondChannelControlSocket)+
−
	{+
−
	LOG_FUNC+
−
	SetSecondChannelCtrlNotify(aClientId, aSecondChannelControlSocket);+
−
	}+
−
+
−
void CAvctpProtocol::PrimaryChannelRefuseAttach(const TBTDevAddr& aRemoteAddr, TUint16 aClientId)+
−
	{+
−
	LOG_FUNC+
−
	+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	+
−
	// when this method is called it means the client refused to be attached to the transport+
−
	// and didn't call the AgreeAttachment. It means that we don't have the TClientItem attached to+
−
	// the transport.+
−
	// However we call transport->RemovePrimaryChannelRef anyway. It is safe to call it even if the+
−
	// aClientId item is not attached, and it does the reference count control so that if there+
−
	// are no more clients attached it destroys the transport.+
−
	// this method can also be called on the PrimaryChannelCancelAttach invocation client side.+
−
	// In this case the client will be found and removed+
−
	if(transport)+
−
		{+
−
		// NOTE: if transport has no more clients attached it deletes itself.+
−
		// so, don't rely on transport after this call because it could have been deleted+
−
		transport->RemovePrimaryChannelRef(aClientId);+
−
		}+
−
	}+
−
+
−
void CAvctpProtocol::SecondaryChannelRefuseAttach(const TBTDevAddr& aRemoteAddr, TUint16 aClientId)+
−
	{+
−
	LOG_FUNC+
−
+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	+
−
	// when this method is called it means the client refused to be attached to the transport+
−
	// and didn't call the AgreeAttachment. It means that we don't have the TClientItem attached to+
−
	// the transport.+
−
	// However we call transport->RemovePrimaryChannelRef anyway. It is safe to call it even if the+
−
	// aClientId item is not attached, and it does the reference count control so that if there+
−
	// are no more clients attached it destroys the transport.+
−
	+
−
	if(transport)+
−
		{+
−
		// we must call AddSecondaryChannelRef() first, that increments the reference count+
−
		// because then we call RemoveSecondaryChannelRef() that decrements it.+
−
		// we want to call RemoveSecondaryChannelRef() because it manages the zero reference which+
−
		// drives the secondary l2cap channel destruction +
−
		transport->AddSecondaryChannelRef();+
−
		transport->RemoveSecondaryChannelRef(aClientId);+
−
		}+
−
	}+
−
+
−
TInt CAvctpProtocol::GetChannelMtu(TInt aChannel, const TBTDevAddr& aAddr, TInt& aMtu)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrNotReady;+
−
	CAvctpTransport* t = FindTransport(aAddr);+
−
	if(t)+
−
		{+
−
		err = t->GetChannelMtu(aChannel, aMtu);+
−
		}+
−
	return err;+
−
	}+
−
+
−
TInt CAvctpProtocol::ReleaseTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrMuxerNotFound;+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	if(transport)+
−
		{+
−
		err = KErrNone;+
−
		transport->NotifyDetachConfirm(aClientId, err);+
−
		// NOTE: if there are no more pid attached to the transport it will delete itself.+
−
		// so, don't rely on the transport after this call because it could have been deleted+
−
		transport->RemovePrimaryChannelRef(aClientId);+
−
		}+
−
	return err;+
−
	}+
−
+
−
TInt CAvctpProtocol::ReleaseExtendedTransport(const TBTDevAddr& aRemoteAddr, TUint16 aClientId)+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrMuxerNotFound;+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	if(transport)+
−
		{+
−
		err = KErrNone;+
−
		transport->NotifyDetachConfirm(aClientId, err, ETrue);+
−
		transport->RemoveSecondaryChannelRef(aClientId);+
−
		}+
−
	return err;+
−
	}+
−
+
−
void CAvctpProtocol::PrimaryChannelIncomingRemoteDisconnection(const TBTDevAddr& aRemoteAddr)+
−
	{+
−
	LOG_FUNC+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
	if(transport)+
−
		{+
−
		// the secondary channel, if present, has been already destroyed.+
−
		transport->NotifyLinkDown(aRemoteAddr, KAvctpPrimaryChannel);	// we are destroying the transport +
−
		}+
−
	}+
−
+
−
/**+
−
Gets a muxer for the given BT device address, using the L2CAP connection provided.+
−
+
−
If it is found that a muxer for the specified BT device already exists, +
−
KErrAlreadyExists will be returned. If a new muxer is successfully created, +
−
KErrNone will be returned along with a valid pointer to the correct muxer in aMuxer +
−
+
−
This flavour of GetMuxer is used when a muxer is being created in response to a +
−
remote request to connect to the local device (i.e. an L2CAP SAP has been created +
−
due to an incoming connection).+
−
+
−
Note that because a synchronous error could occur during the Start call, +
−
aMuxer might be NULL at the end of this function. Note thought this+
−
depends on whether aMuxer was able to asynchronously delete itself or not.+
−
Note that there could then be two error paths, one via the muxer sending+
−
a ConnectComplete (with error) & the return from this function. If this is+
−
the case, KErrSynchronousMuxerError will be returned which should be voided+
−
so that the client doesn't get two errors.+
−
+
−
@internalComponent+
−
@param aRemoteAddr The remote address for which we want a muxer+
−
@param aL2CAPConSAP This is a non null, L2CAP sap for the incoming connection from aRemoteAddr+
−
@param aMuxer A muxer created by this function to hold aL2CAPConSAP (assuming there wasn't one already for aRemoteAddr). aMuxer will be not be owned by the caller+
−
@return KErrNone if the muxer is successfully returned, +
−
		KErrSynchronousMuxerError if the muxer failed immediately on the address give, or+
−
		any other error code from CAvctpTransport::NewL+
−
*/+
−
TInt CAvctpProtocol::AttachInboundConnectionToTransport(const TBTDevAddr& aRemoteAddr,+
−
														CServProviderBase* aL2CAPConSAP)+
−
	{+
−
	LOG_FUNC+
−
	__DEBUG_ONLY+
−
		(+
−
		TBuf<KBTAddressLength> address;+
−
		aRemoteAddr.GetReadable(address);+
−
		LOG1(_L("from BT Device 0x%S"), &address);+
−
		+
−
		//	Check that the device address and the device of the L2CAP remote address match!!+
−
		TBTSockAddr addr;+
−
		aL2CAPConSAP->RemName(addr);+
−
		__ASSERT_DEBUG(addr.BTAddr()==aRemoteAddr,Panic(EMismatchedAddressAndSap));+
−
		)+
−
+
−
	TL2CAPPort localPSM;+
−
	TPckg<TL2CAPPort> localPSMBuf(localPSM);+
−
	TInt err = aL2CAPConSAP->GetOption(KSolBtL2CAP, KL2CAPLocalPSM, localPSMBuf);+
−
+
−
	__ASSERT_DEBUG(err == KErrNone, Panic(EGetOptionError));+
−
	+
−
	//first try to find the transport with a given address: if it exists then this inbound link could be the second channel+
−
	CAvctpTransport* transport = FindTransport(aRemoteAddr);+
−
+
−
	if (transport)+
−
		{+
−
		// ok so try finding a listener transport for this link (which should be control)+
−
		if (localPSM == KAvctpSecondChannelPSM)+
−
			{+
−
			transport->AddSecondChannel(*aL2CAPConSAP);+
−
			}+
−
		else+
−
			{+
−
			// remote was being daft+
−
			return KErrGeneral;+
−
			}+
−
		}+
−
	else+
−
		{+
−
		+
−
		if (localPSM != KAVCTP)+
−
			{+
−
			return KErrGeneral; // the other type of daft remote+
−
			}+
−
				+
−
		// else remote sensibly connected first channel to the right PSM, for which we should have a listening transport on bdaddr==0+
−
		transport = FindOrCreateTransport(aRemoteAddr, KAvctpPrimaryChannel, aL2CAPConSAP); +
−
		if (transport)+
−
			{+
−
			// It's possible that the muxer had to synchronously delete itself+
−
			// and wasn't able to return a synchronous error (e.g. if the client+
−
			// tries to connect to itself and the async deletion attempt OOMs)+
−
			// In this case the muxer will have removed itself from the protocol's Q+
−
			if (!FindTransport(aRemoteAddr))+
−
				{+
−
				transport = NULL; // since it's already dead+
−
				err = KErrSynchronousMuxerError;+
−
				}+
−
			else+
−
				{	// notify link up+
−
				NotifyLinkUp(aRemoteAddr, EFalse);+
−
				}+
−
			}+
−
		else+
−
			{+
−
			err = KErrNotReady;+
−
			}+
−
		}+
−
+
−
	return err;+
−
	}+
−
+
−
/** +
−
Provide interface to class to send AVCTP SDUs (if one for the needed address exists+
−
*/+
−
MAvctpSDUSender* CAvctpProtocol::GetSDUSender(const TBTDevAddr& aRemoteAddr, TInt aChannel)+
−
	{+
−
	LOG_FUNC+
−
+
−
	CAvctpTransport* transport = FindOrCreateTransport(aRemoteAddr, aChannel);+
−
	return transport ? &static_cast<MAvctpSDUSender&>(transport->PacketMgr()) : NULL;+
−
	}+
−
+
−
/**+
−
Check to see if we're still needed.  If not, Q a delayed delete.+
−
+
−
  @internalComponent+
−
*/+
−
void CAvctpProtocol::CheckForIdle()+
−
	{+
−
	LOG_FUNC+
−
+
−
	if (IsIdle())+
−
		{+
−
		QueIdleTimer();+
−
		}+
−
	}+
−
+
−
/** +
−
Called to check whether we can close down. I.e. are there any clients remaining on the+
−
other side of Esock.+
−
+
−
We could be idle even if there are Avctp muxers alive since Esock won't know about these+
−
+
−
@internalComponent+
−
@return ETrue if the protocol can close, EFalse if not+
−
*/+
−
TBool CAvctpProtocol::IsIdle()+
−
	{+
−
	LOG_FUNC+
−
	LOG_SAPS+
−
	+
−
	return (iClosePending && +
−
			iSaps.IsEmpty());+
−
	}+
−
	+
−
/**+
−
Queues the idle timer if necessary+
−
+
−
  @internalComponent+
−
*/+
−
void CAvctpProtocol::QueIdleTimer()+
−
	{+
−
	LOG_FUNC+
−
+
−
	if (!iIdleTimerQueued)+
−
		{+
−
		LOG(_L("Queued idle timer"));+
−
+
−
		iIdleTimerQueued = ETrue;+
−
		BTSocketTimer::Queue(KProtocolIdleTimeout, iIdleTimerEntry);+
−
		}+
−
	}+
−
+
−
/**+
−
Deques idle timer if necessary+
−
+
−
  @internalComponent+
−
*/+
−
void CAvctpProtocol::DequeIdleTimer()+
−
	{+
−
	LOG_FUNC+
−
+
−
	if (iIdleTimerQueued)+
−
		{+
−
		LOG(_L("Dequeued idle timer"));+
−
+
−
		iIdleTimerQueued = EFalse;+
−
		BTSocketTimer::Remove(iIdleTimerEntry);+
−
		}+
−
	}+
−
+
−
	+
−
/** Asynchronous callback function.+
−
+
−
We check if should close then close.+
−
+
−
@internalComponent+
−
@param aProtocol The protocol object+
−
@return EFalse to indicate the callback does not need to be reissued+
−
*/+
−
TInt CAvctpProtocol::TryToClose(TAny* aProtocol)+
−
	{+
−
	LOG_STATIC_FUNC+
−
+
−
	CAvctpProtocol* protocol	= static_cast<CAvctpProtocol*>(aProtocol);+
−
	protocol->iIdleTimerQueued	= EFalse;+
−
	__ASSERT_DEBUG(protocol->IsIdle(), Panic(EIdleTimeoutWhenNotIdle));+
−
	protocol->CanClose();+
−
+
−
	return EFalse; // don't try to callback again+
−
	}+
−
+
−
TInt CAvctpProtocol::IpidAsyncCallBack(TAny* aProtocol)+
−
	{+
−
	LOG_STATIC_FUNC+
−
+
−
	__ASSERT_DEBUG(aProtocol, Panic(ENullAvctpProtocol));+
−
	+
−
	CAvctpProtocol& protocol = *static_cast<CAvctpProtocol*>(aProtocol);+
−
+
−
	TDblQueIter<HAvctpOutgoingSdu> iter(protocol.iIpidResponses);+
−
	HAvctpOutgoingSdu* sdu = NULL;+
−
	MAvctpSDUSender* sender = NULL;+
−
	+
−
	TInt err;+
−
	+
−
	while(iter)+
−
		{+
−
		sdu = iter++;+
−
		sender = protocol.GetSDUSender(sdu->BTAddr(), sdu->Channel());+
−
+
−
		if (sender)+
−
			{+
−
			LOG1(_L("Attempt to write IPID response 0x%08x in IpidAsyncCallBack"), &sdu);+
−
			if ((err = sender->WriteIpid(sdu)) != KErrNone)+
−
				{+
−
				if (err == KErrRemoteSentTooManyIpidSdus)+
−
					{+
−
					CAvctpTransport* transport = protocol.FindTransport(sdu->BTAddr());+
−
					if (transport)+
−
						{+
−
						transport->Shutdown(KErrRemoteSentTooManyIpidSdus);+
−
						}+
−
					}+
−
				else if (err == KErrMuxerBlocked)+
−
					{+
−
					//got blocked+
−
					//it will be called again asyncronously+
−
					}+
−
				}+
−
			// else send completed and sdu ownership transferred to the sender+
−
			}+
−
		else+
−
			{+
−
			// can't send the IPID since we don't have a data path to send it over+
−
			delete sdu; // will deque the sdu+
−
			}+
−
		}	+
−
	return EFalse;	+
−
	}+
−
	+
−
#ifdef __FLOG_ACTIVE	+
−
void CAvctpProtocol::LogSaps()+
−
	{+
−
	LOG_FUNC+
−
	TDblQueIter<CAvctpSap> iter(iSaps);+
−
	CAvctpSap* sap = NULL;+
−
	while (iter)+
−
		{+
−
		sap = iter++;+
−
		LOG2(_L("0x%08x is a sap on PID %d"), sap, sap->Pid());+
−
		}	+
−
	}+
−
	+
−
void CAvctpProtocol::LogMuxers()+
−
	{+
−
	LOG_FUNC+
−
	TDblQueIter<CAvctpTransport> iter(iTransports);+
−
	CAvctpTransport* transport = NULL;+
−
	TBuf<KBTAddressLength> address;+
−
	while (iter)+
−
		{+
−
		transport= iter++;+
−
		transport->DevAddr().GetReadable(address);+
−
		LOG2(_L("0x%08x is a transport on BT Device %S"), transport, &address);+
−
		}	+
−
	}+
−
+
−
#endif+
−
+
−
// TClientItem+
−
+
−
TClientItem::TClientItem(TUint16 aClientId) : +
−
	iClientId(aClientId),+
−
	iPrimaryChannel(NULL),+
−
	iSecondaryChannel(NULL),+
−
	iIsSecondaryChannelAttached(EFalse),+
−
	iRefCount(0)+
−
	{+
−
	LOG_FUNC+
−
	}+
−
+
−
void TClientItem::AttachPrimaryChannel(MSocketNotify& aNotify)+
−
	{+
−
	LOG_FUNC+
−
	iPrimaryChannel = &aNotify;+
−
	iIsSecondaryChannelAttached = EFalse;+
−
	}+
−
+
−
void TClientItem::AttachSecondaryChannel(MSocketNotify& aNotify)+
−
	{+
−
	LOG_FUNC+
−
	iSecondaryChannel = &aNotify;+
−
	iIsSecondaryChannelAttached = ETrue;+
−
	}+
−
+
−
TUint16 TClientItem::ClientId() const+
−
	{+
−
	LOG_FUNC+
−
	return iClientId;+
−
	}+
−
+
−
MSocketNotify* TClientItem::PrimaryChannel() const+
−
	{+
−
	LOG_FUNC+
−
	return iPrimaryChannel;+
−
	}+
−
+
−
MSocketNotify* TClientItem::SecondaryChannel() const+
−
	{+
−
	LOG_FUNC+
−
	return iSecondaryChannel;+
−
	}+
−
+
−
TBool TClientItem::IsSecondaryChannelAttached() const+
−
	{+
−
	LOG_FUNC+
−
	return iIsSecondaryChannelAttached;+
−
	}+
−
+
−
void TClientItem::DetachSecondaryChannel()+
−
	{+
−
	LOG_FUNC+
−
	iSecondaryChannel = NULL;+
−
	iIsSecondaryChannelAttached = EFalse;+
−
	}+
−