// 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:+
−
// Implements the code for AVDTP SAP+
−
// The SAP is really only a conduit to the socket+
−
// The sessions implement the meaningful protocol stuff+
−
// +
−
//+
−
+
−
/**+
−
 @file+
−
 @internalComponent+
−
*/+
−
+
−
#include <bluetooth/logger.h>+
−
#include "avdtpsap.h"+
−
#include "avdtp.h"+
−
#include "avdtpStream.h"+
−
#include "avdtpMediaSession.h"+
−
#include "avdtpReportingSession.h"+
−
#include "avdtpRecoverySession.h"+
−
#include "avdtpSignallingSession.h"+
−
#include "avdtputil.h"+
−
+
−
#ifdef __FLOG_ACTIVE+
−
_LIT8(KLogComponent, LOG_COMPONENT_AVDTP);+
−
#endif+
−
+
−
CAvdtpSAP* CAvdtpSAP::NewL(CAvdtpProtocol& aProt)+
−
/**+
−
Static AVDTP SAP factory function+
−
+
−
  @internalComponent+
−
  @leave KErrNoMemory if the SAP object could not be allocated+
−
  @param aProt protocol object+
−
  @return A pointer to the new SAP+
−
*/+
−
	{+
−
	LOG_STATIC_FUNC+
−
	// Create and return a new SAP+
−
	CAvdtpSAP* sap = new(ELeave) CAvdtpSAP(aProt);+
−
	CleanupStack::PushL(sap);+
−
	sap->ConstructL();+
−
	CleanupStack::Pop(sap);+
−
	return sap;+
−
	}+
−
+
−
void CAvdtpSAP::ConstructL()+
−
/**+
−
Second-phase construction of a SAP+
−
+
−
Set up the async. callback.+
−
+
−
  @internalComponent+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	CBluetoothSAP::ConstructL();+
−
	}+
−
+
−
CAvdtpSAP::CAvdtpSAP(CAvdtpProtocol& aProtocol)+
−
	: CBluetoothSAP(aProtocol.SecMan(), aProtocol.CodMan()),+
−
	  iProtocol(aProtocol),+
−
	  iIndicationQueue(_FOFF(HQueuedAvdtpIndication, iLink))+
−
/**+
−
Constructor for an AVDTP SAP+
−
+
−
  @internalComponent+
−
  @param aProt The AVDTP protocol object+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	}+
−
+
−
+
−
CAvdtpSAP::~CAvdtpSAP()+
−
/**+
−
Called when ESock deletes the SAP, when user app calls RSocket::Close()+
−
+
−
  @internalAll+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	// clear (possible) indication queue+
−
	TSglQueIter<HQueuedAvdtpIndication> iter(iIndicationQueue);+
−
	while (iter)+
−
		{+
−
		delete iter++;+
−
		}+
−
	// at this point we don't support idling sessions+
−
	delete iSession;+
−
	}+
−
+
−
/**+
−
SetLocalName is here used to specify the *local* session to which this SAP will become attached+
−
As a part of this the SAP tries to tell the session of the stream with which it'll be associated+
−
The stream lookup key is the *remote* SEID of the stream (streams are always searched for by this SEID)+
−
This gives rise to an interesting API, but the intended client is only GAVDP+
−
(via ESOCK).+
−
So: the parts of AVDTPSockAddr for passive sides are+
−
BTAddr - not used+
−
SEID - specify the *remote* SEID+
−
Session - specify the *local* session type+
−
+
−
This *could* change if needs be, so that a conversion from local to remote is performed here+
−
but would be fiddly and break the ease of always looking for a stream by its remote SEID+
−
*/+
−
TInt CAvdtpSAP::SetLocalName(TSockAddr& aAddr)+
−
	{+
−
	LOG_FUNC+
−
	// this determines our session+
−
	TRAPD(err, UpdateSessionL(TAvdtpSockAddr::Cast(aAddr)));+
−
	return err;+
−
	}+
