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

//

#include "tavsrcStreamer.h"

#include "tavsrcUI.h"

#include "tavsrcUtils.h"

#include <bluetoothav.h>

static const TSize KStreamerConsole(55,12);

using namespace SymbianBluetoothAV;

using namespace SymbianSBC;

//

// class CSbcTrackInfo

//

CSbcTrackInfo::~CSbcTrackInfo()

	{

	iFrameInfo.Close();

	}

TInt CSbcTrackInfo::GetLastFrameSize()

	{

	TInt frameSize = KErrNotFound;

	TInt count = iFrameInfo.Count();

	if (count > 0)

		{

		frameSize = iFrameInfo[count - 1].iFrameSize;

		}

	return frameSize;

	}

TInt CSbcTrackInfo::AddNewFrame(TInt aFrameSize)

	{

	TInt rerr = KErrNone;

	TInt count = iFrameInfo.Count();

	if ((count > 0) && (iFrameInfo[count - 1].iFrameSize == aFrameSize))

		{

		// another frame of the same size

		iFrameInfo[count - 1].iFrameCount++;

		}

	else

		{

		// add new frame info

		rerr = iFrameInfo.Append(TSbcTrackFrameInfo());

		if (rerr == KErrNone)

			{

			iFrameInfo[count].iFrameSize = aFrameSize;

			iFrameInfo[count].iFrameCount = 1;

			}

		}

	return rerr;

	}

TInt CSbcTrackInfo::RemoveLastFrame()

	{

	TInt rerr = KErrNotFound;

	TInt count = iFrameInfo.Count();

	if (count > 0)

		{

		if (iFrameInfo[count - 1].iFrameCount > 1)

			{

			// remove one of the instances of the last frame size

			iFrameInfo[count - 1].iFrameCount--;

			}

		else

			{

			// remove the last frame info

			iFrameInfo.Remove(count - 1);

			}

		rerr = KErrNone;

		}

	return rerr;	

	}

void CSbcTrackInfo::Reset()

	{

	iFrameInfo.Reset();

	}

//

// class CActiveStreamer

//

CActiveStreamer* CActiveStreamer::NewL(RSocketArray aSockets,

									   CConsoleBase& aConsole,

									   MActiveStreamerUser& aUser,

									   TUint aDisplayMode,

									   TBool aPreloadFile)

	{

	CActiveStreamer* self = new (ELeave) CActiveStreamer (aConsole, aUser, aDisplayMode, aPreloadFile);

	CleanupStack::PushL(self);

	self->ConstructL(aSockets);

	CleanupStack::Pop();

	return self;

	}

CActiveStreamer::CActiveStreamer(CConsoleBase& aConsole, MActiveStreamerUser& aUser, TUint aDisplayMode, TBool aPreloadFile)

: iConsole(aConsole), iUser(aUser), iDisplayMode(aDisplayMode), iPreloadFile(aPreloadFile), iSbcFrameRate(1), iDirectionForward(ETrue)

	{

	iRTPCanSend = ETrue;

	}

CActiveStreamer::~CActiveStreamer()

	{

	delete iTimer;

	iSendSource.Close();

	iSession.Close();

	iSockets[0].Close();

	delete iFiles;

	iFile.Close();

	iRFs.Close();

	delete iProgressBar;

	DestroyBucket();

	delete iStreamingInfoConsole;	

	delete iFileBuf;

	iFileBuf = NULL;

	delete iStreamerUI;

	iStreamerUI = NULL;	

	}

void CActiveStreamer::Stream(TBool aIsSink)

	{

	if (!aIsSink)

		{

		iStartedTime.UniversalTime();

		iTimer->Start(iNominalSendClockInterval);

		Drip();		

		}

	else

		{

		//as sink, we do want to start up rtp and await its notification of a NewSource

		//Nothing to do at the moment, because when INT is a SNK, 

		//it just needs to get the RTP packets running and wait for notification.

		//This has already been done in constructor of the class.		

		}

	iStreamerUI->Play();

	}

void CActiveStreamer::Suspend()

	{

	iTimer->Cancel(); // stop callbacks to send

	iStreamerUI->Pause();

	}

void CActiveStreamer::ReStream()

	{

	iTimer->Start(iNominalSendClockInterval);

	Drip();

	iStreamerUI->Play();

	}

