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

// class CBackupFileObserver

// 

//

class CBackupFileObserver : public CActive, public MBackupObserver

	{

public:

	enum TFileLock

		{ELocked,EReadOnly,ENoAccess};

public:

	static CBackupFileObserver* NewL(TInt aFileObserverNumber);

	~CBackupFileObserver();

	void AddFileL(TInt aFileNumber);

public:

	TInt GetFileLocksChanged();

	void ZeroFileLocksChanged();

	void SetDelay(TBool aDelay);

private:

	CBackupFileObserver();

	void ConstructL(TInt aFileObserverNumber);

private: // from MBackupObserver

	void ChangeFileLockL(const TDesC& aFileName,TFileLockFlags aFlags);

public: // From CActive

	void RunL();

	void DoCancel();

public:

	void Kill(RThread* aThread);

private:

	// File observer session into the server

	CBaBackupSessionWrapper* iBackupSession;

	// Instance number for this obsever

	TInt iFileObserverNumber;

	// Number of file lock notifications received this backup

	TInt iFileLocksChanged;

	// Whether we're testing with an introduced delay or not

	TBool iDelay;

	// Local RTest for this class - needed because global RTest fails in multi-threaded environment

	RTest* iLocalRTest;

	// Name of the file we're observing

	TFileName iFileName;

	// State of the file we're observing

	TFileLock iFileLockState;

	};

//

//	class CBackupOperationObserver

//

class CBackupOperationObserver : public CActive, public MBackupOperationObserver

	{

public:

	static CBackupOperationObserver* NewL(TInt aObserverNumber);

	~CBackupOperationObserver();

public: // From CActive

	void RunL();

	void DoCancel();

public:

	void Kill(RThread* aThread);

private:

	CBackupOperationObserver();

	void ConstructL(TInt aObserverNumber);

	// from MBackupOperationObserver

	virtual void HandleBackupOperationEventL(const TBackupOperationAttributes& aBackupOperationAttributes);

private: 

	// Every backup observer has their own session

	CBaBackupSessionWrapper* iBackupSession;

	// Every backup observer has their own identifying number

	TInt iObserverNumber;

	// Local RTest for this class - needed because global RTest fails in multi-threaded environment

	RTest* iLocalRTest;

	};

//

//	class CBackupTestsStateMachine

//

class CBackupTestsStateMachine : public CActive

	{

public:

	static CBackupTestsStateMachine* NewL();

	CBackupTestsStateMachine();

	~CBackupTestsStateMachine();

public: // From CActive

	void RunL();

	void RunError();

	void DoCancel();

public:

	void Start();

	void End();

	void Complete();

	void StartBackupL();

	void EndBackup(TInt aFileLockChangesExpected, TBool oneTimeOnly);

	void SignalEndBackupL();

	void SingleFileLockTestsL();

public:

	void CreateObserversThreadsL();

	static TInt BackupObserversThreadStartL(TAny* aPtr);

	static TInt FileObserversThreadStartL(TAny* aPtr);

	void CreateBackupObserverInstanceL();

	void CreateFileObserverInstanceL();

public:

	enum StateMachineState

		{EStateMachineStart,

		 ESingleFileTests,		   ENoBackupSessionSingleFileTests,

		 ECloseAllNormalReadOnly,  ECloseAllNormalReadOnlyReturned, 

		 ECloseAllNormalNoAccess,  ECloseAllNormalNoAccessReturned, 

		 ECloseAllDelayReadOnly,   ECloseAllDelayReadOnlyReturned,  

		 ECloseAllDelayNoAccess,   ECloseAllDelayNoAccessReturned,

		 ECloseAllDropFileSession, ECloseAllDropFileSessionReturned,

		 ECloseAllDropBackupObserverSession, ECloseAllDropBackupObserverSessionReturned,

		 EStateMachineEnd};

public:

	void CloseAllStartL(StateMachineState aNextState, MBackupObserver::TFileLockFlags aFlag);

	void CloseAllEndL(StateMachineState aNextState, TInt aExpectedNotifications);

private:

	void ConstructL();

private:

	// The RTest class for this thread

	RTest* iLocalRTest;

	// The "command" session

	CBaBackupSessionWrapper* iBackupSession;	

	// Safety for RArrays

	RMutex iMutex;

	// Array of backup observers

	RPointerArray<CBackupOperationObserver> iBackupObservers;

	// Array of file lock observers

	RPointerArray<CBackupFileObserver> iBackupFileObservers;

	// Used for single file tests

	TInt iEndBackupRecursionCount;

	// Current state of the State Machine

	StateMachineState iState;

	// Used for backup observer threads

	RPointerArray<RThread> iBackupObserverThreads;

	// Used for file observer threads

	RPointerArray<RThread> iFileObserverThreads;

	};