−
+
−
void CAvdtpSAP::LocalName(TSockAddr& aAddr) const+
−
/**+
−
Read the Local Name into aAddr.+
−
+
−
+
−
  @internalAll+
−
  @param aAddr The address to read into+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	if (iSession)+
−
		{+
−
		TAvdtpSockAddr avAddr = TAvdtpSockAddr::Cast(aAddr);+
−
		iSession->LocalName(avAddr);+
−
		aAddr = avAddr;+
−
		}+
−
	}+
−
+
−
void CAvdtpSAP::RemName(TSockAddr& aAddr) const+
−
/**+
−
Read the remote name into aAddr.+
−
+
−
  @internalAll+
−
  @param aAddr The address to read into+
−
*/+
−
	{+
−
	// Return the remote name+
−
	LOG_FUNC+
−
	if (iSession)+
−
		{+
−
		TAvdtpSockAddr avAddr = TAvdtpSockAddr::Cast(aAddr);+
−
		iSession->RemName(avAddr);+
−
		aAddr = avAddr;+
−
		}+
−
	}+
−
+
−
/**+
−
SetRemName is here used to specify the *remote* BTAddr, SEID and session to which this SAP will become attached+
−
As a part of this the SAP tries to tell the session of the stream with which it'll be associated+
−
The stream lookup key is the *remote* SEID of the stream (streams are always searched for by this SEID)+
−
This gives rise to an interesting API, but the intended client is only GAVDP+
−
(via ESOCK).+
−
So: the parts of AVDTPSockAddr for active sides are+
−
BTAddr - that of remote+
−
SEID - the remote SEID+
−
Session - specify the local/remote session type+
−
*/+
−
TInt CAvdtpSAP::SetRemName(TSockAddr& aAddr)+
−
	{+
−
	LOG_FUNC+
−
	TRAPD(err, UpdateSessionL(TAvdtpSockAddr::Cast(aAddr)));+
−
	return err;+
−
	}+
−
	+
−
+
−
void CAvdtpSAP::UpdateSessionL(const TAvdtpSockAddr& aAddr)	+
−
	{+
−
	LOG_FUNC+
−
	+
−
	// do we want to support swapping session type? for now no+
−
	if (!iSession)+
−
		{+
−
		// need to get one+
−
		// get to see our TransportSession here+
−
		TAvdtpTransportSessionType s = aAddr.Session();+
−
		CAVStream* stream = NULL; //non-owned+
−
		if (s!=ESignalling)+
−
			{+
−
			stream = iProtocol.FindStream(aAddr);+
−
			if (!stream)+
−
				{+
−
				User::Leave(KErrUnknown);+
−
				}+
−
			}+
−
			+
−
		switch (s)+
−
			{+
−
			case EMedia:+
−
				iSession = CMediaSession::NewL(iProtocol, *this, *stream);+
−
				break;+
−
			case EReporting:+
−
				iSession = CReportingSession::NewL(iProtocol, *this, *stream);+
−
				break;+
−
			case ERecovery:+
−
				iSession = CRecoverySession::NewL(iProtocol, *this, *stream);+
−
				break;+
−
			case ESignalling:+
−
				iSession = CSignallingSession::NewL(iProtocol, *this);+
−
				break;+
−
			default:+
−
				User::Leave(KErrArgument);+
−
			}+
−
		}+
−
		+
−
	// update the device address (the session may go from passive to active)+
−
	iSession->SetRemoteAddress(aAddr.BTAddr());	// session cannot change type+
−
	}+
−
+
−
void CAvdtpSAP::AutoBind()+
−
/**+
−
Auto bind from ESock.+
−
+
−
@internalComponent+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	}+
−
+
−
TInt CAvdtpSAP::GetOption(TUint aLevel, TUint aName, TDes8& aOption) const+
−
/**+
−
Get a socket option.+
−
+
−
Currently, just for getting the results of an AVDTP operation to user-land+
−
+
−
+
−
  @internalAll+
−
  @param aLevel The socket option level+
−
  @param aName The socket option name+
−
  @param aOption The socket option data+
−
*/+
−
	{+
−
	// Do a getopt+
−
	LOG_FUNC+
−
	return iSession ? iSession->GetOption(aLevel, aName, aOption) : KErrNotReady;+
−
	}+
