// 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 "stacked2_plugin.h"

 #include "plugincommon.h"

 /**

 Leaving New function for the plugin

 @internalComponent

  */

 CStacked2Plugin* CStacked2Plugin::NewL()

 	{

 	CStacked2Plugin* self = new(ELeave) CStacked2Plugin;

 	CleanupStack::PushL(self);

 	self->ConstructL();

 	CleanupStack::Pop();

 	return self;

 	}

 /**

 Constructor for the plugin

 @internalComponent

  */

 CStacked2Plugin::CStacked2Plugin() : iInterceptsEnabled(EFalse),

 iLogging(ETrue)

 		{

 		}

 void CStacked2Plugin::ConstructL()

 	{

 	}

 /**

 The destructor for the plugin

 @internalComponent

  */

 CStacked2Plugin::~CStacked2Plugin()

 	{

 	}

 /**

 Initialise the plugin.

 @internalComponent

  */

 void CStacked2Plugin::InitialiseL()

 	{

 	EnableInterceptsL();		

 	}

 /**

 Enable the plugin's intercepts.

 @internalComponent

  */

 void CStacked2Plugin::EnableInterceptsL()

 	{

 	if (iInterceptsEnabled) return;

 	User::LeaveIfError(RegisterIntercept(EFsFileWrite, 		 	EPreIntercept));	

 	_LOG(_L("Stacked2 Plugin: Enabled intercepts."));

 	iInterceptsEnabled = ETrue;

 	}

 /**

 Disable the plugin's intercepts.

 @internalComponent

  */

 void CStacked2Plugin::DisableInterceptsL()

 	{

 	if (!iInterceptsEnabled) return;

 	User::LeaveIfError(UnregisterIntercept(EFsFileWrite,   		EPreIntercept));

 	_LOG(_L("Stacked2 Plugin: Disabled intercepts."));

 	iInterceptsEnabled = EFalse;

 	}

 /**

 Handle requests

 @internalComponent

  */

 TInt CStacked2Plugin::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 CStacked2Plugin::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("CStacked2Plugin::FsFileWriteL, file: %S, pos: %d, length: %d"), &filename, pos, length);

 	if (aRequest.IsPostOperation())

 		{

 		_LOG(_L("CStacked2Plugin::FsFileWriteL, post intercept"));

 		}

 	else

 		{

 		_LOG(_L("CStacked2Plugin::FsFileWriteL, pre intercept"));

 		//set up test data for plugin

 		TBuf8<20> wbuffer;			

 		wbuffer.Copy(_L8("HELLO SYMBIAN WORLD1"));

 		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

 		//read from file		

 		err = fileplugin.Read(pos, tempBufPtr);

 		_LOG2(_L("CStacked2Plugin::FsFileWriteL, RFilePlugin::Read returned %d"), err);

 		iLastError = err;

 		iLineNumber = __LINE__;

 		if(err!=KErrNone)

 			User::Leave(err); //trapped in DoRequestL

 		//lock and unlock file

 		err = fileplugin.Lock(0,2);

 		iLastError = err;

 		iLineNumber = __LINE__;

 		if(err!=KErrNone)

 			User::Leave(err); //trapped in DoRequestL

 		err = fileplugin.UnLock(0,2);

 		iLastError = err;

 		iLineNumber = __LINE__;

 		if(err!=KErrNone)

 			User::Leave(err); //trapped in DoRequestL

 		//check that correct data is still in file

 		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(KErrNone);	

 		}

 	}

 CFsPluginConn* CStacked2Plugin::NewPluginConnL()

 	{

 	return new(ELeave) CStacked2PluginConn();

 	}

 //Synchronous RPlugin::DoControl

 TInt CStacked2Plugin::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 CStacked2PluginConn::DoControl(CFsPluginConnRequest& aRequest)

 	{

 	return ((CStacked2Plugin*)Plugin())->FsPluginDoControlL(aRequest);

 	}

 void CStacked2PluginConn::DoRequest(CFsPluginConnRequest& aRequest)

 	{

 	DoControl(aRequest);

 	}

 void CStacked2PluginConn::DoCancel(TInt /*aReqMask*/)

 	{

 	}

 //factory functions

 class CStacked2PluginFactory : public CFsPluginFactory

 	{

 	public:

 		CStacked2PluginFactory();

 		virtual TInt Install();			

 		virtual CFsPlugin* NewPluginL();

 		virtual CFsPlugin* NewPluginConnL();

 		virtual TInt UniquePosition();

 	};

 /**

 Constructor for the plugin factory

 @internalComponent

  */

 CStacked2PluginFactory::CStacked2PluginFactory()

 	{

 	}

 /**

 Install function for the plugin factory

 @internalComponent

  */

 TInt CStacked2PluginFactory::Install()

 	{

 	//SetSupportedDrives(1<<23);

 	iSupportedDrives = 1<<23;

 	return(SetName(&KStacked2PluginName));

 	}

 /**

 @internalComponent

  */

 TInt CStacked2PluginFactory::UniquePosition()

 	{

 	return(KStacked2Pos);

 	}

 /**

 Plugin factory function

 @internalComponent

  */

 CFsPlugin* CStacked2PluginFactory::NewPluginL()

 	{

 	return CStacked2Plugin::NewL();

 	}

 /**

 Plugin factory function

 @internalComponent

  */

 CFsPlugin* CStacked2PluginFactory::NewPluginConnL()

 	{

 	return CStacked2Plugin::NewL();

 	}

 /**

 Create a new Plugin

 @internalComponent

  */

 extern "C" {

 EXPORT_C CFsPluginFactory* CreateFileSystem()

 		{

 		return(new CStacked2PluginFactory());

 		}

 }