persistentstorage/sql/SRC/Server/SqlBur.cpp
author hgs
Tue, 19 Oct 2010 16:26:13 +0100
changeset 55 44f437012c90
parent 51 7d4490026038
permissions -rw-r--r--
201041_01

// Copyright (c) 2005-2010 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:
//

#include "SqlBur.h"
#include "SqlAssert.h"
#include "OstTraceDefinitions.h"
#ifdef OST_TRACE_COMPILER_IN_USE
#include "SqlBurTraces.h"
#endif
#include "SqlTraceDef.h"

#define UNUSED_ARG(arg) arg = arg

_LIT(KSqlBurBackupExt,  ".bak");
_LIT(KSqlBurRestoreDir, "temprestore");
_LIT(KSqlBurAllFiles,   "*");

const TUint K8to16bitShift = 1;

//Extracts and returns 32-bit integer from aNumBuf buffer.
static TUint32 GetNumUint32L(const TDesC& aNumBuf)
	{
	TLex lex(aNumBuf);
	lex.SkipSpace();
	TUint32 num = 0xFFFFFFFF;
	__SQLLEAVE_IF_ERROR2(lex.Val(num, EHex));
	return num;
	}

//Extracts and returns 64-bit integer from aNumBuf buffer.
static TInt64 GetNumInt64L(const TDesC& aNumBuf)
	{
	TLex lex(aNumBuf);
	lex.SkipSpace();
	TInt64 num = -1;
	__SQLLEAVE_IF_ERROR2(lex.Val(num, EHex));
	return num;
	}

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////   CSqlBurEventMonitor    //////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 
Standard two phase construction. Creates a CSqlBurEventMonitor instance.
@param aInterface A reference to an interface that is used for retrieving list of databases to be sent for backup.
@return An instance of the backup notifier
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
CSqlBurEventMonitor* CSqlBurEventMonitor::NewL(MSqlSrvBurInterface& aInterface)
	{
	CSqlBurEventMonitor* self = new (ELeave) CSqlBurEventMonitor(aInterface);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_NEWL, "0x%X;CSqlBurEventMonitor::NewL", (TUint)self));
	return self;
	}

/**
Releases the allocated resources.
*/
CSqlBurEventMonitor::~CSqlBurEventMonitor()
	{
	SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_CSQLBACKUPNOTIFIER2, "0x%X;CSqlBurEventMonitor::~CSqlBurEventMonitor", (TUint)this));
	Cancel();
	iBurProperty.Close();
	DestroyContent();
	}

/**
Initializes data members with their default values. 
@param aInterface A reference to an interface that is used for retrieving list of databases to be sent for backup.
*/		
CSqlBurEventMonitor::CSqlBurEventMonitor(MSqlSrvBurInterface& aInterface) :
	CActive(EPriorityStandard), 
	iBurInterface(aInterface)
	{
	}

/**
Initializes the created CSqlBurEventMonitor object.  
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/	
void CSqlBurEventMonitor::ConstructL()
	{
	__SQLLEAVE_IF_ERROR(iBurProperty.Attach(KSqlBurPropertyCategoryUid, KSqlBurBackupRestoreKey));
	CActiveScheduler::Add(this);
	iBurProperty.Subscribe(iStatus);
	SetActive();
	}

/** 
RunL() is called when the value of the {KUidSystemCategory, KUidBackupRestoreKey} gets changed.
That indicates: a backup or a restore is about to begin or about to end.

How the function works:
 - When a backup or restore notification is received, the function will subscribe again for notifications from
   the backup and restore property and will read the property status;
 - If the property status is conn::EBURUnset or conn::EBURNormal, the function will destroy iSqlBurCallback
   and iActiveBackupClient interfaces. No more callbacks will be reseived from the backup and restore server.
   This is the end of the backup or restore processing;
 - If the property status is conn::EBURBackupFull, conn::EBURBackupPartial, conn::EBURRestoreFull or 
   conn::EBURRestorePartial, the function will create iSqlBurCallback and iActiveBackupClient interface
   (iActiveBackupClient's NewL() receives iSqlBurCallback as an input parameter, registering this way the callback
   in the backup and restore server to be called later, when sending or retrieving data to/from the server).
   If the property read and the interface creation operations have been successful, the function will call 
   ConfirmReadyForBURL(KErrNone) to notify the backup and restore server that the SQL server is ready to send/retrieve 
   backup/restore data.
   If the current notification is that a backup is about to begin, after the confirmation the backup and restore server will
   call CSqlBurCallback::InitialiseGetProxyBackupDataL() once per {client secure id, drive} 
   followed by CSqlBurCallback::GetBackupDataSectionL() calls to retrieve the backup data. 
   If the current notification is that a restore is about to begin, after the confirmation the backup and restore server will
   call CSqlBurCallback::InitialiseRestoreProxyBaseDataL() once per {client secure id, drive} 
   followed by CSqlBurCallback::RestoreBaseDataSectionL() calls to send the restore data.
     
The current implementation has one design flaw. If a backup or restore notification is received, there are at lest 3
places before the ConfirmReadyForBURL() call, where the code may leave: 
 - the "property get" operation;
 - the iSqlBurCallback creation;
 - the iActiveBackupClient creation;
If a leave occurs at some of the mentioned places, that leave will be trapped by the current CActiveScheduler object
and CSqlBurEventMonitor::RunError() will be called with the leaved error code.
Problem #1: CSqlBurEventMonitor::RunError() won't do anything with the error (apart from printing a trace in the OST builds).
            The error is silently suppressed. The backup or restore won't start. But the client won't see any notification
            for that problem.
Problem #2: ConfirmReadyForBURL() won't be called. According to the backup and restore documentation, if
            ConfirmReadyForBURL() is called with KErrNone parameter, that's a confirmation for the backup and restore
            server to start the processing. If ConfirmReadyForBURL() is called with an error different than KErrNone,
            that's a confirmation for the backup and restore server that the client is not ready. No backup or restore
            will be started. The remote backup client will be notified about the problem.
After an investigation it was found that the same problems do exist in all active backup clients, none of them has 
solved the problems. Then, the code here will be kept as it is, it might be too dangerous to do a change right now.

@see CSqlBurEventMonitor::RunError()
@see CSqlBurCallback
@see CActiveBackupClient
@see CSqlBurCallback::InitialiseGetProxyBackupDataL()
@see CSqlBurCallback::GetBackupDataSectionL()
@see CSqlBurCallback::InitialiseRestoreProxyBaseDataL()
@see CSqlBurCallback::RestoreBaseDataSectionL()

@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
void CSqlBurEventMonitor::RunL()
	{
	SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_RUNL_ENTRY, "Entry;0x%X;CSqlBurEventMonitor::RunL", (TUint)this));
	iBurProperty.Subscribe(iStatus);
	SetActive();
	TInt status;
	__SQLLEAVE_IF_ERROR(iBurProperty.Get(status));
	status &= conn::KBURPartTypeMask;
#ifdef _SQL_RDEBUG_PRINT
	SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_RUNL1, "0x%X;CSqlBurEventMonitor::RunL;status=%d", (TUint)this, status));
#else
	SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_RUNL2, "0x%X;CSqlBurEventMonitor::RunL;status=%{TBURPartType}", (TUint)this, status));
#endif	    
	switch(status)
		{
		case conn::EBURBackupFull:
		case conn::EBURBackupPartial:
		case conn::EBURRestoreFull:
		case conn::EBURRestorePartial:
			{
			// we only do full backups and full restores
			if(!(iSqlBurCallback && iActiveBackupClient))
				{
				DestroyContent();
				TRAPD(err, CreateContentL());
				if(err != KErrNone)
					{
					DestroyContent();
					__SQLLEAVE(err);
					}
				}
			iActiveBackupClient->ConfirmReadyForBURL(KErrNone);
			}
			break;
		//case conn::EBURUnset:
		//case conn::EBURNormal:
		default:
			DestroyContent();
			break;
		}
	SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPNOTIFIER_EXIT, "Exit;0x%X;CSqlBurEventMonitor::RunL", (TUint)this));
	SQL_BUR_TEST_STOP();
	}

/** 
Cancels the subscribtion for {KUidSystemCategory, KUidBackupRestoreKey} property changes.
*/
void CSqlBurEventMonitor::DoCancel()
	{
	iBurProperty.Cancel();
	}