void CActiveStreamer::Stop()

	{

	iTimer->Cancel();

	iStreamerUI->Stop();

	iFillLevel = 0;

	iPos = 0;

	}

void CActiveStreamer::Pause()

	{

	iTimer->Cancel();

	iStreamerUI->Pause();

	}

void CActiveStreamer::NextTrack()

	{

	iPos=0;

	if (iCurrentFile < iFiles->Count() - 1)

		{

		iCurrentFile++;

		iStreamerUI->Next();

		}

	else

		{

		iCurrentFile = 0;

		iStreamerUI->First();

		}

	TRAPD(err, InitL());		

	if (err)

		{

		iConsole.Printf(_L("InitL failed with error: %d"),err);

		}

	}

void CActiveStreamer::PrevTrack()

	{

	iPos=0;

	if (iCurrentFile>0)

		{

		iCurrentFile--;

		iStreamerUI->Prev();

		}

	TRAPD(err, InitL());		

	if (err)

		{

		iConsole.Printf(_L("InitL failed with error: %d"),err);

		}

	}

void CActiveStreamer::InitL()

	{

	// close current file

	iFile.Close();

	delete iProgressBar;

	iProgressBar = NULL;

	// get file details

	RBuf filename;

	filename.Create(100);

	filename.Append(KSBCFileRoot);

	filename.Append(iFiles->operator[](iCurrentFile).iName);

	User::LeaveIfError(iFile.Open(iRFs,filename,EFileRead | EFileShareReadersOnly));

	TInt numChannels, chMode, numSubbands, blkLen, bitPool, freq, allocMethod;

	User::LeaveIfError(TTavsrcUtils::GetCodecSettingsFromSBCFile(filename, chMode, numChannels, numSubbands, blkLen, bitPool, freq, allocMethod));

	if (iStreamingInfoConsole)

		{

		iStreamingInfoConsole->Printf(_L("\nFirst SBC frame info for: %S...\n"), &filename);

		}

	filename.Close();

	// determine if a re-configuration is required

	if ((iNumChannels != numChannels) || (iFreq != freq) ||

		(iChMode != chMode) || (iBitPool != bitPool) ||

		(iBlkLen != blkLen) || (iNumSubbands != numSubbands) ||

		(iAllocMethod != allocMethod))

		{		

		iNumChannels = numChannels;

		iChMode = chMode;

		iNumSubbands = numSubbands;

		iBlkLen = blkLen;

		iBitPool = bitPool;

		iFreq = freq;

		iAllocMethod = allocMethod;

		// configuration is set first time around

		if (iSBCFrameSize != 0)

			{

			TSBCCodecCapabilities cfg;

			TSBCSubbandsBitmask subbands = numSubbands == 8 ? EEightSubbands : EFourSubbands;

			TSBCAllocationMethodBitmask alloc = allocMethod == 0 ? ELoudness : ESNR;

			TSBCSamplingFrequencyBitmask freqs(0);

			if (freq == 48000) freqs = E48kHz;

			else if (freq == 44100) freqs = E44100Hz; // note else if now as only select one

			else if (freq == 32000) freqs = E32kHz;

			else if (freq == 16000) freqs = E16kHz;

			TSBCChannelModeBitmask chs(0); // set it to anything to prevent warning

			if (chMode == 0) chs=EMono; 

			else if (chMode == 1) chs=EDualChannel; 

			else if (chMode == 2) chs=EStereo; 

			else if (chMode == 3) chs=EJointStereo; 

			TSBCBlockLengthBitmask blkLens(0); // set it to anything to prevent warning

			if (blkLen == 4) blkLens = EBlockLenFour;

			else if (blkLen == 8) blkLens = EBlockLenEight;

			else if (blkLen == 12) blkLens = EBlockLenTwelve;

			else if (blkLen == 16) blkLens = EBlockLenSixteen;

			cfg.SetSamplingFrequencies(freqs);

			cfg.SetChannelModes(chs);

			cfg.SetBlockLengths(blkLens);

			cfg.SetSubbands(subbands);

			cfg.SetAllocationMethods(alloc);

			// reconfig required

			iUser.MediaCodecConfigurationRequired(cfg);

			// ensure no more timer events until we have finished reconfiguring

			iTimer->Cancel();

			}

		if (chMode == 0 || chMode == 1)

			{

			iSBCFrameSize = 4+TReal((4*numSubbands*numChannels))/8+TTavsrcUtils::CEIL(TReal(blkLen*numChannels*bitPool)/8);

			}

		else

			{

			TBool join = chMode == 0x03;

			iSBCFrameSize = 4+TReal((4*numSubbands*numChannels))/8+TTavsrcUtils::CEIL(TReal((join*numSubbands+blkLen*bitPool))/8);

			}

		iSBCBitrate = 8*iSBCFrameSize*freq/(numSubbands*blkLen);

		TUint64 numerator = TUint64(8000000)*iSBCFrameSize;

		iSBCFrameInterval = (numerator)/iSBCBitrate; //microsecs

		}

	iSbcTrackInfo.Reset();

	iSbcTrackInfo.AddNewFrame(iSBCFrameSize);

	iDirectionForward = ETrue;

	iSbcFrameRate = 1;

	User::LeaveIfError(iFile.Size(iFileSize));

	if (iStreamingInfoConsole)

		{

		iStreamingInfoConsole->Printf(_L("Sampling Frequency: %d Hz\n"), iFreq);

		iStreamingInfoConsole->Printf(_L("Subbands: %d\n"), iNumSubbands);

		iStreamingInfoConsole->Printf(_L("BlkLen: %d\n"), iBlkLen);

		iStreamingInfoConsole->Printf(_L("ChannelMode: %d\n"), iChMode);

		iStreamingInfoConsole->Printf(_L("AllocMethod: %d\n"), iAllocMethod);

		iStreamingInfoConsole->Printf(_L("Bitpool: %d\n"), iBitPool);

		iStreamingInfoConsole->Printf(_L("SBC Frame size: %d bytes\n"), iSBCFrameSize);

		iStreamingInfoConsole->Printf(_L("Bitrate: %d bps\n"), iSBCBitrate);

		}

	TInt err = LoadFile();

	if(err==KErrNone)

		{

		if (iDisplayMode & EProgressBarWindow)

			{

			iProgressBar = CProgressBar::NewL(iFileSize);

			}

		FillBucket();

		}

	else

		{

		User::Leave(err);

		}

	// start the timer for this file

	iStartTime.UniversalTime();

	}

