1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/lowlevellibsandfws/apputils/tsrc/T_backupSrv.h Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,150 @@
1.4 +// Copyright (c) 1997-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +// class CBackupFileObserver
1.18 +//
1.19 +//
1.20 +
1.21 +class CBackupFileObserver : public CActive, public MBackupObserver
1.22 + {
1.23 +public:
1.24 + enum TFileLock
1.25 + {ELocked,EReadOnly,ENoAccess};
1.26 +public:
1.27 + static CBackupFileObserver* NewL(TInt aFileObserverNumber);
1.28 + ~CBackupFileObserver();
1.29 + void AddFileL(TInt aFileNumber);
1.30 +public:
1.31 + TInt GetFileLocksChanged();
1.32 + void ZeroFileLocksChanged();
1.33 + void SetDelay(TBool aDelay);
1.34 +private:
1.35 + CBackupFileObserver();
1.36 + void ConstructL(TInt aFileObserverNumber);
1.37 +private: // from MBackupObserver
1.38 + void ChangeFileLockL(const TDesC& aFileName,TFileLockFlags aFlags);
1.39 +public: // From CActive
1.40 + void RunL();
1.41 + void DoCancel();
1.42 +public:
1.43 + void Kill(RThread* aThread);
1.44 +private:
1.45 + // File observer session into the server
1.46 + CBaBackupSessionWrapper* iBackupSession;
1.47 + // Instance number for this obsever
1.48 + TInt iFileObserverNumber;
1.49 + // Number of file lock notifications received this backup
1.50 + TInt iFileLocksChanged;
1.51 + // Whether we're testing with an introduced delay or not
1.52 + TBool iDelay;
1.53 + // Local RTest for this class - needed because global RTest fails in multi-threaded environment
1.54 + RTest* iLocalRTest;
1.55 + // Name of the file we're observing
1.56 + TFileName iFileName;
1.57 + // State of the file we're observing
1.58 + TFileLock iFileLockState;
1.59 + };
1.60 +
1.61 +//
1.62 +// class CBackupOperationObserver
1.63 +//
1.64 +class CBackupOperationObserver : public CActive, public MBackupOperationObserver
1.65 + {
1.66 +public:
1.67 + static CBackupOperationObserver* NewL(TInt aObserverNumber);
1.68 + ~CBackupOperationObserver();
1.69 +public: // From CActive
1.70 + void RunL();
1.71 + void DoCancel();
1.72 +public:
1.73 + void Kill(RThread* aThread);
1.74 +private:
1.75 + CBackupOperationObserver();
1.76 + void ConstructL(TInt aObserverNumber);
1.77 +
1.78 + // from MBackupOperationObserver
1.79 + virtual void HandleBackupOperationEventL(const TBackupOperationAttributes& aBackupOperationAttributes);
1.80 +private:
1.81 + // Every backup observer has their own session
1.82 + CBaBackupSessionWrapper* iBackupSession;
1.83 + // Every backup observer has their own identifying number
1.84 + TInt iObserverNumber;
1.85 + // Local RTest for this class - needed because global RTest fails in multi-threaded environment
1.86 + RTest* iLocalRTest;
1.87 + };
1.88 +
1.89 +//
1.90 +// class CBackupTestsStateMachine
1.91 +//
1.92 +
1.93 +class CBackupTestsStateMachine : public CActive
1.94 + {
1.95 +public:
1.96 + static CBackupTestsStateMachine* NewL();
1.97 + CBackupTestsStateMachine();
1.98 + ~CBackupTestsStateMachine();
1.99 +public: // From CActive
1.100 + void RunL();
1.101 + void RunError();
1.102 + void DoCancel();
1.103 +public:
1.104 + void Start();
1.105 + void End();
1.106 + void Complete();
1.107 + void StartBackupL();
1.108 + void EndBackup(TInt aFileLockChangesExpected, TBool oneTimeOnly);
1.109 + void SignalEndBackupL();
1.110 + void SingleFileLockTestsL();
1.111 +public:
1.112 + void CreateObserversThreadsL();
1.113 + static TInt BackupObserversThreadStartL(TAny* aPtr);
1.114 + static TInt FileObserversThreadStartL(TAny* aPtr);
1.115 + void CreateBackupObserverInstanceL();
1.116 + void CreateFileObserverInstanceL();
1.117 +public:
1.118 + enum StateMachineState
1.119 + {EStateMachineStart,
1.120 + ESingleFileTests, ENoBackupSessionSingleFileTests,
1.121 + ECloseAllNormalReadOnly, ECloseAllNormalReadOnlyReturned,
1.122 + ECloseAllNormalNoAccess, ECloseAllNormalNoAccessReturned,
1.123 + ECloseAllDelayReadOnly, ECloseAllDelayReadOnlyReturned,
1.124 + ECloseAllDelayNoAccess, ECloseAllDelayNoAccessReturned,
1.125 + ECloseAllDropFileSession, ECloseAllDropFileSessionReturned,
1.126 + ECloseAllDropBackupObserverSession, ECloseAllDropBackupObserverSessionReturned,
1.127 + EStateMachineEnd};
1.128 +public:
1.129 + void CloseAllStartL(StateMachineState aNextState, MBackupObserver::TFileLockFlags aFlag);
1.130 + void CloseAllEndL(StateMachineState aNextState, TInt aExpectedNotifications);
1.131 +private:
1.132 + void ConstructL();
1.133 +private:
1.134 + // The RTest class for this thread
1.135 + RTest* iLocalRTest;
1.136 + // The "command" session
1.137 + CBaBackupSessionWrapper* iBackupSession;
1.138 + // Safety for RArrays
1.139 + RMutex iMutex;
1.140 + // Array of backup observers
1.141 + RPointerArray<CBackupOperationObserver> iBackupObservers;
1.142 + // Array of file lock observers
1.143 + RPointerArray<CBackupFileObserver> iBackupFileObservers;
1.144 + // Used for single file tests
1.145 + TInt iEndBackupRecursionCount;
1.146 + // Current state of the State Machine
1.147 + StateMachineState iState;
1.148 + // Used for backup observer threads
1.149 + RPointerArray<RThread> iBackupObserverThreads;
1.150 + // Used for file observer threads
1.151 + RPointerArray<RThread> iFileObserverThreads;
1.152 + };
1.153 +