// 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:
// Header for class specific to rtp unit tests
// 
//

/**
 @file
 @internalComponent
*/

#if (!defined __TRTPSERVER_H__)
#define TRTPSERVER_H
#include <testexecuteserverbase.h>
#include "rtp.h"
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include "rtpsession_internal.h"
#endif 

class CTrtpStep;

class CTrtpServer : public CTestServer
	{
public:
	static CTrtpServer* NewL();
	virtual CTestStep* CreateTestStep(const TDesC& aStepName);
	~CTrtpServer();

	// Member functions used by test steps
	static void StopScheduler(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NewSourceL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void GetPacketL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void Panic(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void LeaveL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NewSourceLeaveL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NotifyError(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CloseSession(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NewSourceCloseSessionL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NewSourceDelayedCloseSessionL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NewSourceLeaveCloseL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void LeaveAfterCloseL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CloseSourceFromSourceL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CloseSourceFromSourceLeaveL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CloseSource(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CloseSendSource(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void NoteEventStatus(CTrtpServer* aPtr, const TRtpEvent& aEvent);

	static void NewSrcForRtcpL(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CbERtpSDES(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CbERtpAPP(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CbERtpSR(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CbERtpRR(CTrtpServer* aPtr, const TRtpEvent& aEvent);
	static void CbERtpBYE(CTrtpServer* aPtr, const TRtpEvent& aEvent);

	//
	static TUint32 Swap32(TUint32 aVal);
	static TUint16 Swap16(TUint16 aVal);

	// Members used by the steps
	TBool iOom;
	TBool iStopping;
	CTrtpStep* iCurrentStep;
	RRtpSendPacket iSendPacket;
	RRtpReceivePacket iReceivePacket;
	RRtpPacket* iPacket; // Used for checking the current 'interesting
						 // packet' has the right values. The same
						 // functions can work on both send and
						 // receive packets. This points to whichever
						 // one we're interested in.
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
	RRtpSession_Internal iSession;
#else
	RRtpSession iSession;
#endif 
	RRtpSendSource iSendSource;
	RArray<RRtpReceiveSource> iSources;
	RRtpReceiveSource iLastActiveSource;
	RSocketServ iSocketServer;
	RSocket iSocket;
	RFs iFs;
	TRtpEvent iLastEvent;
	TInt iStopCount;
	TInt iEventStatus;
	TBool iConnected;
	RSocket iRtpSocket;
	RSocket iRtcpSocket;
	RConnection iConnect;
	RSubConnection iSubConnect;
	CActiveScheduler* iScheduler;

 private:
	CTrtpServer() : iOom(EFalse), iStopping(EFalse), iLastEvent(ERtpAnyEvent, 0, 0) {};
	void ConstructL();
	};

class CWaiter : public CActive
	{
 public:
	static CWaiter* NewLC(CTrtpServer* aServer);

	~CWaiter();
	
	void RunL();
	void DoCancel();

	void Ready() { SetActive();};

 private:
	CWaiter(CTrtpServer* aServer) : CActive(0), iServer(aServer) 
			{
			CActiveScheduler::Add(this);
			};

	CTrtpServer* iServer;
	};

#endif