// Copyright (c) 2003-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:
// CStartServer Client side header
// Implements an active object to asynchronously start server process,
// 
//

/**
 @file
 @internalAll
*/

#include "CA_StartServer.h"
#include "CS_AsyncConnect.h"

EXPORT_C CStartServer::CStartServer(RAsyncConnectBase& aAsyncConnectBase, const TVersion& aVersion, TInt aAsyncMessageSlots) :
CActive(EPriorityStandard),
iAsyncConnectBase(aAsyncConnectBase),
iVersion(aVersion),
iAsyncMessageSlots(aAsyncMessageSlots)
/**
* Constructor
*
* @internalTechnology
*
* @param aAsyncConnectBase the client side server object
* @param aVersion the desired version of the server
* @param aAsyncMessageSlots number of messages to allocate in client server message queue
*
*/
	{
	CActiveScheduler::Add(this);
	}

EXPORT_C CStartServer::~CStartServer()
	{
	Cancel();
	}

EXPORT_C void CStartServer::Cancel()
   {
	iStartProcess.Cancel();
   }

void CStartServer::DoCancel()
	{//never !!
   __ASSERT_DEBUG( EFalse, User::Panic( KNullDesC, KErrGeneral ) );
	}

void CStartServer::RunL()
	{
   if ( iStartProcess.ErrorCode() == KErrCancel )
      {//request has been canceled
		User::RequestComplete(iClientStatus, KErrCancel);
      }
	else if (!iProcessStarting && (iStatus.Int()==KErrNotFound || iStatus.Int()==KErrServerTerminated))
		{
      iProcessStarting = 1;
		iStartProcess.Start(iName, iStatus);
      SetActive();
		//wait for the server to start
		}
	else if (iProcessStarting && ((iStatus.Int() == KErrAlreadyExists && ++iCounter < iAttempts) || iStatus.Int() == KErrNone))
		{
		Connect(iName);
		//wait for the Connect to complete
		}
	else
		{//complete the connection with an error
		User::RequestComplete(iClientStatus, iStatus.Int());
		}
	}

void CStartServer::Connect(const TDesC& aServerName)
	{
	iAsyncConnectBase.CreateSession(aServerName, iVersion, iAsyncMessageSlots, iStatus);
   iName.Des().Copy( aServerName );
   iProcessStarting = 0;
	SetActive();
	}

EXPORT_C void CStartServer::Connect(const TDesC& aServerName, TRequestStatus& aStatus, TUint aAttempts)
/**
* The Start method
*
* Connect the Handle to the Server and asynchronously starts the server if neccessary
*
* @internalTechnology
*
* @param aServerName name of the server, no file extension
* @param aStatus a request of the client waiting for server to connect
* @param aAttempts how many times to try to connect
*
*/
	{
	iAttempts = aAttempts;
	iClientStatus = &aStatus;
	*iClientStatus = KRequestPending;
	iCounter = 0;
	Connect(aServerName);
	}