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: // class CBackupFileObserver
sl@0: // 
sl@0: //
sl@0: 
sl@0: class CBackupFileObserver : public CActive, public MBackupObserver
sl@0: 	{
sl@0: public:
sl@0: 	enum TFileLock
sl@0: 		{ELocked,EReadOnly,ENoAccess};
sl@0: public:
sl@0: 	static CBackupFileObserver* NewL(TInt aFileObserverNumber);
sl@0: 	~CBackupFileObserver();
sl@0: 	void AddFileL(TInt aFileNumber);
sl@0: public:
sl@0: 	TInt GetFileLocksChanged();
sl@0: 	void ZeroFileLocksChanged();
sl@0: 	void SetDelay(TBool aDelay);
sl@0: private:
sl@0: 	CBackupFileObserver();
sl@0: 	void ConstructL(TInt aFileObserverNumber);
sl@0: private: // from MBackupObserver
sl@0: 	void ChangeFileLockL(const TDesC& aFileName,TFileLockFlags aFlags);
sl@0: public: // From CActive
sl@0: 	void RunL();
sl@0: 	void DoCancel();
sl@0: public:
sl@0: 	void Kill(RThread* aThread);
sl@0: private:
sl@0: 	// File observer session into the server
sl@0: 	CBaBackupSessionWrapper* iBackupSession;
sl@0: 	// Instance number for this obsever
sl@0: 	TInt iFileObserverNumber;
sl@0: 	// Number of file lock notifications received this backup
sl@0: 	TInt iFileLocksChanged;
sl@0: 	// Whether we're testing with an introduced delay or not
sl@0: 	TBool iDelay;
sl@0: 	// Local RTest for this class - needed because global RTest fails in multi-threaded environment
sl@0: 	RTest* iLocalRTest;
sl@0: 	// Name of the file we're observing
sl@0: 	TFileName iFileName;
sl@0: 	// State of the file we're observing
sl@0: 	TFileLock iFileLockState;
sl@0: 	};
sl@0: 
sl@0: //
sl@0: //	class CBackupOperationObserver
sl@0: //
sl@0: class CBackupOperationObserver : public CActive, public MBackupOperationObserver
sl@0: 	{
sl@0: public:
sl@0: 	static CBackupOperationObserver* NewL(TInt aObserverNumber);
sl@0: 	~CBackupOperationObserver();
sl@0: public: // From CActive
sl@0: 	void RunL();
sl@0: 	void DoCancel();
sl@0: public:
sl@0: 	void Kill(RThread* aThread);
sl@0: private:
sl@0: 	CBackupOperationObserver();
sl@0: 	void ConstructL(TInt aObserverNumber);
sl@0: 
sl@0: 	// from MBackupOperationObserver
sl@0: 	virtual void HandleBackupOperationEventL(const TBackupOperationAttributes& aBackupOperationAttributes);
sl@0: private: 
sl@0: 	// Every backup observer has their own session
sl@0: 	CBaBackupSessionWrapper* iBackupSession;
sl@0: 	// Every backup observer has their own identifying number
sl@0: 	TInt iObserverNumber;
sl@0: 	// Local RTest for this class - needed because global RTest fails in multi-threaded environment
sl@0: 	RTest* iLocalRTest;
sl@0: 	};
sl@0: 
sl@0: //
sl@0: //	class CBackupTestsStateMachine
sl@0: //
sl@0: 
sl@0: class CBackupTestsStateMachine : public CActive
sl@0: 	{
sl@0: public:
sl@0: 	static CBackupTestsStateMachine* NewL();
sl@0: 	CBackupTestsStateMachine();
sl@0: 	~CBackupTestsStateMachine();
sl@0: public: // From CActive
sl@0: 	void RunL();
sl@0: 	void RunError();
sl@0: 	void DoCancel();
sl@0: public:
sl@0: 	void Start();
sl@0: 	void End();
sl@0: 	void Complete();
sl@0: 	void StartBackupL();
sl@0: 	void EndBackup(TInt aFileLockChangesExpected, TBool oneTimeOnly);
sl@0: 	void SignalEndBackupL();
sl@0: 	void SingleFileLockTestsL();
sl@0: public:
sl@0: 	void CreateObserversThreadsL();
sl@0: 	static TInt BackupObserversThreadStartL(TAny* aPtr);
sl@0: 	static TInt FileObserversThreadStartL(TAny* aPtr);
sl@0: 	void CreateBackupObserverInstanceL();
sl@0: 	void CreateFileObserverInstanceL();
sl@0: public:
sl@0: 	enum StateMachineState
sl@0: 		{EStateMachineStart,
sl@0: 		 ESingleFileTests,		   ENoBackupSessionSingleFileTests,
sl@0: 		 ECloseAllNormalReadOnly,  ECloseAllNormalReadOnlyReturned, 
sl@0: 		 ECloseAllNormalNoAccess,  ECloseAllNormalNoAccessReturned, 
sl@0: 		 ECloseAllDelayReadOnly,   ECloseAllDelayReadOnlyReturned,  
sl@0: 		 ECloseAllDelayNoAccess,   ECloseAllDelayNoAccessReturned,
sl@0: 		 ECloseAllDropFileSession, ECloseAllDropFileSessionReturned,
sl@0: 		 ECloseAllDropBackupObserverSession, ECloseAllDropBackupObserverSessionReturned,
sl@0: 		 EStateMachineEnd};
sl@0: public:
sl@0: 	void CloseAllStartL(StateMachineState aNextState, MBackupObserver::TFileLockFlags aFlag);
sl@0: 	void CloseAllEndL(StateMachineState aNextState, TInt aExpectedNotifications);
sl@0: private:
sl@0: 	void ConstructL();
sl@0: private:
sl@0: 	// The RTest class for this thread
sl@0: 	RTest* iLocalRTest;
sl@0: 	// The "command" session
sl@0: 	CBaBackupSessionWrapper* iBackupSession;	
sl@0: 	// Safety for RArrays
sl@0: 	RMutex iMutex;
sl@0: 	// Array of backup observers
sl@0: 	RPointerArray<CBackupOperationObserver> iBackupObservers;
sl@0: 	// Array of file lock observers
sl@0: 	RPointerArray<CBackupFileObserver> iBackupFileObservers;
sl@0: 	// Used for single file tests
sl@0: 	TInt iEndBackupRecursionCount;
sl@0: 	// Current state of the State Machine
sl@0: 	StateMachineState iState;
sl@0: 	// Used for backup observer threads
sl@0: 	RPointerArray<RThread> iBackupObserverThreads;
sl@0: 	// Used for file observer threads
sl@0: 	RPointerArray<RThread> iFileObserverThreads;
sl@0: 	};
sl@0: