kerneltest/e32test/system/d_atomic.cpp
author Tom Cosgrove <tom.cosgrove@nokia.com>
Fri, 28 May 2010 16:29:07 +0100
changeset 30 8aab599e3476
parent 0 a41df078684a
permissions -rw-r--r--
Fix for bug 2283 (RVCT 4.0 support is missing from PDK 3.0.h) Have multiple extension sections in the bld.inf, one for each version of the compiler. The RVCT version building the tools will build the runtime libraries for its version, but make sure we extract all the other versions from zip archives. Also add the archive for RVCT4.

// Copyright (c) 2008-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:
// e32test\system\d_atomic.cpp
// LDD for testing atomic operations
// 
//

#include <kernel/kern_priv.h>
#include "t_atomic.h"

class DAtomicTest;
struct TPerThreadK : public TPerThread
	{
	TAny* iOldExtraContext;
	const SSlowExecEntry* iOldSlowExecTable;
	DAtomicTest* iCh;
	TInt iId;
	};


class DAtomicTestFactory : public DLogicalDevice
	{
public:
	DAtomicTestFactory();
	~DAtomicTestFactory();
	virtual TInt Install();
	virtual void GetCaps(TDes8& aDes) const;
	virtual TInt Create(DLogicalChannelBase*& aChannel);
public:
	};


class DAtomicTest : public DLogicalChannelBase
	{
public:
	virtual ~DAtomicTest();
protected:
	virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer);
	virtual TInt Request(TInt aFunction, TAny* a1, TAny* a2);
private:
	void SetupExecTable();
	static TInt XGetThreadInfo(TAny* aDest);
	static TInt XSetThreadInfo(const TAny* aSrc);
	static TInt XAtomicAction(TAny* aPtr);
	static TInt XRestore();
private:
	TUint64A	iReg;
	TPerThreadK	iPerThread[KMaxThreads];
	TUint32		iXT[19];
	};


DAtomicTestFactory::DAtomicTestFactory()
	{
	}

DAtomicTestFactory::~DAtomicTestFactory()
	{
	}
TInt DAtomicTestFactory::Create(DLogicalChannelBase*& aChannel)
	{
	aChannel = new DAtomicTest;
	return KErrNone;
	}

TInt DAtomicTestFactory::Install()
	{
	return SetName(&KAtomicTestLddName);
	}

void DAtomicTestFactory::GetCaps(TDes8& aDes) const
	{
	// Not used but required as DLogicalDevice::GetCaps is pure virtual
	}

DECLARE_STANDARD_LDD()
	{
	return new DAtomicTestFactory;
	}


TInt DAtomicTest::DoCreate(TInt /*aUnit*/, const TDesC8* /*aInfo*/, const TVersion& /*aVer*/)
	{
	SetupExecTable();
	return KErrNone;
	}

DAtomicTest::~DAtomicTest()
	{
	}

void DAtomicTest::SetupExecTable()
	{
	NThread* t = NKern::CurrentThread();
	SSlowExecTable& sxt = *(SSlowExecTable*)iXT;
	const SSlowExecTable& orig_sxt = *_LOFF(t->iSlowExecTable, SSlowExecTable, iEntries);
	sxt.iSlowExecCount = 4;		// get thread info, set thread info, atomic action, restore exec table
	sxt.iInvalidExecHandler = orig_sxt.iInvalidExecHandler;
	sxt.iPreprocessHandler = 0;	// not used
	sxt.iEntries[0].iFlags = 0;		// don't do anything special on entry or exit
	sxt.iEntries[0].iFunction = (TLinAddr)&XGetThreadInfo;
	sxt.iEntries[1].iFlags = 0;		// don't do anything special on entry or exit
	sxt.iEntries[1].iFunction = (TLinAddr)&XSetThreadInfo;
	sxt.iEntries[2].iFlags = 0;		// don't do anything special on entry or exit
	sxt.iEntries[2].iFunction = (TLinAddr)&XAtomicAction;
	sxt.iEntries[3].iFlags = 0;		// don't do anything special on entry or exit
	sxt.iEntries[3].iFunction = (TLinAddr)&XRestore;
	}

TInt DAtomicTest::Request(TInt aFunction, TAny* a1, TAny* a2)
	{
	TInt r = KErrNotSupported;
	switch (aFunction)
		{
		case RTestAtomic::ETDGExecuteK:
			{
			TDGBase tdg;
			kumemget32(&tdg, a1, sizeof(tdg));
			r = tdg.Execute();
			kumemput32(a1, &tdg, sizeof(tdg));
			break;
			}
		case RTestAtomic::EInitialise:
			{
			kumemget32(&iReg, a1, sizeof(TUint64));
			break;
			}
		case RTestAtomic::ERetrieve:
			{
			kumemput32(a1, &iReg, sizeof(TUint64));
			break;
			}
		case RTestAtomic::ESetCurrentThreadTimeslice:
			{
			NKern::ThreadSetTimeslice(NKern::CurrentThread(), NKern::TimesliceTicks((TInt)a1));
			r = KErrNone;
			break;
			}
		case RTestAtomic::ESwitchExecTables:
			{
			TUint tid = (TUint)a1;
			NThread* nt = NKern::CurrentThread();
			DThread& t = Kern::CurrentThread();
			if (Kern::NThreadToDThread(nt)==&t && tid<TUint(KMaxThreads))
				{
				TPerThreadK* p = iPerThread + tid;
				p->iOldExtraContext = nt->iExtraContext;
				p->iOldSlowExecTable = nt->iSlowExecTable;
				p->iId = tid;
				p->iCh = this;
				nt->iExtraContext = p;
				SSlowExecTable& sxt = *(SSlowExecTable*)iXT;
				nt->iSlowExecTable = sxt.iEntries;
				r = KErrNone;
				}
			break;
			}
		case RTestAtomic::EGetKernelMemoryAddress:
			{
			r = (TInt)NKern::CurrentThread();	// if we trash this the test should go bang
			break;
			}
		default:
			break;
		}
	return r;
	}

TInt DAtomicTest::XGetThreadInfo(TAny* aDest)
	{
	NThread* t = NKern::CurrentThread();
	TPerThreadK* p = (TPerThreadK*)t->iExtraContext;
	kumemput32(aDest, p, sizeof(TPerThread));
	return KErrNone;
	}

TInt DAtomicTest::XSetThreadInfo(const TAny* aSrc)
	{
	NThread* t = NKern::CurrentThread();
	TPerThreadK* p = (TPerThreadK*)t->iExtraContext;
	kumemget32(p, aSrc, sizeof(TPerThread));
	return KErrNone;
	}

TInt DAtomicTest::XAtomicAction(TAny* aPtr)
	{
	NThread* t = NKern::CurrentThread();
	TPerThreadK* p = (TPerThreadK*)t->iExtraContext;
	TAtomicAction action;
	kumemget32(&action, aPtr, sizeof(TAtomicAction));
	if (action.iThread!=p->iId || TUint(action.iIndex)>=TUint(TOTAL_INDEXES))
		return KErrNotSupported;
	return DoAtomicAction(&p->iCh->iReg, p, action);
	}

TInt DAtomicTest::XRestore()
	{
	NThread* t = NKern::CurrentThread();
	TPerThreadK* p = (TPerThreadK*)t->iExtraContext;
	t->iExtraContext = p->iOldExtraContext;
	t->iSlowExecTable = p->iOldSlowExecTable;
	return KErrNone;
	}