/*

* Copyright (c) 2004 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:  Implementation

*

*/

#include "CTcWatcherSession.h"

#include "CTcWatcherServer.h"

#include "CTcCoroner.h"

#include "CTcGrimreaper.h"

#include "WatcherConstants.h"

CTcWatcherSession* CTcWatcherSession::NewL(

#ifndef __IPC_V2_PRESENT__

 											RThread& aClient,

#endif

 										    CTcWatcherServer* aServer )

	{

	CTcWatcherSession* self =

#ifdef __IPC_V2_PRESENT__

							  new( ELeave ) CTcWatcherSession;

#else

							  new( ELeave ) CTcWatcherSession( aClient );

#endif

	CleanupStack::PushL( self );

	self->ConstructL( aServer );

	CleanupStack::Pop();

	return self;

	}

CTcWatcherSession::~CTcWatcherSession()

	{

	delete iCoroner;

	delete iGrimreaper;

	iWatcherServer->SessionRemoved();

	}

CTcWatcherSession::CTcWatcherSession()

	{

	}

void CTcWatcherSession::ConstructL( CTcWatcherServer* aServer )

	{

#ifndef __IPC_V2_PRESENT__

	CreateL( *aServer );

#endif

	iWatcherServer = aServer;

	iWatcherServer->SessionAdded();

	}

#ifdef __IPC_V2_PRESENT__

void CTcWatcherSession::ServiceL( const RMessage2& aMessage )

#else

void CTcWatcherSession::ServiceL( const RMessage& aMessage )

#endif

	{

	// Any leaves from this function will be catched by the Active Scheduler

	// and forwarded to CTcWatcher::RunError().

	// Check for session related requests

	TInt status( KErrNone );

	switch( aMessage.Function() )

		{

		case ECloseSession:

			{

			// Session destruction is handled

			// by the client-server framework.

			delete iCoroner;

			iCoroner = NULL;

			delete iGrimreaper;

			iGrimreaper = NULL;

			break;

			}

		case EConfigAndStart:

			{

			RThread clientThread;

#ifdef __IPC_V2_PRESENT__

			aMessage.Client( clientThread );

			CleanupClosePushL( clientThread );

			aMessage.ReadL( 0, iAppName );

			iCoroner = CTcCoroner::NewL( clientThread, iAppName, *iWatcherServer );

			iGrimreaper = CTcGrimreaper::NewL( clientThread, aMessage.Int1() );

			CleanupStack::PopAndDestroy();

#else

			aMessage.ReadL( aMessage.Ptr0(), iAppName );

			iCoroner = CTcCoroner::NewL( Client(), iAppName, *iWatcherServer );

			iGrimreaper = CTcGrimreaper::NewL( Client(), aMessage.Int1() );

#endif

			break;

			}

		case EPing:

			{

			iGrimreaper->NotYet();

			break;

			}

		default:

			{

			// Unknown request

			status = KErrUnknown;

			}

		}

	aMessage.Complete( status );

	}