// 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 avdtp media transport session

// 

//

/**

 @file

 @internalComponent

*/

#include <bluetooth/logger.h>

#include "avdtpMediaSession.h"

#include "avdtp.h"

#include "avdtpsap.h"

#include "avdtpStream.h"

#include "avdtputil.h"

#include "gavdpinterface.h"

//#include <es_mbman.h> // for MBUF logging

#ifdef __FLOG_ACTIVE

_LIT8(KLogComponent, LOG_COMPONENT_AVDTP);

#endif

CMediaSession* CMediaSession::NewLC(CAvdtpProtocol& aProtocol, CAvdtpSAP& aSAP, CAVStream& aStream)

	{

	LOG_STATIC_FUNC

	CMediaSession* s = new (ELeave) CMediaSession(aProtocol, aSAP, aStream);

	CleanupStack::PushL(s);

	s->ConstructL();

	return s;

	}

CMediaSession* CMediaSession::NewL(CAvdtpProtocol& aProtocol, CAvdtpSAP& aSAP, CAVStream& aStream)

	{

	LOG_STATIC_FUNC

	CMediaSession* s = CMediaSession::NewLC(aProtocol, aSAP, aStream);

	CleanupStack::Pop();

	return s;		

	}

CMediaSession::CMediaSession(CAvdtpProtocol& aProtocol, CAvdtpSAP& aSAP, CAVStream& aStream)

: CUserPlaneTransportSession(aProtocol, aSAP, EMedia, aStream)

	{

	LOG_FUNC

	iNotifyMediaPacketDroppedFlag = EFalse;

	iPacketsLost = 0;

	}

void CMediaSession::ConstructL()

	{

	LOG_FUNC

	CUserPlaneTransportSession::ConstructL();

	// Balking is set to true.  This allows the circular buffer to wrap

	// and overwrite the oldest data.

	User::LeaveIfError(iSendPool.Create(4, ETrue));

	User::LeaveIfError(iReceivePool.Create(16, ETrue));

	}

TInt CMediaSession::DoActiveOpen()

	{

	LOG_FUNC

	__ASSERT_DEBUG(iStream, Panic(EAvdtpTransportSessionBaseNotCheckStream));

	TInt ret = KErrGeneral; // may be OOM or notfound

	ret = iStream->AddSession(EMedia,*this,iTransportChannel);

	if (ret!=KErrNone)

		{

		// not erroring the stream, as it's not it's fault

		// and it may not exist anyway!

		iStream = NULL;

		iSAP.Error(ret);

		}

	return ret;	

	}

TInt CMediaSession::Send(RMBufChain& aData, TUint /*aOptions*/, TSockAddr* /*aAddr*/)

	{

	LOG_FUNC

	// if we get flow controlled should we *could* indicate to reporting session which could complete

	// an ioctl (for rtcp use)

//	if (iStream && iStream->CanSend(EMedia))

	TInt requestedToSend = aData.Length();

	TInt packetsLostThisSend = 0; // Packets lost during this send (if any)

	if (!iTransportChannelBlocked)

		{

		RMBufChain toSend;

		iSendPool.Remove(toSend);

		if (toSend.IsEmpty())

			{

			toSend.Assign(aData);

			}

		else

			{

			iSendPool.Add(aData, packetsLostThisSend);

			iPacketsLost += packetsLostThisSend;

			}

		DoSend(toSend);

		}

	else

		{

		iSendPool.Add(aData, packetsLostThisSend);

		iPacketsLost += packetsLostThisSend;

		}

	// If client app has previous sent pack drop IOCTL it needs to be notified

	if (iNotifyMediaPacketDroppedFlag && iPacketsLost)

		{

		TPckgBuf<TInt> buf(iPacketsLost);

		iSAP.ServiceComplete(&buf);

		iNotifyMediaPacketDroppedFlag = EFalse;

		iPacketsLost = 0;

		}

	return requestedToSend;

	}

// if pools become nicely generic then we could move this sending stuff to base class

// and have sessions just configure the Tx, Rx pools

void CMediaSession::DoSend(RMBufChain& aData)

	{

	LOG_FUNC

	if (iTransportChannel->SendPacket(EMedia, aData)==0)

		{

		// as media session, just free stale AV data (gets tricky putting stuff back on pool, and not really needed)

		// but mark TC as blokced so we can begin buffering in future

		aData.Free();

		iTransportChannelBlocked = ETrue;

		}

	}

void CMediaSession::CanSend()

	{

	LOG_FUNC

	// pluck off pool

	iTransportChannelBlocked = EFalse;

	//RDebug::Print(_L("MBuf free %d"), CMBufManager::Context()->__DbgGetBufSpace());

	// something was placed on the send pool - remove it and send

	RMBufChain chain;

	do

		{

		iSendPool.Remove(chain);

		if (!chain.IsEmpty())

			{

			DoSend(chain);

			}

		}

	while (!chain.IsEmpty());

	}

void CMediaSession::ReceivePacketLost()

	{

	// Increment the packet lost count.

	iPacketsLost++;

	// If client app has previous sent pack drop IOCTL it needs to be notified

	if (iNotifyMediaPacketDroppedFlag)

		{

		TPckgBuf<TInt> buf(iPacketsLost);

		iSAP.ServiceComplete(&buf);

		iNotifyMediaPacketDroppedFlag = EFalse;

		iPacketsLost = 0;

		}

	}

TInt CMediaSession::GetOption(TUint aLevel, TUint aName, TDes8& aOption) const

	{

	LOG_FUNC

	TInt ret = KErrArgument;

	if (aLevel == KSolBtAVDTPMedia)

		{

		switch (aName)

			{

			case EAvdtpMediaGetMaximumPacketSize:

				{

				if (iTransportChannel)

					{

					TInt mtu;

					ret = iTransportChannel->MaxPacketSize(mtu);

					if (ret==KErrNone)

						{

						LOG1(_L("Media session transport channel MTU = %d"), mtu);

						TPckg<TInt> mtuBuf(mtu);

						aOption = mtuBuf;

						}

					}

				else

					{

					ret = KErrNotReady;

					}

				}

			break;

			case EAvdtpMediaGetMaximumReceivePacketSize:

				{

				if (iTransportChannel)

					{

					TInt mru;

					ret = iTransportChannel->MaxReceivePacketSize(mru);

					if (ret==KErrNone)

						{

						LOG1(_L("Media session transport channel MRU = %d"), mru);

						TPckg<TInt> mruBuf(mru);

						aOption = mruBuf;

						}

					}

				else

					{

					ret = KErrNotReady;

					}

				}

			break;

			default:

				ret = KErrNotSupported;

			}

		}

	return ret;

	}

void CMediaSession::Ioctl(TUint aLevel, TUint aName, const TDesC8* /* aOption */)

	{

	LOG_FUNC

	TInt res;

	if (aLevel == KSolBtAVDTPMedia)	

		{

		switch (aName)

			{

			case ENotifyAvdtpMediaPacketDropped:

				{

				iNotifyMediaPacketDroppedFlag= ETrue;

				res = KErrNone;

				break;

				}

			default:

				{

				res = KErrNotSupported;

				break;

				}

			}

		if (res!=KErrNone)

			{

			iSAP.Error(res);

			}

		}

	}