diff -r 000000000000 -r a41df078684a kerneltest/e32test/system/d_nanowait.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/kerneltest/e32test/system/d_nanowait.cpp Mon Oct 19 15:55:17 2009 +0100 @@ -0,0 +1,193 @@ +// Copyright (c) 1997-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_nanowait.cpp +// LDD for testing nanosecond blocking +// +// + +#include "plat_priv.h" +#include "d_nanowait.h" + +const TInt KMajorVersionNumber=0; +const TInt KMinorVersionNumber=1; +const TInt KBuildVersionNumber=1; + + +// global Dfc Que +TDynamicDfcQue* gDfcQ; + + +class DNanoWaitFactory : public DLogicalDevice +// +// NanoWait LDD factory +// + { +public: + DNanoWaitFactory(); + ~DNanoWaitFactory(); + virtual TInt Install(); //overriding pure virtual + virtual void GetCaps(TDes8& aDes) const; //overriding pure virtual + virtual TInt Create(DLogicalChannelBase*& aChannel); //overriding pure virtual + }; + +class DNanoWait : public DLogicalChannel +// +// nanowait LDD channel +// + { +public: + DNanoWait(); + ~DNanoWait(); +protected: + virtual TInt DoCreate(TInt aUnit, const TDesC8* anInfo, const TVersion& aVer); + TInt DoControl(TInt aFunction, TAny* a1, TAny* a2); + virtual void HandleMsg(TMessageBase* aMsg); +public: + inline DThread* Client() { return iThread; } +public: + DThread* iThread; + }; + + + +DECLARE_STANDARD_LDD() + { + return new DNanoWaitFactory; + } + +DNanoWaitFactory::DNanoWaitFactory() +// +// Constructor +// + { + iVersion=TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber); + //iParseMask=0;//No units, no info, no PDD + //iUnitsMask=0;//Only one thing + } + +TInt DNanoWaitFactory::Create(DLogicalChannelBase*& aChannel) +// +// Create a new DMsTim on this logical device +// + { + aChannel=new DNanoWait; + return aChannel?KErrNone:KErrNoMemory; + } + +const TInt KDNanoWaitThreadPriority = 27; +_LIT(KDNanoWaitThread,"DNanoWaitThread"); + +TInt DNanoWaitFactory::Install() +// +// Install the LDD - overriding pure virtual +// + { + // Allocate a kernel thread to run the DFC + TInt r = Kern::DynamicDfcQCreate(gDfcQ, KDNanoWaitThreadPriority, KDNanoWaitThread); + + if (r != KErrNone) + return r; + + return SetName(&KNanoWaitLddName); + } + +void DNanoWaitFactory::GetCaps(TDes8& aDes) const +// +// Get capabilities - overriding pure virtual +// + { + TCapsNanoWaitV01 b; + b.iVersion=TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber); + Kern::InfoCopy(aDes,(TUint8*)&b,sizeof(b)); + } + +/** + Destructor +*/ +DNanoWaitFactory::~DNanoWaitFactory() + { + if (gDfcQ) + gDfcQ->Destroy(); + } + +DNanoWait::DNanoWait() +// +// Constructor +// + { + iThread=&Kern::CurrentThread(); + iThread->Open(); + } + +TInt DNanoWait::DoCreate(TInt /*aUnit*/, const TDesC8* /*anInfo*/, const TVersion& aVer) +// +// Create channel +// + { + + if (!Kern::QueryVersionSupported(TVersion(KMajorVersionNumber,KMinorVersionNumber,KBuildVersionNumber),aVer)) + return KErrNotSupported; + SetDfcQ(gDfcQ); + iMsgQ.Receive(); + return KErrNone; + } + +DNanoWait::~DNanoWait() +// +// Destructor +// + { + Kern::SafeClose((DObject*&)iThread, NULL); + } + +void DNanoWait::HandleMsg(TMessageBase* aMsg) + { + TInt r=KErrNone; + TThreadMessage& m=*(TThreadMessage*)aMsg; + TInt id=m.iValue; + if (id==(TInt)ECloseMsg) + { + m.Complete(KErrNone,EFalse); + iMsgQ.CompleteAll(KErrServerTerminated); + return; + } + else + { + r=DoControl(id,m.Ptr0(),m.Ptr1()); + } + m.Complete(r,ETrue); + } + +TInt DNanoWait::DoControl(TInt aFunction, TAny* a1, TAny* a2) + { + TInt r=KErrNone; + TInt interval=(TInt)a2; + switch (aFunction) + { + case RNanoWait::EControlStartNanoWait: + { + TInt loopCount=(TInt)a1; + for( int loop = 0; loop < loopCount; loop++) + { + Kern::NanoWait(interval); + } + break; + } + default: + r=KErrNotSupported; + break; + } + return r; + } +