−
+
−
	+
−
TInt CAvdtpSAP::SAPSetOption(TUint aLevel, TUint aName, const TDesC8& aOption)+
−
/**+
−
Set a socket option.+
−
+
−
  @internalAll+
−
  @param aLevel The socket option level+
−
  @param aName The socket option name+
−
  @param aOption The socket option data+
−
*/+
−
	{+
−
	// Perform a setopt+
−
	LOG_FUNC+
−
	TInt ret = KErrNotSupported;+
−
	// if this is not an internal option then pass to the session+
−
	if (aLevel == KSolBtAVDTPInternal)+
−
		{+
−
		switch (aName)+
−
			{				+
−
			case ESetAsSecondarySAP:+
−
				{+
−
				// assert we haven't had an address set+
−
				__ASSERT_DEBUG(iRemoteDev == TBTDevAddr(0), Panic(ERGAVDPSequenceFailure));+
−
				// this SAP does not have a session, nor an addr+
−
				// tell protocol to look after us until a primary collects us+
−
				iProtocol.AddSecondarySAP(*this);+
−
				iIsSecondary = ETrue;+
−
				ret = KErrNone;		+
−
				}+
−
			break;+
−
			case EBindToSecondarySAP:+
−
				{+
−
				// form binding to secondary sap+
−
				iSecondarySAP = iProtocol.GetSecondarySAP();+
−
				__ASSERT_DEBUG(iSecondarySAP, Panic(ERGAVDPSequenceFailure));+
−
				ret = KErrNone;+
−
				}+
−
			break;+
−
			}+
−
		// default covered by ret.+
−
		}+
−
	else+
−
		{+
−
		ret = iSession ? iSession->SetOption(aLevel, aName, aOption) : KErrNotReady;+
−
		}+
−
	return ret;+
−
	}+
−
+
−
+
−
// Startup/Shutdown+
−
+
−
void CAvdtpSAP::ActiveOpen()+
−
/**+
−
Active open an AVDTP socket...+
−
+
−
  @internalAll+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	TInt err = KErrNotReady;+
−
	+
−
	if (iSession)+
−
		{+
−
		err = iSession->ActiveOpen();+
−
		}+
−
		+
−
	if (err!=KErrNone)+
−
		{+
−
		iSocket->Error(err, MSocketNotify::EErrorConnect);+
−
		}+
−
	}+
−
+
−
void CAvdtpSAP::ActiveOpen(const TDesC8& /*aConnectionData*/)+
−
/**+
−
Active open an AVDTP socket (data overload)...+
−
+
−
  @internalAll+
−
  @param aConnectionData Data to send on connection+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	Error(KErrNotSupported);+
−
	}+
−
+
−
TInt CAvdtpSAP::PassiveOpen(TUint /*aQueSize*/)+
−
/**+
−
Passive open an AVDTP socket...+
−
NOT SUPPORTED.+
−
@see CLogicalChannelFactory which acquires inbound logical channels and is aware of their sequence+
−
@see Transport sessions which are ActiveOpened to "find" passive bearers+
−
@internalAll+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	return KErrNotSupported;+
−
	}+
−
+
−
TInt CAvdtpSAP::PassiveOpen(TUint /*aQueSize*/, const TDesC8& /*aConnectionData*/)+
−
/**+
−
Passive open an AVDTP socket...+
−
NOT SUPPORTED.+
−
@see CLogicalChannelFactory which acquires inbound logical channels and is aware of their sequence+
−
@see Transport sessions which are ActiveOpened to "find" passive bearers+
−
@internalAll+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	return KErrNotSupported;+
−
	}+
−
+
−
void CAvdtpSAP::Start()+
−
/**+
−
@internalAll+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	// sessions do not need to be forwarded this at present+
−
	// (primarily as no "usual" passive connections)+
−
	}+
−
+
−
void CAvdtpSAP::Shutdown(TCloseType aCloseType)+
−
/**+
−
Close the SAP down.  We don't declare support for Normal shutdown, but for future use+
−
we pass onto transport session.+
−
+
−
@internalAll+
−
@param aCloseType How fast we're going down+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	if (iSession)+
−
		{+
−
		aCloseType==ENormal ? iSession->Shutdown() : iSession->FastShutdown();+
−
		}+
−
		+
−
	// fast shutdown will delete us after this unwinds+
−
	}+
−
+
−
void CAvdtpSAP::Shutdown(TCloseType aCloseType, const TDesC8& /*aDisconnectionData*/)+
−
/**+
−
Close the SAP down (data overload).+
−
+
−
We don't declare support for Normal or data shutdowns, but for future use+
−
we pass onto transport session.+
−
+
−
@internalAll+
−
@param aCloseType How fast we're going down+
−
@param aDisconnectionData Data to send on disconnect+
−
*/+
−
	{+
−
	// this one's an error+
−
	LOG_FUNC+
−
	Shutdown(aCloseType);+
−
	}+
