--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/testconns/statapi/device/source/statapi/src/dataconsumer_file.cpp	Mon Oct 04 02:58:21 2010 +0300
@@ -0,0 +1,283 @@
+/*
+* Copyright (c) 2005-2009 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "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: 
+*
+*/
+
+
+
+ /*************************************************************************
+ *
+ * System Includes
+ *
+ *************************************************************************/
+
+#include <e32std.h>
+#include <e32base.h>
+#include <f32file.h>
+/*************************************************************************
+ *
+ * Local Includes
+ *
+ *************************************************************************/
+
+#include "dataconsumer_file.h"
+#include "stat.h"
+/*************************************************************************
+ *
+ * Definitions
+ *
+ *************************************************************************/
+_LIT( KTxtDiskError, "DiskError" );
+
+/*************************************************************************
+ *
+ * CDataConsumerFile - Construction
+ *
+ *************************************************************************/
+CDataConsumerFile *CDataConsumerFile::NewL()
+	{
+	CDataConsumerFile *self = new (ELeave) CDataConsumerFile();
+
+	CleanupStack::PushL(self);
+
+	self->ConstructL();
+
+	CleanupStack::Pop();
+
+	return self;
+	}
+
+CDataConsumerFile::CDataConsumerFile()
+	{
+	;
+	}
+
+void CDataConsumerFile::ConstructL( void ) 
+	{
+	
+	_LIT(KFileSrvDll, "efsrv.dll");
+	_LIT(KFileSeparator, "\\");
+	TBuf<8> systemDrive;
+
+	iLock.CreateLocal( EOwnerProcess );
+
+	User::LeaveIfError( iFsSession.Connect( ) );
+	
+	TDriveNumber defaultSysDrive(EDriveC);
+	RLibrary pluginLibrary;
+	TInt pluginErr = pluginLibrary.Load(KFileSrvDll);
+	
+	if (pluginErr == KErrNone)
+		{
+		typedef TDriveNumber(*fun1)();
+		fun1 sysdrive;
+	
+	#ifdef __EABI__
+		sysdrive = (fun1)pluginLibrary.Lookup(336);
+	#else
+		sysdrive = (fun1)pluginLibrary.Lookup(304);
+	#endif
+		
+		if(sysdrive!=NULL)
+			{
+			defaultSysDrive = sysdrive();
+			}
+		}
+	pluginLibrary.Close();
+	
+	systemDrive.Append(TDriveUnit(defaultSysDrive).Name());
+	systemDrive.Append(KFileSeparator);
+	
+
+	RFile	file;
+
+	TInt err = file.Temp( iFsSession, systemDrive,iFilePath, EFileShareExclusive );
+
+	file.Close( );
+
+	User::LeaveIfError( err );
+	}
+
+
+
+CDataConsumerFile::~CDataConsumerFile( )
+	{
+	iLock.Wait( );
+		{
+		iFsSession.Close();
+
+		iLock.Close( );
+		}
+	}
+
+/*************************************************************************
+ *
+ * CDataConsumerFile - Public interface
+ *
+ *************************************************************************/
+
+/*************************************************************************
+ *
+ * Delete
+ *
+ *************************************************************************/
+
+void CDataConsumerFile::Delete( void ) 
+	{
+	delete this;
+	}
+
+/*************************************************************************
+ *
+ * GetTotalSize
+ *
+ *************************************************************************/
+
+TInt CDataConsumerFile::GetTotalSize( TInt &aTotalSize )
+	{
+	TInt	err = KErrNone;
+	TInt	size = 0;
+
+	iLock.Wait( );
+		{
+		RFile	file;
+
+		err = file.Open( iFsSession, iFilePath, EFileRead | EFileStream | EFileShareReadersOnly );
+
+		if( err == KErrNone )
+			{
+			err = file.Size( size );
+
+			if( err == KErrNone )
+				{
+				aTotalSize = size;
+				}
+
+			file.Close( );
+			}
+
+        iLock.Signal( );
+		}
+
+	return ( err );
+	}
+
+/*************************************************************************
+ *
+ * AddData
+ *
+ *************************************************************************/
+
+TInt CDataConsumerFile::AddData( const TDesC8 &aSource )
+	{
+	TInt	err = KErrNone;
+
+	if( err == KErrNone )
+		{
+		iLock.Wait( );
+			{
+			RFile	file;
+			TInt	shareMode = EFileWrite | EFileStream | EFileShareExclusive;
+
+			err = file.Open( iFsSession, iFilePath, shareMode );
+
+			if( err == KErrNotFound )
+    			{
+    			err = file.Create( iFsSession, iFilePath, shareMode );
+    			}
+
+			if( err == KErrNone )
+				{
+				TInt pos = 0;
+				err = file.Seek( ESeekEnd, pos );
+	
+				if( err == KErrNone )
+					{
+					err = file.Write( aSource );
+					}
+
+				file.Flush( );
+				file.Close( );
+				}
+
+            if( err != KErrNone )
+                {
+                err = iFsSession.Delete(iFilePath);
+                User::Panic(KTxtDiskError, err);
+                }
+
+			iLock.Signal( );
+			}
+		}
+
+	return ( err );
+	}
+
+/*************************************************************************
+ *
+ * GetData
+ *
+ *************************************************************************/
+
+TInt CDataConsumerFile::GetData( HBufC8 & )
+	{
+	return ( KErrNotSupported );
+	}
+
+/*************************************************************************
+ *
+ * SaveData
+ *
+ *************************************************************************/
+
+TInt CDataConsumerFile::SaveData( const TDesC &filePath )
+	{
+	TInt	err = KErrNone;
+
+	if( err == KErrNone )
+		{
+		iLock.Wait( );
+			{
+			
+				CFileMan *theFile = CFileMan::NewL(iFsSession);
+				CleanupStack::PushL(theFile);
+				
+				err = theFile->Copy( iFilePath, filePath );
+				
+				if( err == KErrNone )
+					{
+					err = theFile->Delete(iFilePath);	
+					}
+				
+				CleanupStack::PopAndDestroy();
+
+			iLock.Signal( );
+			}
+		}
+
+	return ( err );
+	}
+
+/*************************************************************************
+ *
+ * operator const TDesC8&
+ *
+ *************************************************************************/
+
+CDataConsumerFile::operator const TDesC8&( void ) const
+	{
+	_LIT8( empty, "" );
+	return ( empty );
+	}