--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/debug/d_kern_msg.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,194 @@
+// 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);
+	}