−
+
−
// Data flow & ioctl+
−
+
−
TInt CAvdtpSAP::Write(RMBufChain& aData, TUint aOptions, TSockAddr* aAddr)+
−
	{+
−
	LOG_FUNC+
−
+
−
	if (iSession)+
−
		{+
−
		return iSession->Send(aData, aOptions, aAddr);+
−
		}+
−
	else+
−
		{+
−
		iSocket->Error(KErrNotReady, MSocketNotify::EErrorSend);+
−
		return 0;+
−
		}+
−
	}+
−
+
−
TInt CAvdtpSAP::GetData(RMBufChain& aData, TUint /*aLength*/, TUint /*aOptions*/, TSockAddr* /*aAddr*/)+
−
	{+
−
	LOG_FUNC+
−
	return iSession ? iSession->GetData(aData) : KErrNotSupported;+
−
	}+
−
+
−
+
−
void CAvdtpSAP::Ioctl(TUint aLevel, TUint aName, TDes8* aOption)+
−
/**+
−
Perform an Ioctl.+
−
Primary SAPs ask the session to actually perform the ioctl.+
−
Secondary SAPs do the ioctl themselves.+
−
+
−
Perform ioctl-guarding (one at a time stuff) then forward to session+
−
@internalAll+
−
@param aLevel The Ioctl level+
−
@param aName The Ioctl name+
−
@param aOption The Ioctl data+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	if (!iIsSecondary)+
−
		{+
−
		// we are a *primary* SAP, and should forward to our session+
−
		if (!iSession)+
−
			{+
−
			iSocket->Error(KErrDisconnected, MSocketNotify::EErrorIoctl);+
−
			}+
−
		else+
−
			{+
−
			iIoctlLevel = aLevel;+
−
			iIoctlName = aName;+
−
			iSession->Ioctl(aLevel, aName, aOption);+
−
			}+
−
		}+
−
	else+
−
		{+
−
		if (aLevel == KSolBtAVDTPSignalling)+
−
			{+
−
			// we are a secondary sap, so just deal with ioctls ourselves+
−
			iIoctlLevel = aLevel;+
−
			iIoctlName = aName;+
−
+
−
			switch (aName)+
−
				{+
−
				case EAwaitIndication:+
−
					{+
−
					// if there is one on the queue then deliver+
−
					if (!iIndicationQueue.IsEmpty())+
−
						{+
−
						HQueuedAvdtpIndication* ind = iIndicationQueue.First();+
−
						iIndicationQueue.Remove(*ind);+
−
						ServiceComplete(ind->Indication());+
−
						delete ind;+
−
						}+
−
					}+
−
				break;+
−
				default:+
−
					Error(KErrNotSupported);				+
−
				}+
−
			}+
−
		}+
−
	}+
−
	+
−
	+
−
+
−
void CAvdtpSAP::CancelIoctl(TUint aLevel, TUint aName)+
−
/**+
−
Cancel an Ioctl.+
−
+
−
@internalAll+
−
@param aLevel The Ioctl level+
−
@param aName The Ioctl name+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	__ASSERT_DEBUG(aLevel == iIoctlLevel && aName == iIoctlName, Panic(EAvdtpBadIoctl));+
−
	if (iSession)+
−
		{+
−
		iSession->CancelIoctl(aLevel, aName);+
−
		}+
−
	+
−
	ClearIoctl();+
−
	}+
−
+
−
void CAvdtpSAP::Error(TInt aError)+
−
/**+
−
Error has occurred - tell the socket.+
−
+
−
@internalAll+
−
@param aErr The error code+
−
@param aType The type of error+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	iSocket->Error(aError, iIoctlLevel ? MSocketNotify::EErrorIoctl+
−
									   : MSocketNotify::EErrorAllOperations);+
−
#ifdef _DEBUG									   +
−
	iCanSignalDisconnect = EFalse; // esock doesn't allow error then disconnect+
−
#endif+
−
	ClearIoctl();+
−
	}+
−
	+
−
void CAvdtpSAP::SendError(TInt aError)+
−
	{+
−
	iSocket->Error(aError, MSocketNotify::EErrorSend);+
−
	}+
−
	+
−
void CAvdtpSAP::SessionDisconnect()+
−
	{+
−
#ifdef _DEBUG+
−
	if (iCanSignalDisconnect)+
−
#endif+
−
		{+
−
		iSocket->Disconnect();+
−
#ifdef _DEBUG+
−
		iCanSignalDisconnect = EFalse;+
−
#endif+
−
		}+
−
	}+
−
+
−
+
−
/************************************************************************+
−
+
−
  Events interface (from TransportSession)+
−
+
−
 ************************************************************************/+