/**
No-op. The method does nothing with the reported from CSqlBurEventMonitor::RunL() error  
(apart from logging a trace in OST builds).
Actually, the right action is to return KErrNone (as it is implemented), otherwise the default implementation of 
CActiveScheduler::Error() will panic the current thread.

@see CActiveScheduler::Error()
@see CSqlBurEventMonitor::RunL()
 
@return The RunL() error, if the RunL() call leaves.
@param The RunL() error
*/
TInt CSqlBurEventMonitor::RunError(TInt aError)
	{
	UNUSED_ARG(aError);
	SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RUNERROR, "0x%X;CSqlBurEventMonitor::RunError;aError=%d", (TUint)this, aError));
	SQL_BUR_TEST_SET_ERROR(aError); 
	SQL_BUR_TEST_STOP();
	return KErrNone;
	}

/**
Creates iActiveBackupClient and iSqlBurCallback objects.
*/
void CSqlBurEventMonitor::CreateContentL()
	{
	iSqlBurCallback = CSqlBurCallback::NewL(iBurInterface);
	iActiveBackupClient = conn::CActiveBackupClient::NewL(iSqlBurCallback);
	}

/**
Destroys iActiveBackupClient and iSqlBurCallback objects.
*/
void CSqlBurEventMonitor::DestroyContent()
	{
	delete iActiveBackupClient;
	iActiveBackupClient = NULL;
	delete iSqlBurCallback;
	iSqlBurCallback = NULL;
	}

///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////////   CSqlBurCallback    //////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////


/** 
Creates new CSqlBurCallback instance.
The CSqlBurEventMonitor object monitors the state of the {KUidSystemCategory, KUidBackupRestoreKey} 
property. When a backup or a restore is about to begin, the CSqlBurEventMonitor object creates a
CSqlBurCallback instance, establishes a connection with the B&R server and passes a pointer to
the CSqlBurCallback callback to the BYR conenction.
The CSqlBurCallback methods will be called during the backup/restore for sending/retrieving data.
    
@param aInterface A reference to an interface that is used for retrieving list of databases to be sent for backup.
@return A pointer to the created CSqlBurCallback instance
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
CSqlBurCallback* CSqlBurCallback::NewL(MSqlSrvBurInterface& aInterface)
	{
	CSqlBurCallback* self = new (ELeave) CSqlBurCallback(aInterface);
	SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPCLIENT_NEWLC, "0x%X;CSqlBurCallback::NewL", (TUint)self));
	return self;
	}

/**
Initializes CSqlBurCallback data members with their default values. 
@param aInterface A reference to an interface that is used for retrieving list of databases to be sent for backup.
*/		
CSqlBurCallback::CSqlBurCallback(MSqlSrvBurInterface& aInterface) :
	iInterface(aInterface)
	{
	}

/** 
Releases the allocated resources.
*/
CSqlBurCallback::~CSqlBurCallback()
	{
	SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_CSQLBACKUPCLIENT2, "0x%X;CSqlBurCallback::~CSqlBurCallback;iFile.SubSessionHandle()=0x%X", (TUint)this, (TUint)iFile.SubSessionHandle()));
	BackupCleanup();
	(void)RestoreCleanup();
	}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/////////////////////////////////////       Full backup   //////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 
