--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/kerneltest/f32test/ext/t_bitext.cpp	Mon Oct 19 15:55:17 2009 +0100
@@ -0,0 +1,244 @@
+// Copyright (c) 2002-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:
+// f32test\ext\bitext.cpp
+// extension to do XOR on every byte on 32 byte boundary read or written to media subsystem in same thread
+// therefore RFile::Read/Write does not have this operation carried out on it
+// 
+//
+
+#include <f32fsys.h>
+
+class CBitExtProxyDrive : public CBaseExtProxyDrive
+	{
+public:
+	static CBitExtProxyDrive* NewL(CProxyDrive* aProxyDrive, CMountCB* aMount);
+	~CBitExtProxyDrive();
+public:
+	virtual TInt Initialise();
+	virtual TInt Dismounted();
+	virtual TInt Enlarge(TInt aLength);
+	virtual TInt ReduceSize(TInt aPos, TInt aLength);
+	virtual TInt Read(TInt64 aPos,TInt aLength,const TAny* aTrg,TInt aThreadHandle,TInt anOffset);
+	virtual TInt Read(TInt64 aPos,TInt aLength,TDes8& aTrg);
+	virtual TInt Write(TInt64 aPos,TInt aLength,const TAny* aSrc,TInt aThreadHandle,TInt anOffset);
+	virtual TInt Write(TInt64 aPos,const TDesC8& aSrc);
+	virtual TInt Format(TFormatInfo& anInfo);
+	virtual TInt GetInterface(TInt aInterfaceId,TAny*& aInterface,TAny* aInput);
+private:
+	CBitExtProxyDrive(CProxyDrive* aProxyDrive, CMountCB* aMount);
+private:
+	TInt iReadThread;
+	TInt iRead;
+	TInt iWriteThread;
+	TInt iWrite;
+	TInt iFormat;
+	};
+
+class CBitProxyDriveFactory : public CProxyDriveFactory
+	{
+public:
+	CBitProxyDriveFactory();
+	virtual TInt Install();			
+	virtual CProxyDrive* NewProxyDriveL(CProxyDrive* aProxy,CMountCB* aMount);
+	};
+
+const TUint8 KBitMask=0xcc;
+const TInt KChangePosMask=0x0000001f;
+
+LOCAL_C void DoXOR(TInt aPos,TInt aLength,TUint8* aPtr)
+//
+//
+//
+	{
+	for(TInt i=0;i<aLength;++i)
+		{
+		if(((i+aPos)&KChangePosMask)==0)
+			aPtr[i]^=KBitMask;
+		}
+	}
+
+
+CBitExtProxyDrive* CBitExtProxyDrive::NewL(CProxyDrive* aProxyDrive, CMountCB* aMount)
+//
+//
+//
+	{
+	CBitExtProxyDrive* temp=new(ELeave) CBitExtProxyDrive(aProxyDrive,aMount);
+	return(temp);
+	}
+
+
+CBitExtProxyDrive::CBitExtProxyDrive(CProxyDrive* aProxyDrive, CMountCB* aMount):CBaseExtProxyDrive(aProxyDrive,aMount)
+	{
+	RDebug::Print(_L("CBitExtProxyDrive::CBitExtProxyDrive"));
+	}
+
+CBitExtProxyDrive::~CBitExtProxyDrive()
+//
+//
+//
+	{
+	RDebug::Print(_L("Read Thread = %d"),iReadThread);
+	RDebug::Print(_L("Read = %d"),iRead);
+	RDebug::Print(_L("Write Thread = %d"),iWriteThread);
+	RDebug::Print(_L("Write = %d"),iWrite);
+	RDebug::Print(_L("Format = %d"),iFormat);
+	}
+
+TInt CBitExtProxyDrive::Initialise()
+//
+//
+//
+	{
+	return(CBaseExtProxyDrive::Initialise());
+	}
+
+TInt CBitExtProxyDrive::Dismounted()
+//
+//
+//
+	{
+	return(CBaseExtProxyDrive::Dismounted());
+	}
+
+TInt CBitExtProxyDrive::Enlarge(TInt aLength)
+//
+//
+//
+	{
+	return(CBaseExtProxyDrive::Enlarge(aLength));
+	}
+
+
+TInt CBitExtProxyDrive::ReduceSize(TInt aPos, TInt aLength)
+//
+//
+//
+	{
+	return(CBaseExtProxyDrive::ReduceSize(aPos,aLength));
+	}
+
+TInt CBitExtProxyDrive::Read(TInt64 aPos,TInt aLength,const TAny* aTrg,TInt aThreadHandle,TInt anOffset)
+//
+//
+//
+	{
+	++iReadThread;
+	return(CBaseExtProxyDrive::Read(aPos,aLength,aTrg,aThreadHandle,anOffset));
+	}
+
+TInt CBitExtProxyDrive::Read(TInt64 aPos,TInt aLength,TDes8& aTrg)
+//
+//
+//
+	{
+	++iRead;
+	TInt r=CBaseExtProxyDrive::Read(aPos,aLength,aTrg);
+	DoXOR(I64INT(aPos),aLength,&aTrg[0]);
+	return(r);
+	}
+
+
+TInt CBitExtProxyDrive::Write(TInt64 aPos,TInt aLength,const TAny* aSrc,TInt aThreadHandle,TInt anOffset)
+//
+//
+//
+	{
+	++iWriteThread;
+	return(CBaseExtProxyDrive::Write(aPos,aLength,aSrc,aThreadHandle,anOffset));
+	}
+
+TInt CBitExtProxyDrive::Write(TInt64 aPos,const TDesC8& aSrc)
+//
+//
+//
+	{
+	++iWrite;
+
+	// data may be read-only, so need to copy to a local buffer
+	// before XOR-ing...
+	HBufC8* buf = HBufC8::New( aSrc.Length() );
+	if( !buf )
+		return KErrNoMemory;
+	TPtr8 ptr = buf->Des();
+	ptr.Copy(aSrc);
+
+	DoXOR(I64INT(aPos), ptr.Length(), (TUint8*)ptr.Ptr());
+	TInt r = CBaseExtProxyDrive::Write(aPos, ptr);
+	
+	delete buf;
+
+	return(r);
+	}
+
+TInt CBitExtProxyDrive::Format(TFormatInfo& anInfo)
+//
+//
+//
+	{
+	++iFormat;
+	return(CBaseExtProxyDrive::Format(anInfo));
+	}
+
+
+TInt CBitExtProxyDrive::GetInterface(TInt aInterfaceId,TAny*& aInterface,TAny* aInput)
+	{
+	switch(aInterfaceId)
+		{
+		// file caching supported, so pass query on to next extension
+		case ELocalBufferSupport:
+			return CBaseExtProxyDrive::LocalBufferSupport();
+
+		default:
+			return CBaseExtProxyDrive::GetInterface(aInterfaceId, aInterface, aInput);
+		}
+	}
+
+CBitProxyDriveFactory::CBitProxyDriveFactory()
+//
+//
+//
+	{
+	RDebug::Print(_L("CBitProxyDriveFactory::CBitProxyDriveFactory"));
+	}
+
+TInt CBitProxyDriveFactory::Install()
+//
+//
+//
+	{
+	_LIT(KBitName,"Bitchange");
+	return(SetName(&KBitName));
+	}
+
+
+CProxyDrive* CBitProxyDriveFactory::NewProxyDriveL(CProxyDrive* aProxy,CMountCB* aMount)
+//
+//
+//
+	{
+	return(CBitExtProxyDrive::NewL(aProxy,aMount));
+	}
+
+extern "C" {
+
+EXPORT_C CProxyDriveFactory* CreateFileSystem()
+//
+// Create a new file system
+//
+	{
+	return(new CBitProxyDriveFactory());
+	}
+}
+