−
+
−
void CAvdtpSAP::NewData(TUint aCount)+
−
/**+
−
There is new data from the session for us.+
−
+
−
@internalComponent+
−
@param aPacket The new data from the muxer+
−
*/+
−
	{+
−
	// Write the data out to the socket, if possible.+
−
	LOG_FUNC+
−
	if (iSocket)+
−
		{+
−
		iSocket->NewData(aCount);+
−
		}+
−
	}+
−
+
−
void CAvdtpSAP::CanSend()+
−
/**+
−
Notification from the session that we can send again.+
−
+
−
Pass this through to our state machine.+
−
+
−
  @internalComponent+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	iSocketBlocked = EFalse;+
−
	iSocket->CanSend();+
−
	}+
−
+
−
void CAvdtpSAP::ServiceComplete(const TDesC8* aBuf)+
−
/**+
−
Notification that an AVDTP command has completed.+
−
May be called when no Ioctl called (ag stack-initiated Aborts) - in which case NOP+
−
@param aBuf The Ioctl data+
−
*/+
−
	{+
−
	LOG_FUNC+
−
	if (iIoctlLevel)+
−
		{+
−
		// need to cast away constness!+
−
		iSocket->IoctlComplete(const_cast<TDesC8*>(aBuf));+
−
		ClearIoctl();+
−
		}+
−
	}+
−
+
−
// Bearer (=signalling channel in this case) interface+
−
+
−
void CAvdtpSAP::Ready()+
−
	{+
−
	LOG_FUNC+
−
	// tell socket that session is ready +
−
		{+
−
#ifdef _DEBUG+
−
		iCanSignalDisconnect = ETrue;+
−
#endif+
−
		iSocket->ConnectComplete();+
−
		}+
−
	}+
−
+
−
+
−
/*inline*/ void CAvdtpSAP::ClearIoctl()+
−
	{+
−
	LOG_FUNC+
−
	iIoctlLevel = 0;+
−
	iIoctlName = 0;+
−
	}+
