// 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);
	}