void CActiveStreamer::UpdateFrameInfo()

	{

	TInt numChannels, chMode, numSubbands, blkLen, bitPool, freq, allocMethod;

	User::LeaveIfError(TTavsrcUtils::GetCodecSettingsFromSBCFile(iFile, iPos, chMode, numChannels, numSubbands, blkLen, bitPool, freq, allocMethod));

	// determine if a re-configuration is required

	if ((iNumChannels != numChannels)|| (iFreq != freq) ||

		(iChMode != chMode) || (iBitPool != bitPool) ||

		(iBlkLen != blkLen) || (iNumSubbands != numSubbands) ||

		(iAllocMethod != allocMethod))

		{		

		iNumChannels = numChannels;

		iChMode = chMode;

		iNumSubbands = numSubbands;

		iBlkLen = blkLen;

		iBitPool = bitPool;

		iFreq = freq;

		iAllocMethod = allocMethod;

		TInt newFrameSize = 0;

		if (chMode == 0 || chMode == 1)

			{

			newFrameSize = 4+TReal((4*numSubbands*numChannels))/8+TTavsrcUtils::CEIL(TReal(blkLen*numChannels*bitPool)/8);

			}

		else

			{

			TBool join = chMode == 0x03;

			newFrameSize = 4+TReal((4*numSubbands*numChannels))/8+TTavsrcUtils::CEIL(TReal((join*numSubbands+blkLen*bitPool))/8);

			}

		if (newFrameSize != iSBCFrameSize)

			{

			// work out timer for SBC frame

			iSBCBitrate = 8*newFrameSize*freq/(numSubbands*blkLen);

			TUint64 numerator = TUint64(8000000)*iSBCFrameSize;

			iSBCFrameInterval = (numerator)/iSBCBitrate; //microsecs

			}

		iSBCFrameSize = newFrameSize;

		}	

	}