−
+
−
/* for the case of normal shutdowns from socket this is called when session+
−
is ready to go+
−
*/+
−
void CAvdtpSAP::CanClose()+
−
	{+
−
	LOG_FUNC+
−
	iSocket->CanClose(MSocketNotify::EDelete);+
−
	}+
−
	+
−
/**+
−
Raise an indication to the client+
−
Only secondary saps can propagate indications+
−
*/+
−
void CAvdtpSAP::Indication(const TDesC8& aIndicationData)+
−
	{+
−
	LOG_FUNC+
−
	__ASSERT_DEBUG(iSecondarySAP, Panic(EAvdtpSAPIndicationEngineFailure));+
−
	iSecondarySAP->DoIndication(aIndicationData);+
−
	}+
−
+
−
/**+
−
Actually do the raising of the indication+
−
*/	+
−
void CAvdtpSAP::DoIndication(const TDesC8& aIndicationData)+
−
	{+
−
	LOG_FUNC+
−
	__ASSERT_DEBUG(iSocket, Panic(EAvdtpSAPIndicationEngineFailure));+
−
+
−
	// since the protocol allows multiple outstanding commands it can be that we+
−
	// have to raise subsequent indications before the client has responded to the first+
−
	// therefore we queue the indication data+
−
+
−
	if (iIoctlName == 0)+
−
		// means there is no pending ioctl.+
−
		// the queue can or cannot be empty. However, since there is no+
−
		// pending ioctl, we queue the indication+
−
		{+
−
	    HQueuedAvdtpIndication* ind = HQueuedAvdtpIndication::New(aIndicationData);+
−
		if (ind)+
−
			{+
−
			LOG(_L("Adding Indication to queue"));+
−
			iIndicationQueue.AddLast(*ind);+
−
			}+
−
		else+
−
			{+
−
			// OOM'd - better tell client...they've lost an indication+
−
			Error(KErrNoMemory);+
−
			}+
−
		}+
−
	else+
−
		// if we have an outstanding Ioctl means the queue is empty.+
−
		// infact when an Ioctl (on sec sap) is performed and there are items+
−
		// in the queue, it completes the Ioctl immediately with a queued+
−
		// indication and then it clears the iIoctlName.+
−
		// Otherwise, if it cannot find queued indications then sets the iIoctlName+
−
		// and iIoctlLevel that means having a pending Ioctl +
−
		{+
−
		__ASSERT_DEBUG(iIndicationQueue.IsEmpty(), Panic(EAvdtpUnexpectedIndicationsInQueue));+
−
		// tell client straight away+
−
		if (iSocket)+
−
			{+
−
			ServiceComplete(&aIndicationData);+
−
			}+
−
		}+
−
	}+
−
	+
−
+
−
HQueuedAvdtpIndication* HQueuedAvdtpIndication::New(const TDesC8& aIndicationData)+
−
    {+
−
	LOG_STATIC_FUNC+
−
    HQueuedAvdtpIndication* ind = new HQueuedAvdtpIndication;+
−
    TInt err = KErrNone;+
−
    if (ind)+
−
    	{+
−
    	TRAPD(err, ind->ConstructL(aIndicationData));+
−
    	if (err)+
−
    	    {+
−
    	    delete ind;+
−
    	    ind=NULL;+
−
    	    }+
−
    	}+
−
    return (err==KErrNone) ? ind : NULL;+
−
    }+
−
	+
−
void HQueuedAvdtpIndication::ConstructL(const TDesC8& aIndicationData)+
−
    {+
−
	LOG_FUNC+
−
	iBuf = NULL;+
−
    iBuf = aIndicationData.AllocL();+
−
    }+
−
    +
−
HQueuedAvdtpIndication::~HQueuedAvdtpIndication()+
−
    {+
−
	LOG_FUNC+
−
    delete iBuf;+
−
    }+
−
+
−