// Copyright (c) 2005-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:

//

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#if !defined(__APA_INTERNAL_H__)

#include "apainternal.h"

#endif

#endif //SYMBIAN_ENABLE_SPLIT_HEADERS

#include "ApaServerAppPriv.h"

void AppServerPanic(TApaAppServerPanic aReason)

	{

	_LIT(KPanic, "ApaAppClient");

	User::Panic(KPanic, aReason);

	}

void CleanupServerName(TAny* aParam)

	{

	HBufC** pServerName = static_cast<HBufC**>(aParam);

	delete *pServerName;

	*pServerName = NULL;

	}

/** Protected constructor, instantiable services must derive from this class.*/

EXPORT_C RApaAppServiceBase::RApaAppServiceBase()

: iServerName(NULL)

	{

	}

/** Closes the service and the connection to the server app.*/

EXPORT_C void RApaAppServiceBase::Close()

	{

	delete iServerName;

	iServerName = NULL;

	RSessionBase::Close();

	}

/** Connects to an already running server application, through an already connected service. 

@param aClient A service which is already connected.*/

EXPORT_C void RApaAppServiceBase::ConnectExistingAppL(const RApaAppServiceBase& aClient)

	{

	__ASSERT_DEBUG(!iServerName, AppServerPanic(EApaAppServerPanicClientAlreadyConnected));

	iServerName = aClient.iServerName->AllocL();

	ConnectL();

	}

/** Connects to an already running server application, through an already connected service. 

@param aClient A service which is already connected.

@param aSecurityPolicy The TSecurityPolicy which should be matched with the TSecurityPolicy of the app to be connected.

@see TSecurityPolicy*/

EXPORT_C void RApaAppServiceBase::ConnectExistingAppL(const RApaAppServiceBase& aClient, const TSecurityPolicy& aSecurityPolicy)

	{

	__ASSERT_DEBUG(!iServerName, AppServerPanic(EApaAppServerPanicClientAlreadyConnected));

	iServerName = aClient.iServerName->AllocL();

	ConnectL(aSecurityPolicy);

	}

/** Connects to an already running server application, by name.

@param aName The name of the server hosted by the server app.*/

EXPORT_C void RApaAppServiceBase::ConnectExistingByNameL(const TDesC& aServerName)

	{

	__ASSERT_DEBUG(!iServerName, AppServerPanic(EApaAppServerPanicClientAlreadyConnected));

	iServerName = aServerName.AllocL();

	ConnectL();

	}

/** Connects to an already running server application, by name.

@param aName The name of the server hosted by the server app.

@param aSecurityPolicy The TSecurityPolicy which should be matched with the TSecurityPolicy of the app to be connected.

@see TSecurityPolicy*/

EXPORT_C void RApaAppServiceBase::ConnectExistingByNameL(const TDesC& aServerName, const TSecurityPolicy& aSecurityPolicy)

	{

	__ASSERT_DEBUG(!iServerName, AppServerPanic(EApaAppServerPanicClientAlreadyConnected));

	iServerName = aServerName.AllocL();

	ConnectL(aSecurityPolicy);

	}

void RApaAppServiceBase::ConnectL()

	{

	CleanupStack::PushL(TCleanupItem(CleanupServerName, &iServerName));

	TUid serviceUid = ServiceUid();

	User::LeaveIfError(CreateSession(*iServerName,*reinterpret_cast<TVersion*>(&serviceUid)));

	CleanupStack::Pop(&iServerName);

	}

void RApaAppServiceBase::ConnectL(const TSecurityPolicy& aSecurityPolicy)

	{

	CleanupStack::PushL(TCleanupItem(CleanupServerName, &iServerName));

	TUid serviceUid = ServiceUid();

	User::LeaveIfError(CreateSession(*iServerName, *reinterpret_cast<TVersion*>(&serviceUid), -1, EIpcSession_Unsharable, &aSecurityPolicy));

	CleanupStack::Pop(&iServerName);

	}

/** Gets the name of the server hosted by the server application.

@return the name of the server application, will be empty if

the service is not connected*/

EXPORT_C TPtrC RApaAppServiceBase::ServerName() const

	{

	if (iServerName)

		{

		return *iServerName;

		}

	else

		{

		return KNullDesC();

		}

	}