This is called to let us know that the given SID is to be backed up.
We ask the SQL server (using iInterface, see MSqlSrvBurInterface for more details) 
for a list of databases that want to be backed up.

The backup is initiated by a notification received in CSqlBurEventMonitor::RunL() method.
InitialiseGetProxyBackupDataL() is called once per {client secure id, drive} and each 
InitialiseGetProxyBackupDataL() call is followed after that by a set of CSqlBurCallback::GetBackupDataSectionL() calls,
made from the backup and restore client dll.

During GetBackupDataSectionL() calls the CSqlBurCallback object will read the content of the databases from the list,
retrieved from the MSqlSrvBurInterface::GetBackUpListL() call and send the content to the backup and restore server.     

@see MSqlSrvBurInterface
@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::GetBackupDataSectionL()
@see CSqlServer::GetBackUpListL() 

@param aSid the UID of the application to backup
@param aDrive the drive to be backed up
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
void CSqlBurCallback::InitialiseGetProxyBackupDataL(TSecureId aSid, TDriveNumber aDrive)
	{
	SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_INITIALIZEGETPROXYBACKUPDATAL, "0x%X;CSqlBurCallback::InitialiseGetProxyBackupDataL;aSid=0x%X;aDrive=%d", (TUint)this, (TUint)aSid.iId, (TInt)aDrive));
	BackupCleanup();
	iInterface.GetBackUpListL(aSid, aDrive, iFileList);
	iFileIndex = 0;
	iState = EBackupNoFileOpen;
	iBackupError = KErrNone;
	}

/** 
This is supposed to allow the B&R framework to know in advance how much
data is coming - but unfortunately there is no way to know this
at this stage since we don't even know yet what SID is being processed
So we just answer some number to make the BUE happy. It doesn't
actually rely on this number so there is no risk - the aFinishedFlag
indicates the end of data, not the value returned here. It is
supposed to allow the BUE to optimise its behaviour by know up front
the data volume.

@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::InitialiseGetProxyBackupDataL()

@param aDrive Unused parameter (the drive number is logged in OST builds).
@return an arbitrary number (1024 at the moment)
*/
TUint CSqlBurCallback::GetExpectedDataSize(TDriveNumber aDrive)
	{
	UNUSED_ARG(aDrive);
	// we have no idea at this point - we even don't know who is to be backed up yet
	const TUint KArbitraryNumber = 1024;
	SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETEXPECTEDDATASIZE, "0x%X;CSqlBurCallback::GetExpectedDataSize;aDrive=%d;rc=%u", (TUint)this, (TInt)aDrive, KArbitraryNumber));
	return KArbitraryNumber;
	}

