// 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:

//

#ifndef TAVSRCSTREAMER_H

#define TAVSRCSTREAMER_H

#include "tavsrc.h"

#include "tavsrcTimer.h"

#include "tavsrcStreamerUser.h"

#include <f32file.h>

#include <rtp.h>

static const TInt KLowTidemark = 2;

static const TInt KSendBucketSize = 2;

#ifdef __WINS__

_LIT(KSBCFileRoot, "c:\\");

_LIT(KSBCFiles, "c:\\*.sbc");

#else

//For reference boards, use the MMC drive, because C: is formatted every reboot

_LIT(KSBCFileRoot, "e:\\");

_LIT(KSBCFiles, "e:\\*.sbc");

#endif

class CProgressBar;

class CStreamerUI;

class CActiveSockWriter;

class CActiveSockReader;

class TSbcTrackFrameInfo

	{

public:

	TInt iFrameSize;

	TUint iFrameCount;

	};

// used to keep track of the sizes of the SBC frames to allow going backwards through

// an SBC file on a frame by frame basis. This is require to support VBR where the

// frame sizes can change for a single track.

class CSbcTrackInfo : public CBase

	{

public:

	~CSbcTrackInfo();

	TInt GetLastFrameSize();

	TInt AddNewFrame(TInt aFrameSize);

	TInt RemoveLastFrame();

	void Reset();

private:

	RArray<TSbcTrackFrameInfo> iFrameInfo;

	};

class CActiveStreamer : public CBase, private MAdaptiveHighResPeriodicClient

	{

public:

	static CActiveStreamer*	NewL(RSocketArray aSockets,

								 CConsoleBase& aConsole,

								 MActiveStreamerUser& aUser,

								 TUint aDisplayMode,

								 TBool aPreloadFile);

	~CActiveStreamer();

	static void RTPCallbackL(CActiveStreamer* aStreamer, const TRtpEvent& aEvent);

	// streamer operations

	void Stream(TBool aIsSink);

	void Suspend();

	void ReStream();

	void Stop();

	void Pause();

	void Faster();

	void Slower();

	void Backward();

	void Forward();

	void NextTrack();

	void PrevTrack();

private:

	enum TDisplayMode

		{

		EStatusCommandWindows = 0x00,

		EStreamerInfoWindow = 0x01,

		EProgressBarWindow = 0x02,

		EPlaylistWindow = 0x04,

		EChunkyIconWindow = 0x08,

		};

private:

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

	void TimerEvent(CAdaptiveHighResPeriodic& aTimer);

	void TimerError(CAdaptiveHighResPeriodic& aTimer, TInt aError);

	void StartSinkL();

	void ConstructL(RSocketArray aSockets);

	TInt LoadFile();

	void DoTimerEvent();

	void DestroyBucket();

	void InitL();

	void CreateBucketL();

	void FillBucket();

	void Drip();

	void DrawBucket();

	void CheckJammed();

	void UpdateFrameInfo();

private:

	CConsoleBase& iConsole;

	TInt iProgressBarPos;

	CProgressBar* iProgressBar;

	CStreamerUI* iStreamerUI;

	CConsoleBase* iStreamingInfoConsole;

	CAdaptiveHighResPeriodic* iTimer;

	RFile iFile;

	RFs iRFs;	

	CDir* iFiles;

	TInt iCurrentFile;

	RSocketArray iSockets;

	TInt iMTU;

	TInt iFileSize;

	TTime iStartTime;

	RRtpSession iSession;

	RRtpSendSource iSendSource;

	RRtpReceiveSource iReceiveSource;

	RArray<RRtpSendPacket> iSendPackets; // used like a queue sometimes

	TRtpEventType iEventType;

	TBool iRTPCanSend;

	TInt iSBCFrameBytesPerRTP;

	TInt iSBCFrameSize;

	TInt iSBCFrameInterval;

	TInt iNumSBCFramesInRTP;

	TInt iSBCBitrate;

	TInt iSendClockInterval;		// microsecs

	TInt iNominalSendClockInterval;// microsecs

	TBool iBonusDrip;

	TTime iStartedTime;			// for "absolute" timing style

	// checking for jammed streamer, and leaky mbufs

	TInt iBucketAppearsJammed;

	TBool iBucketJammed;

	TTime iLastPacketSentTime;

	TInt iPreviousFillLevel;

	TInt iPos;

	TInt iFailedSend;

	TInt iSent;

	TInt iFillLevel;

	HBufC8* iFileBuf;

	// current SEP configuration

	TInt iNumChannels;

	TInt iChMode;

	TInt iNumSubbands;

	TInt iBlkLen;

	TInt iBitPool;

	TInt iFreq;

	TInt iAllocMethod;

	MActiveStreamerUser& iUser;	

	TUint iDisplayMode;

	TBool iPreloadFile;

	CSbcTrackInfo iSbcTrackInfo;

	TInt iSbcFrameRate;

	TBool iDirectionForward;

	};

#endif // TAVSRCSTREAMER_H