void CActiveStreamer::TimerEvent(CAdaptiveHighResPeriodic& /*aTimer*/)

	{

	if (iRTPCanSend)

		{

		iSent++;

		}

	else

		{

		// move iPos on anyway?

		iFailedSend++;

		}

	DoTimerEvent();

	}

void CActiveStreamer::TimerError(CAdaptiveHighResPeriodic& /*aTimer*/, TInt aError)

	{

	iConsole.Printf(_L("*ERROR %d*\n"), aError);

	__DEBUGGER();

	}

void CActiveStreamer::DoTimerEvent()

	{

	FillBucket();

	Drip();

	CheckJammed();	

	}

void CActiveStreamer::FillBucket()

	{

	// fill up bucket - it may be fully empty or partially full, but top it up in all cases	

	if (iFillLevel < KLowTidemark)

		{

		for (/*iFillLevel*/; iFillLevel < KSendBucketSize; iFillLevel++)

			{

			// get the next RTP packet to send

			RRtpSendPacket& sendPacket = iSendPackets[iFillLevel];

			TDes8& payload = sendPacket.WritePayload();

			payload.Zero();

			payload.Append(0); // update this later with number of frames in packet.

			TInt spaceInRtpPacket = iSBCFrameBytesPerRTP;

			TInt framesAdded = 0;

			TInt packetInterval = 0;

			TInt nextFrameSize = iDirectionForward ? iSBCFrameSize : iSbcTrackInfo.GetLastFrameSize();

			TBool moreFrames = ETrue;

			while ((nextFrameSize > 0) && (nextFrameSize <= spaceInRtpPacket) && (framesAdded <= 15) && moreFrames)

				{

				// add frame

				if (iPreloadFile)

					{

					TPtrC8 ptr(iFileBuf->Des().Ptr()+iPos, nextFrameSize);

					payload.Append(ptr);

					}

				else

					{

					TPtr8 ptr(const_cast<TUint8*>(iFileBuf->Des().Ptr()), 0, nextFrameSize);

					iFile.Read(iPos, ptr);

					payload.Append(ptr);

					}

				framesAdded++;

				packetInterval+=iSBCFrameInterval;			

				spaceInRtpPacket-=nextFrameSize;

				// get next frame information

				for (TInt count = 0; (count != iSbcFrameRate) && moreFrames; count++)

					{

					iPos = iDirectionForward ? iPos + nextFrameSize : iPos - nextFrameSize;

					// determine if we are done with the current file

					if ((iPos >= iFileSize) || (iPos < 0))

						{

						moreFrames = EFalse;

						}

					else 

						{

						TInt err = KErrNone;

						if (iDirectionForward)

							{

							// keep track of the frame sizes as we go, this is used to rewind,

							// i.e. iDirectionForward = EFalse

							if ((err = iSbcTrackInfo.AddNewFrame(iSBCFrameSize)) != KErrNone)

								{

								iConsole.Printf(_L("Error adding SBC frame information: %d\n"), err);

								__DEBUGGER();

								}

							}

						else

							{

							if ((err = iSbcTrackInfo.RemoveLastFrame()) != KErrNone)

								{

								// this should never happen as we always check the length first

								iConsole.Printf(_L("Error removing SBC frame information: %d\n"), err);

								__DEBUGGER();

								}

							}

						UpdateFrameInfo();

						nextFrameSize = iDirectionForward ? iSBCFrameSize : iSbcTrackInfo.GetLastFrameSize();

						}

					}				

				}

			// has the interval changed since last time we set the timer

			if ((iNominalSendClockInterval != packetInterval) && moreFrames)

				{

				// adjust timer

				if (iStreamingInfoConsole)

					{

					iStreamingInfoConsole->Printf(_L("Interval change from: %d to %d\n"), iNominalSendClockInterval, packetInterval);

					}

				iNominalSendClockInterval = packetInterval;

				iTimer->SetInterval(iNominalSendClockInterval);

				}

			// write number of SBC frames into packet

			payload[0] = TChar(framesAdded);

			//DrawBucket();	//<--- to animate the display

			if (iPos > iFileSize)

				{

				// time to do some metrics, and loop back to beginning

				TTime finTime;

				finTime.UniversalTime();

				TInt64 secs;