sl@0: // Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include <babackup.h>
sl@0: #include <bafl/backup_std.h>
sl@0: #include <e32std.h>
sl@0: #include <e32base.h>
sl@0: #include <baksrv.h>
sl@0: #include "Baksrvs.h"
sl@0: #include <e32math.h>
sl@0: #include <e32svr.h>
sl@0: #include <baflpan.h>
sl@0: 
sl@0: #define UNUSED_VAR(a) a = a
sl@0: 
sl@0: const TUid KServerUid3={0x10004900};
sl@0: const TInt KBADefaultPriority = CActive::EPriorityUserInput;
sl@0: _LIT(KBackupSrvName,"baksrvs");
sl@0: 
sl@0: //
sl@0: // class RBaBackupSession
sl@0: //
sl@0: 
sl@0: const TInt KNumConnectRetries	=10;
sl@0: 
sl@0: 
sl@0: class RBaBackupSession : public RSessionBase
sl@0: 	{
sl@0: public:
sl@0: 	TInt Connect();
sl@0: 	void RegisterForNotifications(TRequestStatus& aStatus) const;
sl@0: 	void DeregisterForNotifications() const;
sl@0: 	void GetEvent(TDes& aFileName,MBackupObserver::TFileLockFlags& aFileFlag) const;
sl@0: 	void CloseAllFiles(MBackupObserver::TFileLockFlags aFlags,TRequestStatus& aStatus) const;
sl@0: 	void RestartApps() const;
sl@0: 	TInt CloseFile(const TDesC& aFileName,MBackupObserver::TFileLockFlags aFlags) const;
sl@0: 	void RestartFile(const TDesC& aFileName) const;
sl@0: 	TInt NotifyChangeFileLock(const TDesC& aFileName) const;
sl@0: 	void NotifyChangeFileLockCancel(const TDesC& aFileName) const;
sl@0: 	void CloseServer() const;
sl@0: 	void NotifyBackupOperation(const TBackupOperationAttributes& aBackupOperationAttributes);
sl@0: 	TBool IsBackupOperationRunning() const;
sl@0: 	void BackupOperationEventReady(TRequestStatus& aStatus, TPckgBuf<TBackupOperationAttributes>& aBackupOperationAttributes) const;
sl@0: 	void CancelOutstandingEventForBackupOperation() const;
sl@0: 	void GetBackupOperationEvent(TBackupOperationAttributes& aBackupOperationAttributes) const;
sl@0: 	void SetBackupOperationObserverIsPresent(TBool aObserverIsPresent) const;
sl@0: private:
sl@0: 	TInt StartServer();
sl@0: 	};
sl@0: 
sl@0: TInt RBaBackupSession::Connect()
sl@0: 	{
sl@0: 	TInt err=KErrNone;
sl@0: 	TInt retry=KNumConnectRetries;
sl@0: 	FOREVER
sl@0: 		{
sl@0: 		err=CreateSession(__BACKUP_SERVER_NAME_V2,TVersion(KBakServMajorVN,KBakServMinorVN,KBakServBuildVN),KBakServMessageSlots);
sl@0: 		if ((--retry>0) && ((err==KErrNotFound) || (err==KErrServerTerminated)))
sl@0: 			{
sl@0: 			err = StartServer();
sl@0: 			if ((err!=KErrNone) && (err!=KErrAlreadyExists))
sl@0: 				{
sl@0: 				break;
sl@0: 				}
sl@0: 			}
sl@0: 		else
sl@0: 			{
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: TInt RBaBackupSession::StartServer()
sl@0: 	{
sl@0: 	const TUidType serverUid(KNullUid,KNullUid,KServerUid3);
sl@0: 	TInt error=KErrNone;
sl@0: 	RProcess server;
sl@0: 	error = server.Create(KBackupSrvName,KNullDesC,serverUid);
sl@0: 	if(error!=KErrNone)
sl@0: 		return error;
sl@0:  	TRequestStatus stat;
sl@0: 	server.Rendezvous(stat);
sl@0:  	if (stat!=KRequestPending)
sl@0:  		server.Kill(0);		// abort startup
sl@0:  	else
sl@0:  		server.Resume();	// logon OK - start the server
sl@0:  	User::WaitForRequest(stat);		// wait for start or death
sl@0:  	// we can't use the 'exit reason' if the server panicked as this
sl@0:  	// is the panic 'reason' and may be '0' which cannot be distinguished
sl@0:  	// from KErrNone
sl@0:  	error=(server.ExitType()==EExitPanic) ? KErrGeneral : stat.Int();
sl@0: 	server.Close();
sl@0: 	return error;
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void RBaBackupSession::RegisterForNotifications(TRequestStatus& aStatus) const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeEventReady,aStatus);
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::DeregisterForNotifications() const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeStopNotifications);
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::GetEvent(TDes& aFileName,MBackupObserver::TFileLockFlags& aFileFlag) const
sl@0: 	{
sl@0: 	TBuf<KMaxFileName+1> buf;
sl@0: 	if (SendReceive(EBakOpCodeGetEvent,TIpcArgs(&buf))!=KErrServerTerminated)
sl@0: 		{
sl@0: 		TBuf<1> num=buf.Left(1);
sl@0: 		buf.Delete(0,1);
sl@0: 		aFileName=buf;
sl@0: 		aFileFlag=(MBackupObserver::TFileLockFlags)(num[0]-'0');
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::CloseAllFiles(MBackupObserver::TFileLockFlags aFlags,TRequestStatus& aStatus) const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeCloseAllFiles,TIpcArgs(aFlags),aStatus);
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::RestartApps() const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeRestartAll);
sl@0: 	}
sl@0: 
sl@0: TInt RBaBackupSession::CloseFile(const TDesC& aFileName,MBackupObserver::TFileLockFlags aFlags) const
sl@0: 	{
sl@0: 	const TInt err=SendReceive(EBakOpCodeCloseFile,TIpcArgs(aFileName.Length(),&aFileName,aFlags));
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::RestartFile(const TDesC& aFileName) const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeRestartFile,TIpcArgs(aFileName.Length(),&aFileName));
sl@0: 	}
sl@0: 
sl@0: TInt RBaBackupSession::NotifyChangeFileLock(const TDesC& aFileName) const
sl@0: 	{
sl@0: 	return SendReceive(EBakOpCodeNotifyLockChange,TIpcArgs(aFileName.Length(),&aFileName));
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::NotifyChangeFileLockCancel(const TDesC& aFileName) const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeNotifyLockChangeCancel,TIpcArgs(aFileName.Length(),&aFileName));
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::CloseServer() const
sl@0: 	{
sl@0: 	Send(EBakOpCodeCloseServer);
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::NotifyBackupOperation(const TBackupOperationAttributes& aBackupOperationAttributes)
sl@0: 	{
sl@0: 	TPckgC<TBackupOperationAttributes> backupOpAttPkg(aBackupOperationAttributes);
sl@0: 	SendReceive(EBakOpCodeNotifyBackupOperation, TIpcArgs(&backupOpAttPkg));
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::CancelOutstandingEventForBackupOperation() const 
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeCancelOutstandingBackupOperationEvent);
sl@0: 	}
sl@0: 
sl@0: TBool RBaBackupSession::IsBackupOperationRunning() const
sl@0: 	{
sl@0: 	TBool isRunning=EFalse;
sl@0: 	TPckg<TBool> pkg(isRunning);
sl@0: 	SendReceive(EBakOpCodeGetBackupOperationState, TIpcArgs(&pkg));
sl@0: 	return pkg();
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::BackupOperationEventReady(TRequestStatus& aStatus, TPckgBuf<TBackupOperationAttributes>& aBackupOperationAttributes) const
sl@0: 	{
sl@0: 	SendReceive(EBakOpCodeBackupOperationEventReady,TIpcArgs(&aBackupOperationAttributes),aStatus);
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::GetBackupOperationEvent(TBackupOperationAttributes& aBackupOperationAttributes) const
sl@0: 	{
sl@0: 	TPckg<TBackupOperationAttributes> backupOpAttPkg(aBackupOperationAttributes);
sl@0: 	SendReceive(EBakOpCodeGetBackupOperationEvent, TIpcArgs(&backupOpAttPkg));
sl@0: 	}
sl@0: 
sl@0: void RBaBackupSession::SetBackupOperationObserverIsPresent(TBool aObserverIsPresent) const
sl@0: 	{
sl@0: 	Send(EBakOpCodeSetBackupOperationObserverIsPresent, TIpcArgs(aObserverIsPresent));
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // class CBaLockChangeNotifier
sl@0: //
sl@0: 
sl@0: NONSHARABLE_CLASS(CBaLockChangeNotifier) : public CActive
sl@0: 	{
sl@0: public:
sl@0: 	static CBaLockChangeNotifier* NewL(RBaBackupSession& aBackupSession);
sl@0: 	~CBaLockChangeNotifier();
sl@0: 	void AddL(const TDesC& aFileName, MBackupObserver& aObserver);
sl@0: 	void Remove(const TDesC& aFileName);
sl@0: protected:
sl@0: 	void StartNotifications();
sl@0: 	void StopNotifications();
sl@0: private: // from CActive
sl@0: 	void DoCancel();
sl@0: 	void RunL();
sl@0: private:
sl@0: 	CBaLockChangeNotifier(RBaBackupSession& aBackupSession);
sl@0: 	void DoRunL();
sl@0: 	TInt Find(const TDesC& aFileName) const;
sl@0: private:
sl@0: 	class TFileItem
sl@0: 		{
sl@0: 	public:
sl@0: 		TFileItem(HBufC* aFile,MBackupObserver& aObserver);
sl@0: 	public:
sl@0: 		HBufC* iFile;
sl@0: 		MBackupObserver& iObserver;
sl@0: 		};
sl@0: private:
sl@0: 	RBaBackupSession& iBackupSession;
sl@0: 	RArray<TFileItem> iFileItems;
sl@0: 	};
sl@0: 
sl@0: CBaLockChangeNotifier::TFileItem::TFileItem(HBufC* aFile,MBackupObserver& aObserver)
sl@0: 	:	iFile(aFile), 
sl@0: 		iObserver(aObserver)
sl@0: 	{}
sl@0: 
sl@0: CBaLockChangeNotifier* CBaLockChangeNotifier::NewL(RBaBackupSession& aBackupSession)
sl@0: 	{ // static
sl@0: 	CBaLockChangeNotifier* self=new(ELeave) CBaLockChangeNotifier(aBackupSession);
sl@0: 	CActiveScheduler::Add(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: CBaLockChangeNotifier::~CBaLockChangeNotifier()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 
sl@0: 	const TInt count=iFileItems.Count();
sl@0: 	for (TInt ii=0;ii<count;ii++)
sl@0: 		{
sl@0: 		delete iFileItems[ii].iFile;
sl@0: 		}
sl@0: 	iFileItems.Close();
sl@0: 	}
sl@0: 
sl@0: void CBaLockChangeNotifier::StartNotifications()
sl@0: 	{
sl@0: 	if(!IsActive())
sl@0: 		{	
sl@0: 		iBackupSession.RegisterForNotifications(iStatus);
sl@0: 		SetActive();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CBaLockChangeNotifier:: StopNotifications()
sl@0: 	{
sl@0: 	const TInt count=iFileItems.Count();
sl@0: 	
sl@0: 	if(count==0)
sl@0: 		{
sl@0: 		Cancel();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CBaLockChangeNotifier::AddL(const TDesC& aFileName, MBackupObserver& aObserver)
sl@0: 	{
sl@0: 	StartNotifications();
sl@0: 
sl@0: 	HBufC* file=aFileName.AllocLC();
sl@0: 	TFileItem fileItem(file,aObserver);
sl@0: 	User::LeaveIfError(iFileItems.Append(fileItem));
sl@0: 	CleanupStack::Pop(); // file
sl@0: 	const TInt err=iBackupSession.NotifyChangeFileLock(aFileName);
sl@0: 	if (err!=KErrNone)
sl@0: 		{
sl@0: 		delete file;
sl@0: 		iFileItems.Remove(iFileItems.Count()-1);
sl@0: 		iFileItems.Compress();
sl@0: 		User::Leave(err);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CBaLockChangeNotifier::Remove(const TDesC& aFileName)
sl@0: 	{
sl@0: 	const TInt index=Find(aFileName);
sl@0: 	if (index!=KErrNotFound)
sl@0: 		{
sl@0: 		const TFileItem& fileItem=iFileItems[index];
sl@0: 		iBackupSession.NotifyChangeFileLockCancel(*fileItem.iFile);
sl@0: 		delete fileItem.iFile;
sl@0: 		iFileItems.Remove(index);
sl@0: 		iFileItems.Compress();
sl@0: 		}
sl@0: 
sl@0: 	StopNotifications();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: void CBaLockChangeNotifier::DoCancel()
sl@0: 	{
sl@0: 	const TInt count=iFileItems.Count();	
sl@0: 
sl@0: 	// release the locks on all outstandng files in this session
sl@0:   	for (TInt ii=0;ii<count;ii++)		
sl@0:   		{
sl@0:   		const TFileItem& fileItem=iFileItems[ii];
sl@0:   		iBackupSession.NotifyChangeFileLockCancel(*fileItem.iFile);
sl@0:   		}								
sl@0: 	iBackupSession.DeregisterForNotifications();
sl@0: 	}
sl@0: 
sl@0: void CBaLockChangeNotifier::RunL()
sl@0: 	{
sl@0: 	TRAPD(err,DoRunL());
sl@0: 	if (err!=KErrServerTerminated)
sl@0: 		{
sl@0: 		StartNotifications();
sl@0: 		}
sl@0: 	User::LeaveIfError(err);
sl@0: 	}
sl@0: 
sl@0: CBaLockChangeNotifier::CBaLockChangeNotifier(RBaBackupSession& aBackupSession)
sl@0: 	: CActive(KBADefaultPriority), iBackupSession(aBackupSession)
sl@0: 	{}
sl@0: 
sl@0: 
sl@0: void CBaLockChangeNotifier::DoRunL()
sl@0: 	{
sl@0: 	const TInt status=iStatus.Int();
sl@0: 
sl@0: 	if (status<0)
sl@0: 		{
sl@0: 		User::Leave(status);
sl@0: 		}
sl@0: 	TFileName fileName;
sl@0: 	MBackupObserver::TFileLockFlags fileFlag;
sl@0: 	iBackupSession.GetEvent(fileName,fileFlag);
sl@0: 	TInt err=KErrNone;
sl@0: 	const TInt count=iFileItems.Count();
sl@0: 	for (TInt ii=0;ii<count;ii++)
sl@0: 		{
sl@0: 		const TFileItem& fileItem=iFileItems[ii];
sl@0: 		if (fileItem.iFile->MatchF(fileName)==0)
sl@0: 			{
sl@0: 			TRAPD(r,fileItem.iObserver.ChangeFileLockL(*fileItem.iFile,fileFlag));
sl@0: 			if (r!=KErrNone && err==KErrNone)
sl@0: 				{
sl@0: 				err=r;
sl@0: 				}
sl@0: 			}
sl@0: 		}
sl@0: 	User::LeaveIfError(err);
sl@0: 	}
sl@0: 
sl@0: TInt CBaLockChangeNotifier::Find(const TDesC& aFileName) const
sl@0: 	{
sl@0: 	TInt index=KErrNotFound;
sl@0: 	const TInt count=iFileItems.Count();
sl@0: 	for (TInt ii=0;ii<count;ii++)
sl@0: 		{
sl@0: 		const TFileItem& fileItem=iFileItems[ii];
sl@0: 		if (*fileItem.iFile==aFileName)
sl@0: 			{
sl@0: 			index=ii;
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	return index;
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // class CBaBackupOperationNotifier
sl@0: //
sl@0: 
sl@0: NONSHARABLE_CLASS(CBaBackupOperationNotifier) : public CActive
sl@0: 	{
sl@0: public:
sl@0: 	static CBaBackupOperationNotifier* NewL(RBaBackupSession& aBackupSession);
sl@0: 	~CBaBackupOperationNotifier();
sl@0: 	void AddBackupOperationObserverL(MBackupOperationObserver& aBackupSession);
sl@0: 	void RemoveBackupOperationObserver(MBackupOperationObserver& aBackupSession);
sl@0: private: // from CActive
sl@0: 	void DoCancel();
sl@0: 	void RunL();
sl@0: private:
sl@0: 	CBaBackupOperationNotifier(RBaBackupSession& aBackupSession);
sl@0: 	void Queue();
sl@0: 	void DoRunL();
sl@0: private:
sl@0: 	RPointerArray<MBackupOperationObserver> iObservers;
sl@0: 	RBaBackupSession& iBackupSession;
sl@0: 	TPckgBuf<TBackupOperationAttributes> iBackupOperationAttributes;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: CBaBackupOperationNotifier* CBaBackupOperationNotifier::NewL(RBaBackupSession& aBackupSession)
sl@0: 	{ // static
sl@0: 	CBaBackupOperationNotifier* self=new(ELeave) CBaBackupOperationNotifier(aBackupSession);
sl@0: 	CActiveScheduler::Add(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: CBaBackupOperationNotifier::~CBaBackupOperationNotifier()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	iObservers.Reset();
sl@0: 	iObservers.Close();
sl@0: 	}
sl@0: 
sl@0: void CBaBackupOperationNotifier::AddBackupOperationObserverL(MBackupOperationObserver& aBackupOperationObserver)
sl@0: 	{
sl@0: 	const TInt index = iObservers.Find(&aBackupOperationObserver);
sl@0: 	if (index == KErrNotFound)
sl@0: 		{
sl@0: 		User::LeaveIfError(iObservers.Append(&aBackupOperationObserver));
sl@0: 		if (iBackupSession.IsBackupOperationRunning())
sl@0: 			{
sl@0: 			TBackupOperationAttributes backupOperationAttributes;
sl@0: 			iBackupSession.GetBackupOperationEvent(backupOperationAttributes);
sl@0: 			aBackupOperationObserver.HandleBackupOperationEventL(backupOperationAttributes);
sl@0: 			}
sl@0: 		}
sl@0: 	Queue();
sl@0: 	}
sl@0: 
sl@0: void CBaBackupOperationNotifier::RemoveBackupOperationObserver(MBackupOperationObserver& aBackupOperationObserver)
sl@0: 	{
sl@0: 	const TInt index = iObservers.Find(&aBackupOperationObserver);
sl@0: 	if (index != KErrNotFound)
sl@0: 		{
sl@0: 		iObservers.Remove(index);
sl@0: 		if (iObservers.Count() == 0)
sl@0: 			{
sl@0: 			iBackupSession.CancelOutstandingEventForBackupOperation();
sl@0: 			iBackupSession.SetBackupOperationObserverIsPresent(EFalse);
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CBaBackupOperationNotifier::DoCancel()
sl@0: 	{
sl@0: 	TBackupOperationAttributes backupOperationAttributes;
sl@0: 	iBackupSession.GetBackupOperationEvent(backupOperationAttributes);
sl@0: 	const TInt count = iObservers.Count();
sl@0: 	for (TInt index=0; index<count; ++index)
sl@0: 		{
sl@0: 		// TRAP and ignore the errCode
sl@0: 		TRAPD(errCode, iObservers[index]->HandleBackupOperationEventL(backupOperationAttributes));
sl@0:         UNUSED_VAR(errCode);
sl@0: 		}
sl@0: 	iBackupSession.CancelOutstandingEventForBackupOperation();
sl@0: 	}
sl@0: 
sl@0: void CBaBackupOperationNotifier::RunL()
sl@0: 	{
sl@0: 	const TInt status=iStatus.Int();
sl@0: 	if (status!=KErrCancel && iObservers.Count()>0)
sl@0: 		{
sl@0: 		TRAPD(err,DoRunL());
sl@0: 		if (err!=KErrServerTerminated)
sl@0: 			{
sl@0: 			Queue();
sl@0: 			}
sl@0: 		User::LeaveIfError(err);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: CBaBackupOperationNotifier::CBaBackupOperationNotifier(RBaBackupSession& aBackupSession)
sl@0: 	: CActive(EPriorityStandard), iBackupSession(aBackupSession)
sl@0: 	{}
sl@0: 
sl@0: void CBaBackupOperationNotifier::Queue()
sl@0: 	{
sl@0: 	if (!IsActive())
sl@0: 		{
sl@0: 		iStatus=KRequestPending;
sl@0: 		SetActive();
sl@0: 		iBackupSession.SetBackupOperationObserverIsPresent(ETrue);
sl@0: 		iBackupSession.BackupOperationEventReady(iStatus, iBackupOperationAttributes);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CBaBackupOperationNotifier::DoRunL()
sl@0: 	{
sl@0: 	const TInt status=iStatus.Int();
sl@0: 	if (status<0)
sl@0: 		{
sl@0: 		User::Leave(status);
sl@0: 		}
sl@0: 	const TInt count = iObservers.Count();
sl@0: 	for (TInt index=0; index<count; ++index)
sl@0: 		{
sl@0: 		iObservers[index]->HandleBackupOperationEventL(iBackupOperationAttributes());
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // class CBaBackupSessionWrapper
sl@0: //
sl@0: 
sl@0: /**
sl@0:  * Returns a newly created CBaBackupSessionWrapper, passing ownership immediately
sl@0:  */
sl@0: EXPORT_C CBaBackupSessionWrapper* CBaBackupSessionWrapper::NewL()
sl@0: 	{ // static
sl@0: 	CBaBackupSessionWrapper* self=new(ELeave) CBaBackupSessionWrapper();
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	CleanupStack::Pop(); // self
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * D'tor.  Any files or apps that have been closed will be restarted
sl@0:  */
sl@0: EXPORT_C CBaBackupSessionWrapper::~CBaBackupSessionWrapper()
sl@0: 	{
sl@0: 	delete iLockChangeNotifier;
sl@0: 	delete iBackupOperationNotifier;
sl@0: 	if (iBackupSession)
sl@0: 		{
sl@0: 		iBackupSession->Close();
sl@0: 		delete iBackupSession;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Register the specified file to the server. The given observer will be called back when 
sl@0: the lock state of the file should be modified
sl@0: 
sl@0: @param aFileName the name of the file to be observed.
sl@0: @param aObserver the observer which will be called back when the lock state of the file should be modified.
sl@0: 
sl@0: @leave KErrServerBusy if the server is busy with the other client or under CloseAll operation. KErrNoMemory 
sl@0: if not enough memory to register this file.
sl@0: */
sl@0: EXPORT_C void CBaBackupSessionWrapper::RegisterFileL(const TDesC& aFileName,MBackupObserver& aObserver)
sl@0: 	{
sl@0: 	if (!iLockChangeNotifier)
sl@0:  		{
sl@0:  		iLockChangeNotifier=CBaLockChangeNotifier::NewL(*iBackupSession);
sl@0:  		}
sl@0: 
sl@0: 	__ASSERT_ALWAYS(iLockChangeNotifier, Panic(EBafPanicNullPointer));
sl@0: 	iLockChangeNotifier->AddL(aFileName,aObserver);
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Stop sending this client requests to alter the lock state of aFileName
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::DeregisterFile(const TDesC& aFileName)
sl@0: 	{
sl@0: 	if(iLockChangeNotifier)
sl@0: 		iLockChangeNotifier->Remove(aFileName);
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  Closes all non-system apps and signal all registered files to have their locks altered according to aFlags.
sl@0:  Returns immediately before having finished all processing.  aStatus will be completed when everything is
sl@0:  closed or closing has completed.  Possible error codes are
sl@0:  		KErrNoMemory		- Not enough memory to signal all apps/files to close
sl@0:  		KErrServerBusy	- Another client has some files closed - No-one else should attempt any backup operation
sl@0:  		KErrLocked			- Not all apps were successfully closed
sl@0:  In all cases, an undefined number of apps/files may have been closed and backup may still be possible although
sl@0:  install/restore operations should not be attempted.
sl@0:   
sl@0:  @param aFlags the file lock state to request the other clients with.
sl@0:  @param aStatus the request status to be completed when all files have been closed.
sl@0:  @publishedPartner
sl@0:  @released
sl@0:  @capability WriteDeviceData
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::CloseAll(MBackupObserver::TFileLockFlags aFlags,TRequestStatus& aStatus)
sl@0: 	{
sl@0: 	iBackupSession->CloseAllFiles(aFlags,aStatus);
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Opposite of CloseAll.  Can safely be called nothing has been closed by this client
sl@0:  * 
sl@0:  * @publishedPartner
sl@0:  * @released
sl@0:  * @capability WriteDeviceData
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::RestartAll()
sl@0: 	{
sl@0: 	iBackupSession->RestartApps();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  Close or reduce use of aFileName depending on the state of aFlags.  
sl@0:   
sl@0:  @param aFileName the name of the file to be closed / changed the file lock state.
sl@0:  @param aFlag the file lock state to change to.
sl@0:  @leave KErrNoMemory if not enough memory to signal the files to close. KErrServerIsBusy if another client 
sl@0:  has some files being closed.
sl@0:  @publishedPartner
sl@0:  @released
sl@0:  @capability WriteDeviceData
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::CloseFileL(const TDesC& aFileName,MBackupObserver::TFileLockFlags aFlags)
sl@0: 	{
sl@0: 	User::LeaveIfError(iBackupSession->CloseFile(aFileName,aFlags));
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Opposite of CloseFileL.  Can be safely called if CloseFileL hasn't been called before
sl@0:  * 
sl@0:  * @publishedPartner
sl@0:  * @released
sl@0:  * @capability WriteDeviceData
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::RestartFile(const TDesC& aFileName)
sl@0: 	{
sl@0: 	iBackupSession->RestartFile(aFileName);
sl@0: 	}
sl@0: 
sl@0: CBaBackupSessionWrapper::CBaBackupSessionWrapper()
sl@0: 	{}
sl@0: 
sl@0: void CBaBackupSessionWrapper::ConstructL()
sl@0: 	{
sl@0: 	iBackupSession=new(ELeave) RBaBackupSession();
sl@0: 	User::LeaveIfError(iBackupSession->Connect());
sl@0: 	}
sl@0: 
sl@0: 
sl@0: /**
sl@0:  * Registers the observer aBackupOperationObserver for getting notifications whether a backup or
sl@0:  * restore operation starts or ends.
sl@0:  * 
sl@0:  * @since App-Framework_6.2
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::RegisterBackupOperationObserverL(MBackupOperationObserver& aBackupOperationObserver)
sl@0: 	{
sl@0: 	if (!iBackupOperationNotifier)
sl@0: 		{
sl@0: 		iBackupOperationNotifier=CBaBackupOperationNotifier::NewL(*iBackupSession);
sl@0: 		}
sl@0: 	iBackupOperationNotifier->AddBackupOperationObserverL(aBackupOperationObserver);
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * De-registers the observer aBackupOperationObserver for getting notifications whether a backup or
sl@0:  * restore operation starts or ends.
sl@0:  *
sl@0:  * @since App-Framework_6.2
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::DeRegisterBackupOperationObserver(MBackupOperationObserver& aBackupOperationObserver)
sl@0: 	{
sl@0: 	if (iBackupOperationNotifier)
sl@0: 		{
sl@0: 		iBackupOperationNotifier->RemoveBackupOperationObserver(aBackupOperationObserver);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Returns ETrue when either a backup or restore operation is running, otherwise it retunrs EFalse.
sl@0:  *
sl@0:  * @since App-Framework_6.2
sl@0:  */
sl@0: EXPORT_C TBool CBaBackupSessionWrapper::IsBackupOperationRunning() const
sl@0: 	{
sl@0: 	return iBackupSession->IsBackupOperationRunning();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0:  * Notifies the server that a backup operation is going to happen.
sl@0:  *
sl@0:  * @since App-Framework_6.2
sl@0:  * @publishedPartner
sl@0:  * @released
sl@0:  * @capability WriteDeviceData
sl@0:  */
sl@0: EXPORT_C void CBaBackupSessionWrapper::NotifyBackupOperationL(const TBackupOperationAttributes& aBackupOperationAttributes)
sl@0: 	{
sl@0: 	iBackupSession->NotifyBackupOperation(aBackupOperationAttributes);
sl@0: 	}
sl@0: 
sl@0: 
sl@0: EXPORT_C void MBackupOperationObserver::Reserved1()
sl@0: 	{
sl@0: 	}