// 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 "mmrcserver.h"

#include "mmrcserversession.h"

#include "mmrcservercontroller.h"

#include "mmrcserverstart.h"

#include <a3f/a3ffourcclookup.h>

#include <a3f/a3f_trace_utils.h>

//------------------------------------------------------------------------------------

//

//------------------------------------------------------------------------------------

/**

 * Constructor

 */

CMMRCServer::CMMRCServer()

:  CServer2(EPriorityStandard)

	{ 

	TRACE_CREATE();

	DP_CONTEXT(----> CMMRCServer::CMMRCServer *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	Cancel();

	DP_OUT();

	}

/**

 * Destructor.

 */

CMMRCServer::~CMMRCServer()

	{

	DP_CONTEXT(----> CMMRCServer::~CMMRCServer *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	if(iMMRCServerController)

		{

		delete iMMRCServerController;

		}

	delete iFourCCConvertor;

	DP_OUT();

	}

//------------------------------------------------------------------------------------

//

//------------------------------------------------------------------------------------

/**

 * Constructs, and returns a pointer to, a new CMMRCServer object.

 * Leaves on failure.

 * @return CMMRCServer* A pointer to newly created utlitly object.

 */		

CMMRCServer* CMMRCServer::NewL()

	{

	DP_STATIC_CONTEXT(----> CMMRCServer::NewL *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	CMMRCServer* self = NewLC();

	CleanupStack::Pop(self);

	DP0_RET(self, "0x%x");

	} 

/**

 * Constructs, leaves object on the cleanup stack, and returns a pointer

 * to, a new CMMRCServer object.

 * Leaves on failure.

 * @return CMMRCServer* A pointer to newly created utlitly object.

 */		

CMMRCServer* CMMRCServer::NewLC()

	{

	DP_STATIC_CONTEXT(----> CMMRCServer::Open *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	CMMRCServer* self = new(ELeave) CMMRCServer;

	CleanupStack::PushL(self);

	self->ConstructL();

	DP0_RET(self, "self = 0x%x");

	}

/**

 	CMMRCServer::ConstructL

 	Symbian 2nd phase constructor can leave.

 */

void CMMRCServer::ConstructL()

	{

	DP_CONTEXT(----> CMMRCServer::ConstructL *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	iMMRCServerController = CMMRCServerController::NewL();

	iFourCCConvertor = CFourCCConvertor::NewL();

	DP_OUT();

	}

//------------------------------------------------------------------------------------

//

//------------------------------------------------------------------------------------

/**

 * From CServer2. Creates a server-side client session object.

 * Creates a new session.  Only one session may be created with the ControllerProxyServer.

 * This function may leave with one of the system-wide error codes.

 * @param const TVersion& aVersion	The version number of the session.

 * @param const RMessage2& aMessage

 * @return A pointer to the new session.

 */

CSession2* CMMRCServer::NewSessionL(const TVersion& aVersion, const RMessage2& /*aMessage*/) const

	{

	DP_CONTEXT(----> CMMRCServer::NewSessionL *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	TVersion version(KMMRCServerVersion,KMMRCServerMinorVersionNumber,KMMRCServerBuildVersionNumber);

	if(!User::QueryVersionSupported(version, aVersion))

		{

		User::Leave(KErrNotSupported);	   

		}

	CMMRCServerSession* mmrcSession = CMMRCServerSession::NewL(*iMMRCServerController, *iFourCCConvertor);

	DP0_RET(mmrcSession, "mmrcSession = 0x%x");

	}

/**

A utility function to panic the server.

*/

void CMMRCServer::PanicServer(TInt aPanic)

	{

	_LIT(KMMRCServerPanic,"MMRC Server panic");

	User::Panic(KMMRCServerPanic, aPanic);

	}

//------------------------------------------------------------------------------------

//

//------------------------------------------------------------------------------------

TInt CMMRCServer::ThreadFunctionL(TAny* /**aStarted*/)

	{

	DP_STATIC_CONTEXT(----> CMMRCServer::ThreadFunctionL *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	// create an active scheduler and server

	CActiveScheduler* sched = new (ELeave) CActiveScheduler;

	CleanupStack::PushL(sched);

	//Install the active scheduler

	CActiveScheduler::Install(sched);

	CMMRCServer *server = CMMRCServer::NewLC();

	// Start the server

	TInt err = server->Start(KMMRCServerName);

	if (err != KErrNone)

		{

		CMMRCServer::PanicServer(KErrNoMemory);

		}

	// Let everyone know that we are ready to

	// deal with requests.

	RThread::Rendezvous(KErrNone);

	// And start fielding requests from client(s).

	CActiveScheduler::Start();

	// Tidy up...

	CleanupStack::PopAndDestroy(2, sched);

	DP0_RET(KErrNone, "error = %d");

	}

/**

Create the thread that will act as the server.

This function is exported from the DLL and called by the client.

Note that a server can also be implemented as a separate

executable (i.e. as a separate process).

*/

TInt CMMRCServer::ThreadFunction(TAny* aStarted)

	{

	DP_STATIC_CONTEXT(----> CMMRCServer::ThreadFunction *CD1*, CtxDevSound, DPLOCAL);

	DP_IN();

	// get clean-up stack

	CTrapCleanup* cleanup=CTrapCleanup::New();

	if (cleanup == NULL)

		{

		CMMRCServer::PanicServer(KErrNoMemory);

		}

	TRAPD( err, ThreadFunctionL(aStarted) );

	delete cleanup; 

	DP0_RET(err, "error = %d");

	}

/**

Create the thread that will act as the server.

This function is exported from the DLL and called by the client.

Note that a server can also be implemented as a separate

executable (i.e. as a separate process).

*/

EXPORT_C TInt StartMMRCServer(RThread& aServerThread)

	{

	TInt res = KErrNone;

	// Create the server, if one with this name does not already exist.

	TFindServer findCountServer(KMMRCServerName);

	TFullName   name;

	// Need to check that the server exists.

	if ( findCountServer.Next(name) != KErrNone )

		{

		  // Create the thread for the server.

		res = aServerThread.Create(KMMRCServerName,

			CMMRCServer::ThreadFunction,

			KMMRCServerStackSize,

			KMMRCServerInitHeapSize,

			KMMRCServerMaxHeapSize,

			NULL

			);

		// The thread has been created OK so get it started - however

		// we need to make sure that it has started before we continue.

		if (res==KErrNone)

			{

			TRequestStatus rendezvousStatus;

			aServerThread.SetPriority(EPriorityNormal);

			aServerThread.Rendezvous(rendezvousStatus);

			aServerThread.Resume();

			User::WaitForRequest(rendezvousStatus);

			}

		  // The thread has not been created - clearly there's been a problem.

		else

			{

			aServerThread.Close();

			}

		}	

	return res;

	}

//EOF