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

//

/**

 @file

*/

#include <e32debug.h>

#include "amastartsrv.h"

/**

 * Used to create a new CAmaStartServer

 * @return A pointer to the CAmaStartServer

 * @leave One of the system-wide error codes if construction fails.

 */

EXPORT_C CAmaStartServer* CAmaStartServer::NewLC()

	{

	DEBUGPRINT1A( ">CAmaStartServer::NewLC" );

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

	CleanupStack::PushL( self );

	self->ConstructL();

	DEBUGPRINT1A( "CAmaStartServer::NewLC>" );

	return self;	

	}

/**

 * Static function used to create and start CAmaStartServer

 * 

 * @return KErrAlreadyExists if the server is already running

 */

EXPORT_C TInt CAmaStartServer::StartAmaStartSrv()

	{

	DEBUGPRINT1A( ">CAmaStartServer::StartAmaStartSrv" );

	const TInt KAmaStartSrvMinHeapSize = 0x2000;

	const TInt KAmaStartSrvMaxHeapSize = 10 * KAmaStartSrvMinHeapSize;

	RThread srvThread;

	TInt err = srvThread.Create( KAmaStartSrvName, &CAmaStartServer::AmaStartSrvThreadFn, 

								 KDefaultStackSize, KAmaStartSrvMinHeapSize, KAmaStartSrvMaxHeapSize, 

								 NULL, EOwnerProcess );

	if( KErrNone == err )

		{

		TRequestStatus trs;

		srvThread.Rendezvous( trs );

		if ( trs != KRequestPending)

			{

			srvThread.Kill(trs.Int());

			srvThread.Close();

			DEBUGPRINT1A( "CAmaStartServer::StartAmaStartSrv> (Not Request pending)" );

			return trs.Int();

			}

		srvThread.Resume();

		User::WaitForRequest( trs );

		srvThread.Close();

		err = trs.Int();

		}

	DEBUGPRINT1A( "CAmaStartServer::StartAmaStartSrv>" );

	return err;

	}

CAmaStartServer::~CAmaStartServer()

	{

	DEBUGPRINT1A( ">CAmaStartServer::~CAmaStartServer" );

	TInt i = 0;

	TInt count = iSessionInfoArray.Count();

	for(; i < count; i++ )

		{

		delete iSessionInfoArray[ i ].iStarter;

		iSessionInfoArray[ i ].iStarter = NULL;

		}

	iSessionInfoArray.Close();

	DEBUGPRINT1A( "CAmaStartServer::~CAmaStartServer>" );

	}

void CAmaStartServer::StartDscL( const TUid& aDscId, const RMessage2& aMessage, const TInt aSessionIndex )

	{

	DEBUGPRINT1A( ">CAmaStartServer::StartDscL" );

	if( !__IN_RANGE(aSessionIndex, iSessionInfoArray.Count()) )

		{

		User::Leave( KErrArgument );

		}

	iSessionInfoArray[ aSessionIndex ].iStarter = CAmaStartAsync::NewL( aMessage );

	iSessionInfoArray[ aSessionIndex ].iMessagePtr = aMessage;

	iSessionInfoArray[ aSessionIndex ].iStarter->StartL( aDscId );

	DEBUGPRINT1A( "CAmaStartServer::StartDscL>" );

	}

/**

 * Locate the CommandListExecutor associated with the session calling CommandListCancel.

 * Delete the Command list (which cancels its AO) then complete the client's RMessage with KErrCancel.

 */

void CAmaStartServer::StartDscCancel( const TInt aSessionIndex )

	{

	DEBUGPRINT1A( ">CAmaStartServer::StartDscCancel" );

	__ASSERT_DEBUG( __IN_RANGE( aSessionIndex, iSessionInfoArray.Count()), User::Panic( KAmaStartSrvBadIdx, KAmaStartSrvArrayIndexInvalid ) );

	iSessionInfoArray[ aSessionIndex ].iStarter->Cancel();

	DEBUGPRINT1A( "CAmaStartServer::StartDscCancel>" );

	}

/**

 * Iterate through iSessionInfoArray to find an unused array element

 * If found, use it. Otherwise, Append() a new TAmaStartSessionInfo.

 * Called during CSession construction.

 */

