// Copyright (c) 2004-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\mmu\d_asid.cpp

 // 

 //

 #include <kernel/kern_priv.h>

 #include "d_asid.h"

 //

 // Class definitions

 //

 class DAsidFactory : public DLogicalDevice

 	{

 public:

 	~DAsidFactory();

 	virtual TInt Install();

 	virtual void GetCaps(TDes8& aDes) const;

 	virtual TInt Create(DLogicalChannelBase*& aChannel);

 	};

 class DAsidChannel : public DLogicalChannelBase

 	{

 public:

 	DAsidChannel();

 	~DAsidChannel();

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

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

 public:

 	DAsidFactory*	iFactory;

 private:

 	DThread* iThread;

 	};

 //

 // DAsidFactory

 //

 TInt DAsidFactory::Install()

 	{

 	return SetName(&KMemoryTestLddName);

 	}

 DAsidFactory::~DAsidFactory()

 	{

 	}

 void DAsidFactory::GetCaps(TDes8& /*aDes*/) const

 	{

 	// Not used but required as DLogicalDevice::GetCaps is pure virtual

 	}

 TInt DAsidFactory::Create(DLogicalChannelBase*& aChannel)

 	{

 	aChannel = NULL;

 	DAsidChannel* channel=new DAsidChannel;

 	if(!channel)

 		return KErrNoMemory;

 	channel->iFactory = this;

 	aChannel = channel;

 	return KErrNone;

 	}

 DECLARE_STANDARD_LDD()

 	{

 	return new DAsidFactory;

 	}

 //

 // DAsidChannel

 //

 TInt DAsidChannel::DoCreate(TInt /*aUnit*/, const TDesC8* /*aInfo*/, const TVersion& /*aVer*/)

 	{

 	return KErrNone;

 	}

 DAsidChannel::DAsidChannel() : iThread(NULL)

 	{

 	}

 DAsidChannel::~DAsidChannel()

 	{

 	if (iThread)

 		iThread->Close(NULL);

 	}

 TInt DAsidChannel::Request(TInt aFunction, TAny* a1, TAny* a2)

 	{

 	TInt r=KErrNotSupported;

 	switch(aFunction)

 		{

 		case RAsidLdd::EGetCurrentThread:

 			{

 			DThread* thread = &Kern::CurrentThread();

 			kumemput32(a1, (TAny*)&thread, sizeof(DThread*));

 			r = KErrNone;

 			}

 			break;

 		case RAsidLdd::EOpenThread:

 			{

 			if (iThread)

 				{

 				r = KErrInUse;

 				break;

 				}

 			iThread = (DThread*) a1;

 			iThread->Open();

 			r = KErrNone;

 			}

 			break;

 		case RAsidLdd::ECloseThread:

 			{

 			if (!iThread)

 				{

 				r = KErrNotFound;

 				break;

 				}

 			NKern::ThreadEnterCS();

 			iThread->Close(NULL);

 			iThread = NULL;

 			r = KErrNone;

 			NKern::ThreadLeaveCS();

 			}

 			break;

 		case RAsidLdd::EReadDesHeader:

 			{

 			SDesHeader hdr;

 			TUint8* ptr;

 			kumemget32((TAny*)&hdr, a2, sizeof(SDesHeader));

 			r = Kern::ThreadGetDesInfo((DThread*)a1, hdr.iDes, hdr.iLength, hdr.iMaxLength, ptr, ETrue);

 			if (r == KErrNone)

 				{// copy the data back to user side struct.

 				kumemput32(a2, &hdr, sizeof(SDesHeader));

 				}

 			}

 			break;

 		}

 	return r;

 	}