diff -r 000000000000 -r bde4ae8d615e os/kernelhwsrv/kerneltest/f32test/plugins/version_2/src/stacked3_plugin.cpp --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/os/kernelhwsrv/kerneltest/f32test/plugins/version_2/src/stacked3_plugin.cpp Fri Jun 15 03:10:57 2012 +0200 @@ -0,0 +1,329 @@ +// Copyright (c) 2007-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: +// + +#include "stacked3_plugin.h" +#include "plugincommon.h" + + +/** +Leaving New function for the plugin +@internalComponent + */ +CStacked3Plugin* CStacked3Plugin::NewL() + { + CStacked3Plugin* self = new(ELeave) CStacked3Plugin; + CleanupStack::PushL(self); + self->ConstructL(); + CleanupStack::Pop(); + return self; + } + + +/** +Constructor for the plugin +@internalComponent + */ +CStacked3Plugin::CStacked3Plugin() : iInterceptsEnabled(EFalse), +iLogging(ETrue) + { + } + + +void CStacked3Plugin::ConstructL() + { + } + +/** +The destructor for the plugin +@internalComponent + */ +CStacked3Plugin::~CStacked3Plugin() + { + } + +/** +Initialise the plugin. +@internalComponent + */ +void CStacked3Plugin::InitialiseL() + { + EnableInterceptsL(); + } + +/** +Enable the plugin's intercepts. +@internalComponent + */ +void CStacked3Plugin::EnableInterceptsL() + { + if (iInterceptsEnabled) return; + + User::LeaveIfError(RegisterIntercept(EFsFileWrite, EPreIntercept)); + + _LOG(_L("Stacked3 Plugin: Enabled intercepts.")); + + iInterceptsEnabled = ETrue; + } + +/** +Disable the plugin's intercepts. +@internalComponent + */ +void CStacked3Plugin::DisableInterceptsL() + { + if (!iInterceptsEnabled) return; + + User::LeaveIfError(UnregisterIntercept(EFsFileWrite, EPreIntercept)); + + _LOG(_L("Stacked3 Plugin: Disabled intercepts.")); + + iInterceptsEnabled = EFalse; + } + +/** +Handle requests +@internalComponent + */ +TInt CStacked3Plugin::DoRequestL(TFsPluginRequest& aRequest) + { + + TInt err = KErrNone; + + TInt function = aRequest.Function(); + + switch(function) + { + case EFsFileRead: + break; + + case EFsFileWrite: + TRAP(err, FsFileWriteL(aRequest)); + break; + + default: + break; + } + + return err; + } + + +/** +@internalComponent + */ +void CStacked3Plugin::FsFileWriteL(TFsPluginRequest& aRequest) + { + TInt length = 0; + TInt64 pos = 0; + TFileName filename; + TParse parse; + + TInt err = aRequest.FileName(filename); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + err = aRequest.Read(TFsPluginRequest::ELength, length); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + err = aRequest.Read(TFsPluginRequest::EPosition, pos); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + parse.Set(filename, NULL, NULL); + + _LOG4(_L("CStacked3Plugin::FsFileWriteL, file: %S, pos: %d, length: %d"), &filename, pos, length); + + if (aRequest.IsPostOperation()) + { + _LOG(_L("CStacked3Plugin::FsFileWriteL, post intercept")); + } + else + { + _LOG(_L("CStacked3Plugin::FsFileWriteL, pre intercept")); + + //set up test data for plugin + TBuf8<20> wbuffer; + wbuffer.Copy(_L8("HELLO WORLD SYMBIAN")); + TInt length = wbuffer.Length(); + + HBufC8* tempBuf = HBufC8::NewMaxLC(length); + TPtr8 tempBufPtr((TUint8 *)tempBuf->Des().Ptr(), length, length); + + RFilePlugin fileplugin(aRequest); + err = fileplugin.AdoptFromClient(); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + //write to file + err = fileplugin.Write(pos, wbuffer); + _LOG2(_L("CStacked3Plugin::FsFileWriteL, RFilePlugin::Write returned %d"), err); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + //read from file + err = fileplugin.Read(pos, tempBufPtr); + _LOG2(_L("CStackedPlugin::FsFileWriteL, RFilePlugin::Read returned %d"), err); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + //testing the correct thing has been written to the drive + err = wbuffer.Compare(tempBufPtr); + iLastError = err; + iLineNumber = __LINE__; + if(err!=KErrNone) + User::Leave(err); //trapped in DoRequestL + + fileplugin.Close(); + CleanupStack::PopAndDestroy(); + + // send request down the stack + User::Leave(KErrCompletion); + } + } + + +CFsPluginConn* CStacked3Plugin::NewPluginConnL() + { + return new(ELeave) CStacked3PluginConn(); + } + + +//Synchronous RPlugin::DoControl +TInt CStacked3Plugin::FsPluginDoControlL(CFsPluginConnRequest& aRequest) + { + TInt err = KErrNone; + TPckg<TInt> errCodeDes(iLastError); + TPckg<TInt> lineNumberDes(iLineNumber); + + TInt function = aRequest.Function(); + switch(function) + { + case KPluginSetDrive: + { + TPckg<TChar> drive(iDriveToTest); + TRAP(err,aRequest.ReadParam1L(drive)); + break; + } + case KPluginGetError: + { + TRAP(err,aRequest.WriteParam1L(errCodeDes)); + TRAP(err,aRequest.WriteParam2L(lineNumberDes)); + break; + } + default: + break; + } + + return err; + } + +TInt CStacked3PluginConn::DoControl(CFsPluginConnRequest& aRequest) + { + return ((CStacked3Plugin*)Plugin())->FsPluginDoControlL(aRequest); + } + +void CStacked3PluginConn::DoRequest(CFsPluginConnRequest& aRequest) + { + DoControl(aRequest); + } + +void CStacked3PluginConn::DoCancel(TInt /*aReqMask*/) + { + } + +//factory functions + +class CStacked3PluginFactory : public CFsPluginFactory + { + public: + CStacked3PluginFactory(); + virtual TInt Install(); + virtual CFsPlugin* NewPluginL(); + virtual CFsPlugin* NewPluginConnL(); + virtual TInt UniquePosition(); + }; + +/** +Constructor for the plugin factory +@internalComponent + */ +CStacked3PluginFactory::CStacked3PluginFactory() + { + } + +/** +Install function for the plugin factory +@internalComponent + */ +TInt CStacked3PluginFactory::Install() + { + //SetSupportedDrives(1<<23); + iSupportedDrives = 1<<23; + return(SetName(&KStacked3PluginName)); + } + +/** +@internalComponent + */ +TInt CStacked3PluginFactory::UniquePosition() + { + return(KStacked3Pos); + } + +/** +Plugin factory function +@internalComponent + */ +CFsPlugin* CStacked3PluginFactory::NewPluginL() + + { + return CStacked3Plugin::NewL(); + } + +/** +Plugin factory function +@internalComponent + */ +CFsPlugin* CStacked3PluginFactory::NewPluginConnL() + + { + return CStacked3Plugin::NewL(); + } + +/** +Create a new Plugin +@internalComponent + */ +extern "C" { + +EXPORT_C CFsPluginFactory* CreateFileSystem() + { + return(new CStacked3PluginFactory()); + } +} +