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

//

/**

 @file

 @internalComponent - Internal Symbian test code  

*/

#include "messageservsession.h"

const TInt STOP_SERVER_CODE	= 0xff;

/**

   Constructor - passes client to CSession.

 */

CMessageServSession::CMessageServSession(CMessageServServer * aServer)

	: CSession2()//aClient)

	{

	__DECLARE_NAME(_S("CMessageServSession"));

	iMsgSvr=aServer;

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method creates a Server session for a client thread aClient.

 */

CMessageServSession* CMessageServSession::NewL(CMessageServServer * aServer)

	{

	return new(ELeave) CMessageServSession(aServer);

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method handles the servicing of client requests to the message server.

   The message is serviced by calling CMessageServSession::DispatchMessageL()

   and signals completion of the client request by invoking RMessage::Complete().

 */

void CMessageServSession::ServiceL(const RMessage2& aMessage)

	{

	TRAPD(err,DispatchMessageL(aMessage));

	aMessage.Complete(err);

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method services the client requests to the message server.

   The opcode is checked and does approprate servicing by invoking methods

   SetFromStringL() and SetErrorFromStringL().

 */

void CMessageServSession::DispatchMessageL(const RMessage2 &aMessage)

	{

	switch (aMessage.Function())

        {

	case EMessageServSetFromString:

		SetFromStringL(aMessage);

		return;

	case EMessageServSetErrorFromString:

		SetErrorFromStringL(aMessage);

		return;

	case EMessageServStop:

		{	

			CActiveScheduler::Stop();

			iMsgSvr->iMessageProvider->Message()->RequestForTheMessageOutput(STOP_SERVER_CODE);

			return;

		}

	// requests we don't understand at all are a different thing,

	// so panic the client here, this function also completes the message

	default:

		PanicClient(EBadRequest);

		return;

        }

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method services Error message received from the client to the message

   server. It reads Error message, filename, line number and error code from

   the message

 */

void CMessageServSession::SetErrorFromStringL(const RMessage2 &aMessage)

	{

	TInt res;

	//const TAny* pD=aMessage.Ptr0();

	TInt desLen=aMessage.GetDesLength(0);

	HBufC* writeBuf=HBufC::New(desLen);

	TPtr initptr = writeBuf->Des();

	TRAP(res,aMessage.ReadL(0,initptr));

	//const TAny* pD1=aMessage.Ptr1();

	TInt desLen1=aMessage.GetDesLength(1);//pD1);

	HBufC8* writeBuf1=HBufC8::New(desLen1);

	TPtr8 initptr1 = writeBuf1->Des();

	TRAP(res,aMessage.ReadL(1,initptr1));

	const TInt lineNumber = aMessage.Int2();

	const TInt errorCode = aMessage.Int3();

	// read the contents of the client pointer into a TPtr.

	if (res!=KErrNone)

		PanicClient(EBadDescriptor);

	iMsgSvr->iMessageProvider->Message()->iError = errorCode;

	iMsgSvr->iMessageProvider->Message()->iLineNumber = lineNumber;

	iMsgSvr->iMessageProvider->Message()->iMsg.Copy(initptr);

	iMsgSvr->iMessageProvider->Message()->iFileName.Copy(initptr1);

	delete writeBuf;

	delete writeBuf1;

	iMsgSvr->iMessageProvider->Message()->RequestForTheMessageOutput(errorCode);

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method demonstrates reading message from the client address space to

   the server. It reads filename, line number and descriptor content from

   the message

 */

void CMessageServSession::SetFromStringL(const RMessage2 &aMessage)

	{

	TInt res;

	//const TAny* pD=aMessage().Ptr0();

	TInt desLen=aMessage.GetDesLength(0);

	HBufC* writeBuf=HBufC::New(desLen);

	TPtr initptr = writeBuf->Des();

	TRAP(res,aMessage.ReadL(0,initptr));

	//const TAny* pD1=Message().Ptr1();

	TInt desLen1=aMessage.GetDesLength(1);

	HBufC8* writeBuf1=HBufC8::New(desLen1);

	TPtr8 initptr1 = writeBuf1->Des();

	TRAP(res,aMessage.ReadL(1,initptr1));

	const TInt lineNumber = aMessage.Int2();

	// read the contents of the client pointer into a TPtr.

	if (res!=KErrNone)

		PanicClient(EBadDescriptor);

	iMsgSvr->iMessageProvider->Message()->iLineNumber = lineNumber;

	iMsgSvr->iMessageProvider->Message()->iMsg.Copy(initptr);

	iMsgSvr->iMessageProvider->Message()->iFileName.Copy(initptr1);

	delete writeBuf;

	delete writeBuf1;

	iMsgSvr->iMessageProvider->Message()->RequestForTheMessageOutput();

	}

/**

   Auxiliary function for TestCaseID TPACKAGESTARTER-doTestStepL

   This method is used to Panic the client thread

 */

void CMessageServSession::PanicClient(TInt aPanic) const

	{

	_LIT(KTxtServer,"CountServ server");

	User::Panic(KTxtServer,aPanic);

	}