/** 
This is the backup state machine
Because the data has to be sent back in sections and the various
components of the dataflow may straddle chunks, we have to keep
track of where we are between each transfer - a state machine is
the simplest and most understandable implementation.

Please note how the function processes the errors occuring during the backup.
If an error occurs, the error is not propagated back to the B&R server immediatelly.
The error is stored in iBurError data member and is reported at the end of the backup process.
The reason for such unusual error reporting poicy is: the SQL server performs full backup of possibly more
than one database file. If an error occurs during the backup of the first file for example, the backup
process should not stop at that point. All files will be processed and then at the end, the error will be reproted.

In details, the function runs a state machine, where:
 - every file in the list retrieved in InitialiseGetProxyBackupDataL() is opened;
 - the file is read and 32-bit checksum over the file data - calculated;
 - a file backup header is prepared, including there the file size, file name, file name length, protocol verison number
   and the checksum. The header is sent to the backup restore server;
 - the file data is read and sent to the backup and restore server;
 - during the described above sequence no leave ever occurs. The error that occurs during the file processing,
   is stored into a data member of CSqlBurCallback class. At the end, after the last file in the list is processed,
   the backup and restore server will get a notification (via a User::Leave() call) regarding the error;
   The used error reporting policy allows all files to be process without interrupting the backup process.
   For example, if there are 5 files to be sent to the backup and restore server, an error that occurs during the 
   processing of file #3, won't prevent files #4 and #5 from being sent for backup.       

@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::InitialiseGetProxyBackupDataL()

@param aBuffer Output parameter, the buffer where the data will be put to be passed back
@param aFinishedFlag Set to true when all data has been submitted for backup
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
void CSqlBurCallback::GetBackupDataSectionL(TPtr8& aBuffer, TBool& aFinishedFlag)
	{
	// don't assume they set it to false
	aFinishedFlag=EFalse;
	// any files to backup
	if(iFileList.Count()==0)
		{
		// nothing to backup
		SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL1, "0x%X;CSqlBurCallback::GetBackupDataSectionL;file count is 0", (TUint)this));
		aFinishedFlag = ETrue;
		BackupCleanup();
		return;
		}

	// run the state machine
	for(TInt bufFreeSpace=aBuffer.MaxSize()-aBuffer.Size(); bufFreeSpace>0; bufFreeSpace=aBuffer.MaxSize()-aBuffer.Size())
		{
		switch(iState)
			{
			case EBackupNoFileOpen: // open a file for processing
				{
				if(iFileIndex>=iFileList.Count())
					{// all files have been processed - send the finished flag
					SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL2, "0x%X;CSqlBurCallback::GetBackupDataSectionL;all files processed;iBackupError=%d", (TUint)this, iBackupError));
					aFinishedFlag = ETrue;
					BackupCleanup();
					__SQLLEAVE_IF_ERROR(iBackupError);
					return;
					}
				// open the database file to send
				TPtrC fname = iFileList[iFileIndex]->Des();
				TInt err = iFile.Open(iInterface.Fs(), fname, EFileRead | EFileShareExclusive);
				SQL_TRACE_BUR(OstTraceExt5(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL3, "0x%X;CSqlBurCallback::GetBackupDataSectionL;BEGIN;fname=%S;iFileIndex=%d;iFile.SubSessionHandle()=0x%X;err=%d", (TUint)this, __SQLPRNSTR(fname), iFileIndex, (TUint)iFile.SubSessionHandle(), err));
				if(KErrNone != err)
					{
					// there's nothing we can do if we can't open the file so we just skip it
					SetBackupError(err);
					++iFileIndex;
					break;
					}
				iState=EBackupOpenNothingSent;
				break;
				}
			case EBackupOpenNothingSent: // nothing sent (so far) for this file - send the header info
				{
				TInt64 fileSize;
				TInt err = iFile.Size(fileSize);
				if(KErrNone != err)
					{
					SetBackupError(err);
					iState = EBackupEndOfFile;
					break;
					}
				
				TUint64 checksum64 = 0;
				err = CheckSum(iFile, checksum64);
				SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL4, "0x%X;CSqlBurCallback::GetBackupDataSectionL;CheckSum();iFileIndex=%d;err=%d", (TUint)this, iFileIndex, err));
				if(err != KErrNone)
					{
					//An error occured while reading the file (or there was not enough memory for the read buffer)
					SetBackupError(err);
					iState = EBackupEndOfFile;
					break;
					}
				// Only grab last 4 bytes of the checksum - enough to be satisfied that the backup and restore worked ok
				TUint32 checksum32 = checksum64 & KMaxTUint32;

                // build the header - this is an instance member because it
                // has to persist over multiple calls to this method
				TPtrC fname = iFileList[iFileIndex]->Des();
				iBuffer.Format(_L("%8x%8x%4x%16lx%8x%S"),
					checksum32,					// %8x
					KSqlBurMagicNum,			// %8x
					KSqlBurHeaderVersion,		// %4x
					fileSize,					// %16lx
					fname.Length(),				// %8x
					&fname);					// %S
				SQL_TRACE_BUR(OstTraceExt4(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL5, "0x%X;CSqlBurCallback::GetBackupDataSectionL;fileName=%S;hdrPtr=|%S|;fileSize=%lld", (TUint)this, __SQLPRNSTR(fname), __SQLPRNSTR(iBuffer), fileSize));
				
				// we need it to look like an 8bit buffer
				TPtr8 hdrPtr8((TUint8*)iBuffer.Ptr(), iBuffer.Size(), iBuffer.Size());
							
				TInt len = Min(hdrPtr8.Size(), bufFreeSpace);
				
				// append the header to the buffer (only till it's full)
				aBuffer.Append(hdrPtr8.Ptr(), len);
				
				// decide what needs to happen next
				// if complete then we need data, otherwise we need to put
				// the rest of the header in the next chunk
				if(hdrPtr8.Size() <= bufFreeSpace)
					{
					iState = EBackupOpenAllHeaderSent;
					}
				else
					{
					// we need to keep track of how much of the header has
					// been sent so that we only send the reminder on the next
					// iteration
					iHeaderSent = len;
					iState = EBackupOpenPartHeaderSent;
					}
				break;
				}
			case EBackupOpenPartHeaderSent: // need to send the rest of the header
				{
				// get back the header - this is already loaded with the necessary info
				// from the previous state we were in - EBackupOpenNothingSent
				
				// we need it to look like an 8bit buffer
				TPtr8 hdrPtr8((TUint8*)iBuffer.Ptr(), iBuffer.Size(), iBuffer.Size());
				
				// how many bytes have we yet to send?
				TInt bytesRemaining = hdrPtr8.Size() - iHeaderSent;
				TInt len = Min(bytesRemaining, bufFreeSpace);
				aBuffer.Append(hdrPtr8.Ptr() + iHeaderSent, len);
				
				if(bytesRemaining <= bufFreeSpace)
					{
					iHeaderSent = 0; // ready for next header
					iState = EBackupOpenAllHeaderSent;
					}
				else
					{
					iHeaderSent += len; // ready to do round again
					//iState=EBackupOpenPartHeaderSent; same state as now!
					}
				break;
				}
			case EBackupOpenAllHeaderSent: // need to send some data
				{
				TPtr8 ptr((TUint8*)aBuffer.Ptr() + aBuffer.Size(), 0, bufFreeSpace);
				TInt err = iFile.Read(ptr);
				if(err != KErrNone)
					{
					//An error occured while reading the file 
					SetBackupError(err);
					iState = EBackupEndOfFile;
					SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL6, "0x%X;CSqlBurCallback::GetBackupDataSectionL;File read;iFileIndex=%d;err=%d", (TUint)this, iFileIndex, err));
					break;
					}
				TInt bytesRead = ptr.Size();
				aBuffer.SetLength(aBuffer.Size() + bytesRead);
				// EOF
				if(bytesRead == 0)
					{
					iState = EBackupEndOfFile;
					break;
					}
				break;
				}
			case EBackupEndOfFile:
				{
				SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_GETBACKUPDATASECTIONL7, "0x%X;CSqlBurCallback::GetBackupDataSectionL;END;iFile.SubSessionHandle()=0x%X;iFileIndex=%d", (TUint)this, (TUint)iFile.SubSessionHandle(), iFileIndex));
				iFile.Close();
				++iFileIndex; // move on to next file
				iState = EBackupNoFileOpen; // go round again
				break;
				}
			default:
				__ASSERT_DEBUG(EFalse, __SQLPANIC(ESqlPanicInternalError));
				break;
			}//end of the "switch" statement
		}//end of the "for" statement
	}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
/////////////////////////////////////       Full restore   /////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 
Called when the BUE wants to start sending data to us.
Creates the folder (if the folder does not exist) where the temporary files will be created during the restore process.
Deletes all files from the restore folder.

The restore is initiated by a notification received in CSqlBurEventMonitor::RunL() method.
InitialiseRestoreProxyBaseDataL() is called once per {client secure id, drive} and each 
InitialiseRestoreProxyBaseDataLL() call is followed after that by a set of CSqlBurCallback::RestoreBaseDataSectionL() 
calls, made from the backup and restore client dll.

During RestoreBaseDataSectionLL() calls the CSqlBurCallback object will receive data from the backup and resore server.     

@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::RestoreBaseDataSectionL()

@param aSid the UID of the application that is to be restored. Not used (only logged in OST builds).
@param aDrive the drive to restore.
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
void CSqlBurCallback::InitialiseRestoreProxyBaseDataL(TSecureId aSid, TDriveNumber aDrive)
	{
	UNUSED_ARG(aSid);
	UNUSED_ARG(aDrive);
	SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_INITIALIZERESTOREPROXYBASEDATAL, "0x%X;CSqlBurCallback::InitialiseRestoreProxyBaseDataL;aSid=0x%X;aDrive=%d", (TUint)this, (TUint)aSid.iId, (TInt)aDrive));
	iBuffer.Zero();
	iState = ERestoreExpectChecksum;
	iRestoreDrive = aDrive;
	iRestoreId = aSid;
	//Create the directory for the temporary files created during the restore process.
	TFileName privatePath;
	__SQLLEAVE_IF_ERROR(iInterface.Fs().PrivatePath(privatePath));
	TDriveUnit driveUnit(iRestoreDrive);
	TDriveName driveName = driveUnit.Name();
	privatePath.Insert(0, driveName);
	__SQLLEAVE_IF_ERROR(iParse.Set(KSqlBurRestoreDir, &privatePath, 0));
	iRestoreDir.Copy(iParse.FullName());
	iRestoreDir.Append(KPathDelimiter);
	TInt err = iInterface.Fs().MkDirAll(iRestoreDir);
	if(err != KErrAlreadyExists)
		{
		__SQLLEAVE_IF_ERROR(err);
		}
	//Cleanup the restore directory
	err = RestoreCleanup();
	if(err != KErrNotFound)
		{
		__SQLLEAVE_IF_ERROR(err);
		}
	}

/** 
This is called by BUE when the restore has completed.

@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::InitialiseRestoreProxyBaseDataL()

@param aDrive the drive that is being restored. Not used (only logged in OST builds).
*/
void CSqlBurCallback::RestoreComplete(TDriveNumber aDrive)
	{
	UNUSED_ARG(aDrive);
	SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTORECOMPLETE, "0x%X;CSqlBurCallback::RestoreComplete;aDrive=%d", (TUint)this, (TInt)aDrive));
	iRestoreDrive = TDriveNumber(-1);
	iRestoreId = TSecureId(KNullUid);
	}

