/*

* Copyright (c) 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: Juha Kauppinen, Mika Hokkanen

* 

* Description: Photo Browser

*

*/

// Include files

#include <e32cons.h>

#include <IEBgpsInfo.h>

//#include <IEBGPSTrace.h>

#include "IEBgpServer.h"

#include "IEBgpServerSession.h"

// --------------------------- MEMBER FUNCTIONS ---------------------------- //

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

//

//

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

CIEBgpServer* CIEBgpServer::NewL()

{

	DP0_IMAGIC((_L("CIEBgpServer::NewL ++")));

	CIEBgpServer* self = new (ELeave) CIEBgpServer();

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	DP0_IMAGIC((_L("CIEBgpServer::NewL --")));

	return self;

}

CIEBgpServer::~CIEBgpServer()

{

DP0_IMAGIC((_L("CIEBgpServer::~CIEBgpServer")));

iFileServer.Close();

RFbsSession::Disconnect();

DP0_IMAGIC((_L("CIEBgpServer::~CIEBgpServer")));	

}

//EPriorityIdle, EPriorityLow, EPriorityStandard, EPriorityUserInput, EPriorityHigh

CIEBgpServer::CIEBgpServer()

:CServer2(EPriorityIdle)

{	

}

void CIEBgpServer::ConstructL()

{

	DP0_IMAGIC((_L("CIEBgpServer::ConstructL ++")));

	StartL(KIEBgpServerName);

	User::LeaveIfError(iFileServer.Connect());

    User::LeaveIfError( FbsStartup() );

    User::LeaveIfError(RFbsSession::Connect());

	DP0_IMAGIC((_L("CIEBgpServer::ConstructL --")));

}

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

{

	DP0_IMAGIC((_L("CIEBgpServer::NewSessionL ++")));

	CIEBgpServerSession* session = CIEBgpServerSession::NewL(const_cast<RFs*>(&iFileServer));

	DP0_IMAGIC((_L("CIEBgpServer::NewSessionL --")));

	return session;

}

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

// Thread function to start the server

//

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

GLDEF_C TInt CIEBgpServer::ThreadFunction(TAny* /*aParam*/)

{

	DP0_IMAGIC((_L("CIEBgpServer::ThreadFunction ++")));

	// First get the cleanup stack

	CTrapCleanup* cleanupStack = CTrapCleanup::New();

	TRAPD(error, StartServerL());

	delete cleanupStack;

	DP0_IMAGIC((_L("CIEBgpServer::ThreadFunction --")));

	return error;

}

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

// Starts the server

//

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

void CIEBgpServer::StartServerL()

{

	DP0_IMAGIC((_L("CIEBgpServer::StartServerL ++")));

	// Create an active scheduler before server is created

	CActiveScheduler* as = new (ELeave) CActiveScheduler();

	CleanupStack::PushL(as);

	CActiveScheduler::Install(as);

	// Create server

	CIEBgpServer* server = CIEBgpServer::NewL();

	CleanupStack::PushL(server);

	RThread::Rendezvous(KErrNone);

	// Start active scheduler

	CActiveScheduler::Start();

	// Clean up

	CleanupStack::PopAndDestroy(2, as);

	DP0_IMAGIC((_L("CIEBgpServer::StartServerL --")));

}

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

// Creates the server thread

//

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

EXPORT_C TInt CreateServerThread(RThread& aThread)

{

	DP0_IMAGIC((_L("CIEBgpServer::CreateServerThread ++")));

	TInt error = KErrNone;

	// Check if the server already exists

	TFindServer findServer(KIEBgpServerName);

	TFileName matchingServer;

	if(findServer.Next(matchingServer) != KErrNone)

	{

		error = aThread.Create(KIEBgpServerName, // Server name

							CIEBgpServer::ThreadFunction, // thread function to call when thread is created and resumed

							KDefaultStackSize, // stack size

							KIEHeapSizeMin, // min heap size

							KIEHeapSizeMax, // max heap size

							NULL); // data ptr needed (if)

		if(error == KErrNone)

		{

			// Thread created successfully, resume it

			TRequestStatus rendezvousStatus;

			//Keep priority low to enable smooth UI drawing

			//aThread.SetPriority(EPriorityNormal);

			aThread.SetPriority(EPriorityLess);//EPriorityNormal, EPriorityLess, EPriorityMuchLess, EPriorityNull

			aThread.Rendezvous(rendezvousStatus);

			aThread.Resume();

			User::WaitForRequest(rendezvousStatus);

		}

		else

		{

			// error in thread creation

			aThread.Close();

		}

	}

	else

	{

		error = KErrAlreadyExists;

	}

	DP0_IMAGIC((_L("CIEBgpServer::CreateServerThread --")));

	return error;

}

// EOF