/*

* Copyright (c) 2007 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:  Class definition of 

*

*/

#include "diagresultsdatabasecommon.h"

#include "diagresultsdbserver.h"

#include "diagresultsdbsession.h"

#include <e32base.h>

#include <e32uid.h>

//Enter any new accepted UIDs here.

const TInt KAcceptedUids[] = 

    { 

    0x2000B0E8, //Phone Doctor

    0x2000E542, //Diagnostics application

    0x102073E4,    // STIF

#if defined( _DEBUG ) || defined( __WINSCW__ )

    0x10282CDA,   //Results DB test app

    0x20000FB1,   //EUnitAppEnv

    0x20000FB2,   //EUnitEikApp

    0x20000FB3,   //EUnitExeEnv

    0xED80F513,   // DiagFramework Test app

#endif // _DEBUG || __WINSCW__

    0x2000F8E8    // donno

    };

const TInt KAcceptedUidCount = sizeof( KAcceptedUids ) / sizeof( TInt );

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

// Constructor.

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

//  

CDiagResultsDbServer::CDiagResultsDbServer(TInt aPriority, 

                                            const TPolicy &aPolicy)

: CPolicyServer(aPriority, aPolicy), iContainerIndex( NULL ), iSessionCount(0)

	{

	}

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

// Destructor.

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

//  

CDiagResultsDbServer::~CDiagResultsDbServer()

	{

	delete iContainerIndex;

	}

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

// NewLC.

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

//  

void CDiagResultsDbServer::NewLC(const TPolicy &aPolicy)

	{

	CDiagResultsDbServer *pS = new CDiagResultsDbServer( 

	                                        CActive::EPriorityHigh, aPolicy );

	CleanupStack::PushL( pS ); 

	pS->StartL( KDiagResultsDatabaseServerName );

	pS->ConstructL();

	}

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

// ConstructL.

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

// 

void CDiagResultsDbServer::ConstructL()

	{

	iContainerIndex = CObjectConIx::NewL();

	}

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

// Create a new server session.

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

// 

CSession2 *CDiagResultsDbServer::NewSessionL(const TVersion &aVersion, 

                                        const RMessage2 &/*aMessage*/) const

	{

	// check we're the right version

	TVersion v(KDiagResultsDatabaseServerMajor, KDiagResultsDatabaseServerMinor, 

	                                            KDiagResultsDatabaseServerBuild);

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

		User::Leave( KErrNotSupported );

	// make new session

	return CDiagResultsDbSession::NewL((CDiagResultsDbServer*)this);

	}

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

// Create new object container.

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

//

CPolicyServer::TCustomResult CDiagResultsDbServer::CustomSecurityCheckL(

                        const RMessage2 &aMsg, 

                        TInt &/*aAction*/, 

                        TSecurityInfo &/*aMissing*/)

	{

	CPolicyServer::TCustomResult result = EFail;

	TInt sid = aMsg.SecureId();

    for ( TInt i = 0; i < KAcceptedUidCount; ++i )

        {

        if ( sid == KAcceptedUids[i] )

            {

            if ( aMsg.HasCapability( ECapabilityReadDeviceData ) &&

	             aMsg.HasCapability( ECapabilityWriteDeviceData ) )

	            {

	            result = EPass;   

	            break; 

	            }    

            }

        }

	return result;

	}

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

// Create new object container.

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

//

CObjectCon* CDiagResultsDbServer::NewContainerL()

	{

	return iContainerIndex->CreateL();

	}

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

// Remove object from a container index,

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

// 

void CDiagResultsDbServer::RemoveContainer(CObjectCon* aCon)

	{

	iContainerIndex->Remove( aCon );

	}	

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

// Return the total amount of client sessions.

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

// 	

TInt CDiagResultsDbServer::SessionCount()

	{

	return iSessionCount;

	}

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

// Decrease session count when one client leaves and stop server if there are

// no more clients.

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

// 

void CDiagResultsDbServer::DecreaseSessionCount()

	{

	iSessionCount--;

	if (iSessionCount == 0)

		{

		CActiveScheduler::Stop();

		}

	}

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

// One new session created.

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

// 	

void CDiagResultsDbServer::IncreaseSessionCount()

	{

	iSessionCount++;

	}		

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

// Create cleanupStack and call RunserverL.

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

// 

TInt CDiagResultsDbServer::RunServer()

	{

	__UHEAP_MARK;

	//

	CTrapCleanup* cleanup = CTrapCleanup::New();

	TInt ret = KErrNoMemory;

	if( cleanup )

		{

		TRAP( ret, CDiagResultsDbServer::RunServerL() );

		delete cleanup;

		}

	//

	__UHEAP_MARKEND;

	if( ret != KErrNone )

		{

		// Signal the client that server creation failed

		RProcess::Rendezvous( ret );

		}

	return ret;

	}

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

// Create active scheduler and run server.

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

// 

void CDiagResultsDbServer::RunServerL()

	{

	User::RenameThread(KDiagResultsDatabaseServerName);

	// Create and install the active scheduler we need

	CActiveScheduler *as=new (ELeave)CActiveScheduler;

	CleanupStack::PushL( as );

	CActiveScheduler::Install(as);

	// Create server

	CDiagResultsDbServer::NewLC(policy);

	// Initialisation complete, now signal the client

	RProcess::Rendezvous(KErrNone);

	// Ready to run

	CActiveScheduler::Start();

	// Cleanup the server and scheduler

	CleanupStack::PopAndDestroy(2, as);

	}

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

// Main function that is called when server(.EXE) is launched.

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

// 

TInt E32Main()

	{

	TInt error(KErrNone);

	error = CDiagResultsDbServer::RunServer();

	return error;

	}