--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/e32test/smpsoak/d_smpsoak.cpp	Thu Jan 07 13:38:45 2010 +0200
@@ -0,0 +1,185 @@
+// Copyright (c) 2002-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:
+//
+// e32test\smpsoak\d_smpsoak.cpp
+//
+
+// LDD for smpsoak - setting Thread CPU Affinity
+//
+
+#include "d_smpsoak.h"
+#include <platform.h>
+#include <kernel/kern_priv.h>
+
+const TInt KMajorVersionNumber=0;
+const TInt KMinorVersionNumber=1;
+const TInt KBuildVersionNumber=1;
+
+class DSmpSoakFactory : public DLogicalDevice
+//
+// IPC copy LDD factory
+//
+	{
+public:
+	DSmpSoakFactory();
+	virtual TInt Install();						//overriding pure virtual
+	virtual void GetCaps(TDes8& aDes) const;	//overriding pure virtual
+	virtual TInt Create(DLogicalChannelBase*& aChannel);	//overriding pure virtual
+	};
+
+class DSmpSoak : public DLogicalChannelBase
+	{
+public:
+	DSmpSoak();
+	virtual ~DSmpSoak();
+protected:
+	virtual TInt DoCreate(TInt aUnit, const TDesC8* aInfo, const TVersion& aVer);
+	virtual TInt Request(TInt aReqNo, TAny* a1, TAny* a2);
+public:
+	static void IDfcFn(TAny* aPtr);
+public:
+	void OccupyCpus();
+	};
+
+DECLARE_STANDARD_LDD()
+	{
+	Kern::Printf("DSmpSoak called");
+    return new DSmpSoakFactory;
+    }
+
+DSmpSoakFactory::DSmpSoakFactory()
+//
+// Constructor
+//
+    {
+	Kern::Printf("DSmpSoakFactory::DSmpSoakFactory called");
+    iVersion=TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber);
+    }
+
+TInt DSmpSoakFactory::Create(DLogicalChannelBase*& aChannel)
+//
+// Create a new DSmpSoak on this logical device
+//
+    {
+	Kern::Printf("DSmpSoakFactory::Create called");
+	aChannel=new DSmpSoak;
+    return aChannel?KErrNone:KErrNoMemory;
+    }
+
+TInt DSmpSoakFactory::Install()
+//
+// Install the LDD - overriding pure virtual
+//
+    {
+	Kern::Printf("DSmpSoakFactory::Install called");
+    return SetName(&KSmpSoakLddName);
+    }
+
+void DSmpSoakFactory::GetCaps(TDes8& aDes) const
+//
+// Get capabilities - overriding pure virtual
+//
+    {
+    Kern::Printf("DSmpSoakFactory::GetCaps called");
+    }
+
+DSmpSoak::DSmpSoak()
+//
+// Constructor
+//
+	{
+	Kern::Printf("DSmpSoak::DSmpSoak called");
+	}
+
+DSmpSoak::~DSmpSoak()
+	{
+	Kern::Printf("DSmpSoak::~DSmpSoak called");
+	}
+
+TInt DSmpSoak::DoCreate(TInt /*aUnit*/, const TDesC8* /*anInfo*/, const TVersion& aVer)
+//
+// Create channel
+//
+    {
+	Kern::Printf("DSmpSoak::DoCreate called");
+
+    if (!Kern::QueryVersionSupported(TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber),aVer))
+    	return KErrNotSupported;
+	
+	return KErrNone;
+	}
+
+
+TInt DSmpSoak::Request(TInt aFunction, TAny* a1, TAny* a2)
+	{
+	DThread *pT = NULL;
+	NThread *pMyNThread = NULL;
+	TInt handle = (TInt)a1;
+	TInt priority = (TInt)a2;
+
+	TInt r = KErrNotSupported;
+	Kern::Printf("DSmpSoak::Request called aFunction = %d, a1 = %d, a2 = %d", aFunction, a1, a2);
+
+	switch (aFunction)
+		{
+		case RSMPSoak::KGETPROCESSORCOUNT:
+			r = NKern::NumberOfCpus();
+			Kern::Printf("DSmpSoak::Request Processor count = %d", r);
+			break;
+		case RSMPSoak::KGETCURRENTCPU:
+			r = NKern::CurrentCpu();
+			Kern::Printf("DSmpSoak::Request Current CPU = %d", r);
+			break;
+		case RSMPSoak::KGETCURRENTTHREAD:
+			r = (TInt)NKern::CurrentThread();
+			Kern::Printf("DSmpSoak::Request Current Thread %02x", r);
+			break;
+		case RSMPSoak::KTHREADSETCPUAFFINITY:
+			r = NKern::ThreadSetCpuAffinity(NKern::CurrentThread(), (TInt)a1);
+			r = (TInt)NKern::CurrentCpu();
+			Kern::Printf("DSmpSoak::Request Current Cpu = %d", r);
+			break;
+		case RSMPSoak::KOCCUPYCPUS:
+			Kern::Printf("DSmpSoak::Request OCCUPYCPUS: called");
+			OccupyCpus();
+			break;
+		case RSMPSoak::KCHANGEAFFINITY:
+			Kern::Printf("DSmpSoak::Request CHANGEAFFINITY");
+			NKern::LockSystem();
+			pT=(DThread*)Kern::CurrentThread().ObjectFromHandle(handle);
+			pMyNThread=(NThread*)&pT->iNThread;
+			NKern::ThreadSetCpuAffinity((NThread*)pMyNThread, (TInt)a2);
+			NKern::UnlockSystem();
+			break;
+		case RSMPSoak::KCHANGETHREADPRIORITY:
+			Kern::Printf("DSmpSoak::Request CHANGETHREADPRIORITY");
+			NKern::LockSystem();
+			pT=(DThread*)Kern::CurrentThread().ObjectFromHandle(handle);
+			Kern::Printf("DSmpSoak::Request Current Thread %d", pT);
+			pT->SetThreadPriority(priority);
+			Kern::Printf("DSmpSoak::CHANGETHREADPRIORITY now  %d", pT->iThreadPriority);
+			NKern::UnlockSystem();
+			break;
+		default:
+			Kern::Printf("DSmpSoak::Request default: called");
+			break;
+		}
+	return r;
+	}
+
+void DSmpSoak::OccupyCpus()
+	{
+	Kern::Printf(">>>DSmpSoak::OccupyCpus()");
+	}
+
+
+