// 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 the License "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:

// LDD for testing nanokernel debug trace bits

// 

//

//#undef __REMOVE_PLATSEC_DIAGNOSTICS__

#include "platform.h"

#include <kernel/kern_priv.h>

#include "u32std.h"

#include "d_kern_msg.h"

const TInt KMajorVersionNumber=0;

const TInt KMinorVersionNumber=1;

const TInt KBuildVersionNumber=1;

class DKernMsgTestFactory : public DLogicalDevice

//

// Kernel msg test LDD factory

//

	{

public:

	DKernMsgTestFactory();

	virtual TInt Install();						//overriding pure virtual

	virtual void GetCaps(TDes8& aDes) const;	//overriding pure virtual

	virtual TInt Create(DLogicalChannelBase*& aChannel);	//overriding pure virtual

	};

class DKernMsgTest : public DLogicalChannelBase

//

// Trace test LDD channel

//

	{

public:

	DKernMsgTest();

	~DKernMsgTest();

protected:

	virtual TInt Request(TInt aReqNo, TAny* a1, TAny* a2);

	virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);

private:

	DThread* iClient;

	TInt iShotNumber;

	TInt iCurShot;

	NTimer iNTimer;

	static void NTimerCallBack(TAny*);

	};

DECLARE_STANDARD_LDD()

	{

	//=== load

    return new DKernMsgTestFactory;

    }

DKernMsgTestFactory::DKernMsgTestFactory()

//

// Constructor

//

    {

	//=== load

    iVersion=TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber);

    }

TInt DKernMsgTestFactory::Create(DLogicalChannelBase*& aChannel)

//

// Create a new DNKTraceTest on this logical device

//

    {

	//=== open

	aChannel=new DKernMsgTest;

    return aChannel?KErrNone:KErrNoMemory;

    }

TInt DKernMsgTestFactory::Install()

//

// Install the LDD - overriding pure virtual

//

    {

	//=== load

    return SetName(&KLddName);

    }

void DKernMsgTestFactory::GetCaps(TDes8& aDes) const

//

// Get capabilities - overriding pure virtual

//

    {

    TCapsTraceTestV01 b;

    b.iVersion=TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber);

    Kern::InfoCopy(aDes,(TUint8*)&b,sizeof(b));

    }

DKernMsgTest::DKernMsgTest()

	: iNTimer(NTimerCallBack, this)

//

// Constructor

//

	//=== open

    {

	// Get pointer to client threads DThread object

	iClient=&Kern::CurrentThread();

	// Open a reference on client thread so it's control block can't dissapear until

	// this driver has finished with it.

	// Note, this call to Open can't fail since its the thread we are currently running in

	iClient->Open();

    }

/**

  Destructor

*/

DKernMsgTest::~DKernMsgTest()

	{

	iNTimer.Cancel();

	// Close our reference on the client thread

	Kern::SafeClose((DObject*&)iClient,NULL);

	}

TInt DKernMsgTest::DoCreate(TInt /*aUnit*/, const TDesC8* /*anInfo*/, const TVersion& aVer)

//

// Create channel

//

    {

	//=== open

    if (!Kern::QueryVersionSupported(TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber),aVer))

    	return KErrNotSupported;

	return KErrNone;

	}

TInt DKernMsgTest::Request(TInt aReqNo, TAny* a1, TAny*)

	{

	TInt r=KErrNotSupported;

	switch (aReqNo)

		{

		case RKernMsgTest::EControlKDebug:

			{

			TBuf8<1024> msg;

			TInt ret=Kern::ThreadDesRead(iClient,a1,msg,0,0);

			if (ret != KErrNone)

				return ret;

			*((char*)msg.Ptr() + msg.Length()) = '\0';

			Kern::Printf("%s", msg.Ptr());

			r = Kern::CurrentThread().iId;

			}

			break;

		case RKernMsgTest::EControlIsrContextTest:

			{

			iShotNumber = (TInt) a1;

			iCurShot = 0;

			iNTimer.OneShot(5);

			r = KErrNone; 

			}

			break;

		default:

			break;

		}

	return r;

	}

void DKernMsgTest::NTimerCallBack(TAny* ptr)

	{

	DKernMsgTest* p = (DKernMsgTest*) ptr;

	if (p->iCurShot++ == p->iShotNumber)

		return;

	Kern::Printf("%d", p->iCurShot);

	p->iNTimer.Again(10);

	}