void CAmaStartServer::RegisterSessionL( TInt& aSessionIndex )

	{

	DEBUGPRINT1A( ">CAmaStartServer::RegisterSessionL" );

	TInt i = 0;

	TInt count = iSessionInfoArray.Count();

	TBool slotFound = EFalse;

	for(; i < count; i++ )

		{

		if( iSessionInfoArray[ i ].iInUse )

			{

			continue;

			}

		else

			{

			iSessionInfoArray[ i ].iInUse = ETrue;

			iSessionInfoArray[ i ].iStarter = NULL;

			aSessionIndex = i;

			slotFound = ETrue;

			iSessionCount++;

			break;

			}

		}

	if( !slotFound )

		{

		TAmaStartSessionInfo sessionInfo;

		sessionInfo.iStarter = NULL;

		sessionInfo.iInUse = ETrue;

		iSessionInfoArray.AppendL( sessionInfo );

		aSessionIndex = iSessionCount++;

		}

	DEBUGPRINT2A( "Registered in slot %d", aSessionIndex );

	DEBUGPRINT1A( "CAmaStartServer::RegisterSessionL>" );

	}

/**

 * Called from CSession destructor.

 */

void CAmaStartServer::DeregisterSession( const TInt& aSessionIndex )

	{

	DEBUGPRINT1A( ">CAmaStartServer::DeregisterSession" );

	__ASSERT_DEBUG( __IN_RANGE(aSessionIndex, iSessionInfoArray.Count()), User::Panic(KAmaStartSrvBadIdx, KAmaStartSrvArrayIndexInvalid) );

	if( iSessionInfoArray[ aSessionIndex ].iStarter )

		{

		delete iSessionInfoArray[ aSessionIndex ].iStarter;

		iSessionInfoArray[ aSessionIndex ].iStarter = NULL;

		}

	iSessionInfoArray[ aSessionIndex ].iInUse = EFalse;

	iSessionCount--;

	DEBUGPRINT2A( "De-registered slot %d", aSessionIndex );

	DEBUGPRINT1A( "CAmaStartServer::DeregisterSession>" );

	}

/**

 * Used to create a new server-side session.

 * @return A pointer to the new instance of CSession2.

 * @leave KErrNotSupported if versions are incompatible.

 */

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

	{

	DEBUGPRINT1A( ">CAmaStartServer::NewSessionL" );

    CAmaStartServer& mutatedSelf = MUTABLE_CAST( CAmaStartServer&, *this );

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

		{

		User::Leave( KErrNotSupported );

		}

	DEBUGPRINT1A( "CAmaStartServer::NewSessionL>" );

	return CAmaStartSession::NewL( mutatedSelf ); 

	}

CAmaStartServer::CAmaStartServer()

: CServer2( EPriorityHigh, EUnsharableSessions ),

  iVersion( KAmaStartSrvVersionMajor, KAmaStartSrvVersionMinor, KAmaStartSrvVersionBuild )

	{

	DEBUGPRINT1A( ">CAmaStartServer::CAmaStartServer> (Empty constructor)" );

	}

void CAmaStartServer::ConstructL()

	{

	DEBUGPRINT1A( ">CAmaStartServer::ConstructL" );

	StartL( KAmaStartSrvName );

	// The starting thread is signalled in the thread function.

	DEBUGPRINT1A( "CAmaStartServer::ConstructL>" );

	}

// Static functions

TInt CAmaStartServer::AmaStartSrvThreadFn( TAny* /*aAny*/ )

	{

	DEBUGPRINT1A( ">CAmaStartServer::AmaStartSrvThreadFn" );

    CTrapCleanup* cleanup = CTrapCleanup::New();

    TRAPD( err, AmaStartSrvThreadRunL() ); 

    delete cleanup;

    DEBUGPRINT1A( "CAmaStartServer::AmaStartSrvThreadFn>" );

    return err;

	}

void CAmaStartServer::AmaStartSrvThreadRunL()

	{

	DEBUGPRINT1A( ">CAmaStartServer::AmaStartSrvThreadRunL" );

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

    CleanupStack::PushL( sched );

    CActiveScheduler::Install( sched );

    CAmaStartServer* amaStartSrv = CAmaStartServer::NewLC();

    RThread::Rendezvous( KErrNone );

    CActiveScheduler::Start();

    CleanupStack::PopAndDestroy( 2, sched );

    DEBUGPRINT1A( "CAmaStartServer::AmaStartSrvThreadRunL>" );

	} //lint !e529 not subsequently referenced (amaStartSrv)