/** 
This is repeatedly called by the BUE to send us chunks of restore data (for the current SID)
Becuase the data is spread over chunks we need to manage the state across mutiple calls
to this method so we use a state machine.

The function runs the state machine and for each file block detected in the coming data, the function does:
 - creates a temporary file in the restore directory (created by InitialiseRestoreProxyBaseDataL());
 - stores the file data in the created temporary file;
 - During the 2 steps descirbed above, if an error occurs, that erro will be reproted to the backup and restore
   server (via a User::Leave() call);
 - When all data is received and stored in temporary files in the restore directory, 
   for each received file the function will:
   = move the original database file to the restore directory with a ".bak" extension added to the file name;
   = move the temporary file, which has the same name as the original database file, to the location of the
     original database file - the SQL server private data cage;
   = delete the file with the ".bak" extension;
   The three steps described above are implemented as "all or none" operation - if an error occurs during step (2),
   the content of the original database file will be restored from the file with the ".bak" extension.   

@see CSqlBurEventMonitor::RunL()
@see CSqlBurCallback::InitialiseRestoreProxyBaseDataL()

@param aInBuffer Buffer with data to be restored
@param aFinishedFlag Set when there is not more data to restore
@leave  KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also leave with some other system-wide error codes.
*/
void CSqlBurCallback::RestoreBaseDataSectionL(TDesC8& aInBuffer, TBool aFinishedFlag)
	{
	// used to walk the buffer
	// got a new buffer - because each time this method is called, we have a
	// fresh chunk of data
	TInt inBufferPos = 0;

	// to mark when the state machine is through
	TBool done = EFalse;
	
	// check whether this is an empty restore
	if(aFinishedFlag && aInBuffer.Size() == 0)
		{
		return;
		}

	TInt iterations = 0;
	
	// run the state machine
	do
		{
		// how many bytes are there available in the buffer for processing?
		TInt bytesAvailable = aInBuffer.Size() - inBufferPos;
		// the reason why we are testing finishedFlag is because we must
		// make sure we re-enter the machine to do the tidyup
		if(bytesAvailable <= 0 && !aFinishedFlag)
			{
			// ran out of data in the chunk
			// so we return and wait for more data to arrive
			return;
			}
		switch(iState)
			{
			case ERestoreExpectChecksum: // 16 bytes (the header is UTF16 encoded, 8 unicode characters for the checksum)
				{
				const TInt KCheckSumStrLen = 8;
				CopyBufData(aInBuffer, inBufferPos, iBuffer, KCheckSumStrLen);
				if(iBuffer.Length() == KCheckSumStrLen)
					{
					iChecksum = ::GetNumUint32L(iBuffer);
					iState = ERestoreExpectOldFileSize;
					iBuffer.Zero();
					}
				break;
				}
			case ERestoreExpectOldFileSize: // 16 bytes (the header is UTF16 encoded, 8 unicode characters for 32-bit old file size)
				{
				const TInt KOldFileSizeStrLen = 8;
				CopyBufData(aInBuffer, inBufferPos, iBuffer, KOldFileSizeStrLen);
				if(iBuffer.Length() == KOldFileSizeStrLen)
					{
					TUint32 oldFileSize = ::GetNumUint32L(iBuffer);
					if(oldFileSize == KSqlBurMagicNum)
						{
						iState = ERestoreExpectVersion;
						}
					else
						{
						iFileSize = oldFileSize;	
						iState = ERestoreExpectFileNameSize;
						}
					iBuffer.Zero();
					}
				break;
				}	
			case ERestoreExpectVersion:
				{
				const TInt KVersionStrLen = 4;
				CopyBufData(aInBuffer, inBufferPos, iBuffer, KVersionStrLen);
				if(iBuffer.Length() == KVersionStrLen)
					{
					//Ignore the version: ::GetNumUint32L(iBuffer);	
					//At this stage we know that the version is 2+
					iState = ERestoreExpectFileSize;
					iBuffer.Zero();
					}
				break;
				}
			case ERestoreExpectFileSize:
				{
				const TInt KFileSizeStrLen = 16;
				CopyBufData(aInBuffer, inBufferPos, iBuffer, KFileSizeStrLen);
				if(iBuffer.Length() == KFileSizeStrLen)
					{
					iFileSize = GetNumInt64L(iBuffer);	
					iState = ERestoreExpectFileNameSize;
					iBuffer.Zero();
					}
				SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL1, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;iFileSize=%lld", (TUint)this, iFileSize));
				break;
				}
			case ERestoreExpectFileNameSize: // the size of the file name to restore
				{
				const TInt KFileNameLenStrLen = 8;
				CopyBufData(aInBuffer, inBufferPos, iBuffer, KFileNameLenStrLen);
				if(iBuffer.Length() == KFileNameLenStrLen)
					{
					iFileNameSize = GetNumUint32L(iBuffer);		
					iState = ERestoreExpectFileName;
					iBuffer.Zero();
					}
				break;
				}
			case ERestoreExpectFileName:  // the name of the file to restore
				{
				CopyBufData(aInBuffer, inBufferPos, iBuffer, iFileNameSize);
				SQL_TRACE_BUR(OstTraceExt4(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL2, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;BEGIN;iBuffer=%S;iBuffer.Length()=%d;iFileNameSize=%d", (TUint)this, __SQLPRNSTR(iBuffer), iBuffer.Length(), iFileNameSize));
				if(iBuffer.Length() == iFileNameSize)
					{
					iState = ERestoreExpectData;
					TParse parse;
					__SQLLEAVE_IF_ERROR(parse.Set(iBuffer, 0, 0));
					__SQLLEAVE_IF_ERROR(iParse.Set(parse.NameAndExt(), &iRestoreDir, 0));
					TPtrC fname(iParse.FullName());
					//The database is restored first to a temporary file, in the restore folder, on the same drive.
					__SQLLEAVE_IF_ERROR(iFile.Replace(iInterface.Fs(), fname, EFileWrite | EFileShareExclusive));
					SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL3, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;fname=%S;iFile.SubSessionHandle()=0x%X", (TUint)this, __SQLPRNSTR(fname), (TUint)iFile.SubSessionHandle()));
					iBuffer.Zero();
					}
				break;
				}
			case ERestoreExpectData: // now for the data
				{
				TInt len = Min((aInBuffer.Size() - inBufferPos), iFileSize);
				TInt err = iFile.Write(aInBuffer.Mid(inBufferPos, len));
				if(err != KErrNone)
					{
					(void)RestoreCleanup();
					__SQLLEAVE(err);
					}
				inBufferPos += len;
				iFileSize -= len;
				if(iFileSize == 0)
					{
					iState = ERestoreComplete;
					}
				break;
				}
			case ERestoreComplete: // file completely restored
				{
				TUint64 checkSum64 = 0;
			    TInt restoreErr = iFile.Flush();
				if(restoreErr == KErrNone)
					{
					// calculate the checksum
					restoreErr = CheckSum(iFile, checkSum64);
					}
				iFile.Close();
				if(restoreErr != KErrNone)
					{
					(void)RestoreCleanup();
					__SQLLEAVE(restoreErr);
					}
				SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL4, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;END;iFile.SubSessionHandle()=0x%X", (TUint)this, (TUint)iFile.SubSessionHandle()));
				TUint32 checkSum32 = checkSum64 & KMaxTUint32;
                if(checkSum32 != iChecksum)
                    {
					(void)RestoreCleanup();
                    __SQLLEAVE(KErrCorrupt);
                    }
				if((aInBuffer.Size() - inBufferPos) > 0)
					{//There are bytes to be consumed in the input buffer
					iState = ERestoreExpectChecksum;
					break;
					}
				SQL_TRACE_BUR(OstTrace1(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL5, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;aFinishedFlag=ETrue", (TUint)this));
				//End of data. We have all data restored in the restore folder.
				//The final step of the "restoring files" process consists of the following sub-steps:
				// - Rename the database file to be restored to a file with ".bak" extension
				// - Rename the file with the restored data to the database file
				// - Delete the file with ".bak" extension
				//Do not leave during the restore process! Restore as much files as possible.
				//The only excpetion is TParse::Set() - if it fails it is a fatal error, the
				//restored file path cannot be constructed.
				__ASSERT_DEBUG(iRestoreDrive != TDriveNumber(-1), __SQLPANIC(ESqlPanicInternalError));
				__ASSERT_DEBUG(iRestoreId != TSecureId(KNullUid), __SQLPANIC(ESqlPanicInternalError));
				//Include the aUid and the "*" mask
				TUidName uidName = (static_cast <TUid> (iRestoreId)).Name();
				TBuf<KMaxUidName + sizeof(KSqlBurAllFiles)> fileNameMask(uidName);
				fileNameMask.Append(KSqlBurAllFiles);
				__SQLLEAVE_IF_ERROR(iParse.Set(fileNameMask, &iRestoreDir, 0));
				CDir* dir = NULL;
				TPtrC searchPattern(iParse.FullName());
				SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL5A, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;search pattern=%S", (TUint)this, __SQLPRNSTR(searchPattern)));
				restoreErr = iInterface.Fs().GetDir(searchPattern, KEntryAttNormal, ESortNone, dir);
				if(restoreErr == KErrNone)
					{
					SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL6, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;restored files=%d", (TUint)this, dir->Count()));
					for(TInt i=0;i<dir->Count();++i)
						{
						const TEntry& entry = (*dir)[i];
						__SQLLEAVE_IF_ERROR(iParse.Set(entry.iName, &iRestoreDir, 0));
						TFileName dbName(iParse.FullName());
						SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL7, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;restored file=%S", (TUint)this, __SQLPRNSTR(dbName)));
						TInt pos = dbName.Find(KSqlBurRestoreDir);
						__ASSERT_DEBUG(pos >= 0, __SQLPANIC(ESqlPanicInternalError));
						dbName.Delete(pos, KSqlBurRestoreDir().Length() + 1);//"+1" for the path delimitier
						SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL8, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;database=%S", (TUint)this, __SQLPRNSTR(dbName)));
						TFileName bakDbName(iParse.FullName());
						bakDbName.Append(KSqlBurBackupExt);
						SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL9, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;backup file=%S", (TUint)this, __SQLPRNSTR(dbName)));
						//Now, dbName contains the original database (full path), iParse - the restored file,
						//bakDbName - backup file name
						TInt err = iInterface.Fs().Rename(dbName, bakDbName);
						if(err == KErrNone || err == KErrNotFound)
							{
							err = iInterface.Fs().Rename(iParse.FullName(), dbName);
							if(err == KErrNone)
								{//commit: delete the backup database file
								SQL_TRACE_BUR(OstTraceExt2(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL10, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;Commit;file=%S", (TUint)this, __SQLPRNSTR(dbName)));
								(void)iInterface.Fs().Delete(bakDbName);
								}
							else
								{//rollback: restore the original database file
								err = iInterface.Fs().Rename(bakDbName, dbName);
								SQL_TRACE_BUR(OstTraceExt3(TRACE_INTERNALS, CSQLBACKUPCLIENT_RESTOREBASEDATASECTONL11, "0x%X;CSqlBurCallback::RestoreBaseDataSectionL;Rollback;file=%S;err=%d", (TUint)this, __SQLPRNSTR(dbName), err));
								}
							}
						if(err != KErrNone && err != KErrNotFound)
							{
							if(restoreErr == KErrNone)
								{
								restoreErr = err;
								}
							}
						}//for(...)
					delete dir;
					}//iInterface.Fs().GetDir(...)
				done = ETrue;
				(void)RestoreCleanup();
				if(restoreErr != KErrNone)
					{
					__SQLLEAVE(restoreErr);
					}
				break;
				}
			default:
				__ASSERT_DEBUG(EFalse, __SQLPANIC(ESqlPanicInternalError));
				break;
			}//switch(...)
		if((aInBuffer.Size() - inBufferPos) == bytesAvailable)
			{//No bytes have been consumed from the buffer. 
			if(++iterations > 1 && !done)
				{//This is the second iteration in the loop where no bytes have been consumed from the input buffer. 
				 //But the "done" flag is still false. Corrupted archive.
				__SQLLEAVE(KErrCorrupt);
				}
			}
		} while(!done);
	}

/** 
The operation was terminated - we should tidyup here (as best we can)
Backup: close the file, free the allocated memory for the file names.
Restore: since the final restore step is a non-leaving one, nothing special needs to be done here - 
RestoreCleanup() is called to close the file and delete if there are any temporary files left.
*/	
void CSqlBurCallback::TerminateMultiStageOperation()
	{
	BackupCleanup();
	(void)RestoreCleanup();
	}

/** 
We do our own checksumming so we don't need this
@return the checksum
@param aDrive the drive affected (unused)
*/
TUint CSqlBurCallback::GetDataChecksum(TDriveNumber /* aDrive */)
	{
	// not required - not implemented
	const TUint KArbitraryNumber = 1024;
	return KArbitraryNumber;
	}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////     Incremental backup/restore      ////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 
We don't support incremental backup
*/
void CSqlBurCallback::GetSnapshotDataL(TDriveNumber /* aDrive */, TPtr8& /* aBuffer */, TBool& /* aFinishedFlag */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::InitialiseGetBackupDataL(TDriveNumber /* aDrive */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::InitialiseRestoreBaseDataL(TDriveNumber /* aDrive */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::InitialiseRestoreIncrementDataL(TDriveNumber /* aDrive */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::RestoreIncrementDataSectionL(TDesC8& /* aBuffer */, TBool /* aFinishedFlag */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::AllSnapshotsSuppliedL()
	{
	}

/** 
We don't support incremental backup
*/
void CSqlBurCallback::ReceiveSnapshotDataL(TDriveNumber /* aDrive */, TDesC8& /* aBuffer */, TBool /* aFinishedFlag */)
	{
	__SQLLEAVE(KErrNotSupported);
	}

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
///////////////////////////     Helper functions      //////////////////////////////////////////////////////////////
////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

/** 
A simple checksumming algorithm to allow a degree
of trust that the backup and restore worked.
Note the file pointer will be back at the start when the function call completes successfully.
In case of an error, the position of the file pointer is undetermined.

@param aOpenFile Already opened database file on which the checksum is calculated.
@param aCheckSum Output parameter. The checksum is returned in this parameter.
@return KErrNoMemory, an out of memory condition has occurred;
                      Note that the function may also return some other system-wide error codes.
*/
TInt CSqlBurCallback::CheckSum(const RFile64& aOpenFile, TUint64& aCheckSum) const
	{
	// scoot through the database file building the checksum
	aCheckSum = 0;
	TInt64 seekPos = 0; // rewind first
	TInt err = aOpenFile.Seek(ESeekStart, seekPos);
	if(err != KErrNone)
		{
		return err;
		}
	const TUint KCheckSumBlockSize = 4 * 1024;
	HBufC8* buf = HBufC8::New(KCheckSumBlockSize);
	if(!buf)
		{
		return KErrNoMemory;
		}
	TPtr8 ptr = buf->Des();
	for(;;)
		{
		err = aOpenFile.Read(ptr);
		if(err != KErrNone)
			{
			delete buf;
			return err;
			}
		TInt len = ptr.Length();
		if(len == 0)
			{
			break;
			}
		// calculate the checksum
		for(TInt i=0;i<len;++i)
			{
			aCheckSum = (aCheckSum << 1) | (aCheckSum >> 63);
			aCheckSum += ptr[i];
 			}
		};		
	delete buf;
	// restore file position
	seekPos = 0;
	err = aOpenFile.Seek(ESeekStart,seekPos);
	return err;
	}

/**
Reads the content of aInBuf from position aInBufReadPos and stores the data into aOutBuf.
aDataLen is the length of the data. If the input buffer does not contain all the data, then only the
available data will be copied to the output buffer.

How the function works. It is called during the restore process and aInBuf parameter contains a block of raw
data sent by the B&R server. The calling function, RestoreBaseDataSectionL(), uses a state 
machine to processes the incoming data. At particular moment RestoreBaseDataSectionL() will process the data header 
and will have to read "aDataLen" 16-bit characters at position "aInBufReadPos". If there are "aDataLen" characters
at position "aInBufReadPos" and enough free space in "aOutBuf", CopyBufData() will copy all of them,  
otherwise CopyBufData() will copy as much characters as possible (in which case RestoreBaseDataSectionL() will
stay in the same state, waiting for more data from the B&R server).

@param aInBuf        8-bit buffer with input data
@param aInBufReadPos The position in the buffer from which the read operation starts. 
                     When the "buffer read" operatio completes, aInBufReadPos is updated with the 
                     number of bytes read from the input buffer. 
@param aOutBuf       16-bit output buffer. The data read from the input buffer is stored in the output buffer.
@param aDataLen      How much bytes to be read from the input buffer. Note that if there is not enough
                     data in the input buffer, the function will read as much as possible from the input buffer.
                     The aInBufReadPos in/out parameter will be updated with the actual number of bytes read.                     
*/
void CSqlBurCallback::CopyBufData(const TDesC8& aInBuf, TInt& aInBufReadPos, TDes& aOutBuf, TInt aDataLen)
	{
    __ASSERT_DEBUG(aInBufReadPos >= 0, __SQLPANIC(ESqlPanicBadArgument));
    __ASSERT_DEBUG(aDataLen > 0, __SQLPANIC(ESqlPanicBadArgument));
	
	TInt needed = (aDataLen - aOutBuf.Length()) << K8to16bitShift;
	TInt available = aInBuf.Size() - aInBufReadPos;
	TInt len = Min(needed, available);
	TPtrC8 ptr8 = aInBuf.Mid(aInBufReadPos, len);
	aInBufReadPos += len;
	
	len >>= K8to16bitShift;
	aOutBuf.Append((const TUint16*)ptr8.Ptr(), len);
	}

/**
Cleans up the allocated during the backup resources - file handles, buffers allocated for the file names.
*/
void CSqlBurCallback::BackupCleanup()
	{
	for(TInt i=0;i<iFileList.Count();++i)
		{
		delete iFileList[i];
		}
	iFileList.Close();
	iFile.Close();
	}

/**
Deletes created during the restore temporary files.
*/
TInt CSqlBurCallback::RestoreCleanup()
	{
	if(iRestoreDir.Find(KSqlBurRestoreDir) < 0)
		{//iRestoreDir is not initialized - that means RestoreCleanup() was called either from the
		 //destructor or from the TerminateMultistageOperation() during a backup.
		return KErrNone;
		}
	iFile.Close();
	CFileMan* fm = NULL;
	TRAPD(err, fm = CFileMan::NewL(iInterface.Fs()));
	if(err == KErrNone)
		{
		TFileName allFiles;
		allFiles.Copy(iRestoreDir);
		allFiles.Append(KSqlBurAllFiles);
		err = fm->Delete(allFiles);
		delete fm;
		}
	return err;
	}

/**
Stores the error occured during backup for furhter processing.
Please note that the function asserts if the aError parameter is KErrNone.
Call the function only with a real error.

@param aError The backup error to be stored 
*/
void CSqlBurCallback::SetBackupError(TInt aError)
	{
	__ASSERT_DEBUG(aError != KErrNone, __SQLPANIC(ESqlPanicBadArgument));
	if(aError != KErrNotFound && aError != KErrPathNotFound)
		{
		if(iBackupError == KErrNone || aError == KErrDiskFull || aError == KErrCorrupt)
			{
			iBackupError = aError;
			}
		}
	}