/** Requests notification of server application exit.

@param aStatus On completion, this contains the exit code of the server application.

@see CApaServerAppExitMonitor*/

EXPORT_C void RApaAppServiceBase::NotifyServerExit(TRequestStatus& aStatus) const

	{

	SendReceive(EApaAppServerNotifyServerExit,TIpcArgs(),aStatus);

	}

/** Cancels the request for notification of server application exit.*/

EXPORT_C void RApaAppServiceBase::CancelNotifyServerExit() const

	{

	SendReceive(EApaAppServerCancelNotifyServerExit);	

	}

/** Extension mechanism - for internal BC proofing. */

EXPORT_C void RApaAppServiceBase::ExtensionInterface(TUid /*aInterfaceId*/, TAny*& /*aImplementaion*/)

	{

	}

EXPORT_C void RApaAppServiceBase::RApaAppServiceBase_Reserved1()

	{

	}

EXPORT_C void RApaAppServiceBase::RApaAppServiceBase_Reserved2()

	{

	}

/** Transfers the ownership of the session passed to self.

@param aClient A service which is already connected. On return, this service will be reset.

@leave KErrArgument The session passed is not connected.

@panic ApaAppClient 3 The client getting the ownership already has a connected session. Debug builds only.

*/	

EXPORT_C void RApaAppServiceBase::TransferExistingSessionL(RApaAppServiceBase& aClient)

	{

	__ASSERT_DEBUG(!iServerName, AppServerPanic(EApaAppServerPanicClientAlreadyConnected));

	if(aClient.iServerName == NULL)

		{

		User::Leave(KErrArgument);

		}

	if(this != &aClient)

		{

		iServerName = aClient.iServerName;

		iApaReserved1 = aClient.iApaReserved1;

		iApaReserved2 = aClient.iApaReserved2;

		SetHandle(aClient.Handle());

		aClient.iServerName = NULL;

		aClient.SetHandle(0);

		}

	}

//

// CApaServerAppExitMonitor

//

/** Creates a new monitor object and starts monitoring server app lifetime.

@param aClient A connected server app session, which requires monitoring.

@param aObserver An implementer of the MApaServerAppExitObserver that wants to be notified of server app exits.

@param aPriority The active object priority that this monitor should run at.

@return a new instance of a monitor. */

EXPORT_C CApaServerAppExitMonitor* CApaServerAppExitMonitor::NewL(RApaAppServiceBase& aClient, MApaServerAppExitObserver& aObserver, TInt aPriority)

	{

	CApaServerAppExitMonitor* self = new(ELeave) CApaServerAppExitMonitor(aClient, aObserver, aPriority);

	return self;

	}

/** Creates a new monitor object, places it on the cleanup stack and starts monitoring server app lifetime.

@param aClient A connected server app session, which requires monitoring.

@param aObserver An implementer of the MApaServerAppExitObserver that wants to be notified of server app exits.

@param aPriority The active object priority that this monitor should run at.

@return a new instance of a monitor, which is placed on the cleanup stack. */

EXPORT_C CApaServerAppExitMonitor* CApaServerAppExitMonitor::NewLC(RApaAppServiceBase& aClient, MApaServerAppExitObserver& aObserver, TInt aPriority)

	{

	CApaServerAppExitMonitor* self = new(ELeave) CApaServerAppExitMonitor(aClient, aObserver, aPriority);

	CleanupStack::PushL(self);

	return self;

	}

/** The destructor stops monitoring of server app exit. */

EXPORT_C CApaServerAppExitMonitor::~CApaServerAppExitMonitor()

	{

	Cancel();

	}

CApaServerAppExitMonitor::CApaServerAppExitMonitor(RApaAppServiceBase& aClient, MApaServerAppExitObserver& aObserver, TInt aPriority)

: CActive(aPriority), iClient(aClient), iObserver(aObserver)

	{

	CActiveScheduler::Add(this);

	iClient.NotifyServerExit(iStatus);

	SetActive();

	}

void CApaServerAppExitMonitor::RunL()

	{

	TInt reason = iStatus.Int();

	iObserver.HandleServerAppExit(reason);

	}

void CApaServerAppExitMonitor::DoCancel()

	{

	iClient.CancelNotifyServerExit();

	}

TInt CApaServerAppExitMonitor::RunError(TInt aError)

	{

	return aError;

	}