1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/ossrv/lowlevellibsandfws/apputils/tsrc/T_BackupSrv.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,767 @@
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 +//
1.18 +
1.19 +#include <e32debug.h>
1.20 +#include <e32test.h>
1.21 +#include <babackup.h>
1.22 +#include "T_backupSrv.h"
1.23 +LOCAL_D RTest MainTest(_L(" T_BackupSrv.cpp"));
1.24 +
1.25 +_LIT(KFileName1, "FileName1");
1.26 +_LIT(KFileName2, "FileName2");
1.27 +_LIT(KFileName3, "FileName3");
1.28 +_LIT(KFileName4, "FileName4");
1.29 +
1.30 +// Nasty global convenience function
1.31 +LOCAL_D void LogThread()
1.32 +{
1.33 + TBuf<150> buf((RThread().Name()));
1.34 + RDebug::Print(_L("*** Currently in thread : "));
1.35 + RDebug::Print(buf);
1.36 +}
1.37 +
1.38 +//
1.39 +// class CBackupOperationObserver
1.40 +//
1.41 +CBackupOperationObserver* CBackupOperationObserver::NewL(TInt aObserverNumber)
1.42 + {
1.43 + LogThread();
1.44 + RDebug::Print(_L("CBackupOperationObserver::NewL"));
1.45 +
1.46 + CBackupOperationObserver* self = new (ELeave) CBackupOperationObserver();
1.47 + CleanupStack::PushL(self);
1.48 + self->ConstructL(aObserverNumber);
1.49 + CleanupStack::Pop();
1.50 + return self;
1.51 + }
1.52 +
1.53 +CBackupOperationObserver::CBackupOperationObserver()
1.54 + : CActive(0)
1.55 + { ; }
1.56 +
1.57 +CBackupOperationObserver::~CBackupOperationObserver()
1.58 + {
1.59 + LogThread();
1.60 + RDebug::Print(_L("CBackupOperationObserver::~CBackupOperationObserver"));
1.61 +
1.62 + iBackupSession->DeRegisterBackupOperationObserver(*this);
1.63 + delete iBackupSession;
1.64 +
1.65 + delete iLocalRTest;
1.66 + }
1.67 +
1.68 +void CBackupOperationObserver::ConstructL(TInt aObserverNumber)
1.69 + {
1.70 + // Set up the AO callback
1.71 + CActiveScheduler::Add(this);
1.72 + SetActive();
1.73 + iStatus = KRequestPending;
1.74 +
1.75 + // Create a new session for this backup notification observer
1.76 + iBackupSession = CBaBackupSessionWrapper::NewL();
1.77 + iBackupSession->RegisterBackupOperationObserverL(*this);
1.78 + iObserverNumber = aObserverNumber;
1.79 + iLocalRTest = new (ELeave) RTest(_L("BackupOperationObserver"));
1.80 + }
1.81 +
1.82 +void CBackupOperationObserver::HandleBackupOperationEventL(const TBackupOperationAttributes& aBackupOperationAttributes)
1.83 + {
1.84 + LogThread();
1.85 + RDebug::Print(_L("CBackupOperationObserver::HandleBackupOperationEventL"));
1.86 +
1.87 + TBuf<150> buf;
1.88 + buf.Format(_L("Backup observer number %d received a notification of operation type %d and file lock type: %d\n"),iObserverNumber, aBackupOperationAttributes.iOperation, aBackupOperationAttributes.iFileFlag);
1.89 + RDebug::Print(buf);
1.90 + }
1.91 +
1.92 +void CBackupOperationObserver::DoCancel()
1.93 + { ; }
1.94 +
1.95 +void CBackupOperationObserver::RunL()
1.96 + {
1.97 + // Okay - we're back in the right thread!
1.98 + LogThread();
1.99 + RDebug::Print(_L("CBackupOperationObserver::RunL"));
1.100 +
1.101 + // Finished with this object
1.102 + delete this;
1.103 +
1.104 + // And the active scheduler in this thread
1.105 + CActiveScheduler::Current()->Stop();
1.106 +
1.107 + }
1.108 +
1.109 +void CBackupOperationObserver::Kill(RThread* aThread)
1.110 + {
1.111 + LogThread();
1.112 + RDebug::Print(_L("CBackupFileObserver::Kill"));
1.113 +
1.114 + // Trigger the Active Object locally - in a different thread!
1.115 + TRequestStatus* tempStatus=(&iStatus);
1.116 + aThread->RequestComplete(tempStatus, KErrNone);
1.117 + }
1.118 +
1.119 +//
1.120 +// class CBackupFileObserver
1.121 +//
1.122 +
1.123 +CBackupFileObserver::CBackupFileObserver()
1.124 + : CActive(0)
1.125 + { ; }
1.126 +
1.127 +void CBackupFileObserver::ConstructL(TInt aFileObserverNumber)
1.128 + {
1.129 + // Set up the AO callback
1.130 + CActiveScheduler::Add(this);
1.131 + SetActive();
1.132 + iStatus = KRequestPending;
1.133 +
1.134 + // Create a new session for this file lock observer
1.135 + iBackupSession = CBaBackupSessionWrapper::NewL();
1.136 + iFileObserverNumber = aFileObserverNumber;
1.137 + iFileLocksChanged = 0;
1.138 + iFileLockState = ELocked;
1.139 + iLocalRTest = new (ELeave) RTest(_L("BackupFileObserver"));
1.140 + }
1.141 +
1.142 +CBackupFileObserver* CBackupFileObserver::NewL(TInt aFileObserverNumber)
1.143 + {
1.144 + LogThread();
1.145 + RDebug::Print(_L("CBackupFileObserver::NewL"));
1.146 +
1.147 + CBackupFileObserver* self=new(ELeave) CBackupFileObserver();
1.148 + CleanupStack::PushL(self);
1.149 + self->ConstructL(aFileObserverNumber);
1.150 + CleanupStack::Pop();
1.151 + return self;
1.152 + }
1.153 +
1.154 +CBackupFileObserver::~CBackupFileObserver()
1.155 + {
1.156 + LogThread();
1.157 + RDebug::Print(_L("CBackupFileObserver::~CBackupFileObserver"));
1.158 +
1.159 + delete iBackupSession;
1.160 +
1.161 + delete iLocalRTest;
1.162 + }
1.163 +
1.164 +void CBackupFileObserver::AddFileL(TInt aFileNumber)
1.165 + {
1.166 + LogThread();
1.167 + RDebug::Print(_L("CBackupFileObserver::AddFileL"));
1.168 +
1.169 + // We base the filename of the number of thread in the RArray
1.170 + iFileName.Format(_L("FileName%d"), aFileNumber);
1.171 +
1.172 + iBackupSession->RegisterFileL(iFileName,*this);
1.173 + }
1.174 +
1.175 +TInt CBackupFileObserver::GetFileLocksChanged()
1.176 + {
1.177 + return iFileLocksChanged;
1.178 + }
1.179 +
1.180 +void CBackupFileObserver::ZeroFileLocksChanged()
1.181 + {
1.182 + iFileLocksChanged = 0;
1.183 + }
1.184 +
1.185 +void CBackupFileObserver::SetDelay(TBool aDelay)
1.186 +{
1.187 + iDelay = aDelay;
1.188 +}
1.189 +
1.190 +void CBackupFileObserver::ChangeFileLockL(const TDesC& aFileName,TFileLockFlags aFlags)
1.191 + {
1.192 + LogThread();
1.193 + RDebug::Print(_L("BackupFileObserver::ChangeFileLockL"));
1.194 +
1.195 + // Keep a count of how many release notifications there have been
1.196 + if (aFlags != MBackupObserver::ETakeLock)
1.197 + {
1.198 + iFileLocksChanged++;
1.199 + }
1.200 +
1.201 + // If delay is set then insert wait now
1.202 + if (iDelay && (!(aFileName.Compare(KFileName1))))
1.203 + {
1.204 + User::After(10000000);
1.205 + }
1.206 +
1.207 + // Check this file is the one for this observer - if not fail test;
1.208 + if (iFileName.Compare(aFileName))
1.209 + {
1.210 + RDebug::Print(_L("\nReceived notification for non-registered file!"));
1.211 + (*iLocalRTest)(EFalse);
1.212 + }
1.213 +
1.214 + // Update the local file lock array
1.215 + CBackupFileObserver::TFileLock flag = (CBackupFileObserver::TFileLock) aFlags;
1.216 + iFileLockState = flag;
1.217 +
1.218 + // Test output
1.219 + TBuf<150> buf;
1.220 + buf.Format(_L("File backup observer number %d was notified for file %S of file lock type: %d\n"),iFileObserverNumber, &aFileName, flag);
1.221 + RDebug::Print(buf);
1.222 + }
1.223 +
1.224 +void CBackupFileObserver::DoCancel()
1.225 + { ; }
1.226 +
1.227 +void CBackupFileObserver::RunL()
1.228 + {
1.229 + // Okay - we're back in the right thread!
1.230 + LogThread();
1.231 + RDebug::Print(_L("CBackupFileObserver::RunL"));
1.232 +
1.233 + // Finished with this object
1.234 + delete this;
1.235 +
1.236 + // And the active scheduler in this thread
1.237 + CActiveScheduler::Current()->Stop();
1.238 +
1.239 + }
1.240 +
1.241 +void CBackupFileObserver::Kill(RThread* aThread)
1.242 + {
1.243 + LogThread();
1.244 + RDebug::Print(_L("CBackupFileObserver::Kill"));
1.245 +
1.246 + // Trigger the Active Object locally - in a different thread!
1.247 + TRequestStatus* tempStatus=(&iStatus);
1.248 + aThread->RequestComplete(tempStatus, KErrNone);
1.249 + }
1.250 +
1.251 +//
1.252 +// class CBackupTestsStateMachine
1.253 +//
1.254 +
1.255 +CBackupTestsStateMachine* CBackupTestsStateMachine::NewL()
1.256 + {
1.257 + CBackupTestsStateMachine* self = new (ELeave) CBackupTestsStateMachine();
1.258 + CleanupStack::PushL(self);
1.259 + self->ConstructL();
1.260 + CleanupStack::Pop();
1.261 + return self;
1.262 + }
1.263 +
1.264 +CBackupTestsStateMachine::CBackupTestsStateMachine()
1.265 + : CActive(0)
1.266 +{ ; }
1.267 +
1.268 +void CBackupTestsStateMachine::ConstructL()
1.269 + {
1.270 + // Set up the RTest for this thread and display we're started
1.271 + iLocalRTest = new (ELeave) RTest(_L("T_BACKUP_SRV"));
1.272 + iLocalRTest->Title();
1.273 +
1.274 + // Set the ititial state
1.275 + iState = EStateMachineStart;
1.276 +
1.277 + // Zero the EndBackupRecursionCount (see below)
1.278 + iEndBackupRecursionCount = 0;
1.279 +
1.280 + // Add this to the Active Scheduler and set us active
1.281 + CActiveScheduler::Add(this);
1.282 + SetActive();
1.283 +
1.284 + // Create the backup "command" session
1.285 + iBackupSession = CBaBackupSessionWrapper::NewL();
1.286 +
1.287 + // Set up the mutex
1.288 + iMutex.CreateLocal();
1.289 + }
1.290 +
1.291 +// Observers need to have their own thread
1.292 +void CBackupTestsStateMachine::CreateObserversThreadsL()
1.293 + {
1.294 + RDebug::Print(_L("Starting observers threads"));
1.295 +
1.296 + TInt i;
1.297 + TBuf<30> newThreadNames;
1.298 + TInt error;
1.299 + for (i = 0; i<4 ; i++)
1.300 + {
1.301 + // Backup observer
1.302 + iBackupObserverThreads.AppendL(new (ELeave) RThread);
1.303 + newThreadNames.Format(_L("Backup Observer Thread %d"), i+1);
1.304 + error = iBackupObserverThreads[i]->Create(newThreadNames, CBackupTestsStateMachine::BackupObserversThreadStartL, 0x2000, NULL, (TAny*)this);
1.305 + (*iLocalRTest)(error==KErrNone);
1.306 + iBackupObserverThreads[i]->Resume();
1.307 +
1.308 + // File observer
1.309 + iFileObserverThreads.AppendL(new (ELeave) RThread);
1.310 + newThreadNames.Format(_L("File Observer Thread %d"), i+1);
1.311 + error = iFileObserverThreads[i]->Create(newThreadNames, CBackupTestsStateMachine::FileObserversThreadStartL, 0x2000, NULL, (TAny*)this);
1.312 +
1.313 + (*iLocalRTest)(error==KErrNone);
1.314 + iFileObserverThreads[i]->Resume();
1.315 +
1.316 + // Brief delay to let the observer threads get started
1.317 + User::After(1000000);
1.318 + }
1.319 +
1.320 + }
1.321 +
1.322 +// Static starting function for the backup observers threads
1.323 +TInt CBackupTestsStateMachine::BackupObserversThreadStartL(TAny* aPtr)
1.324 + {
1.325 + // Create the Cleanup Stack and Active Scheduler for this thread
1.326 +
1.327 + CTrapCleanup* theTrapCleanup = CTrapCleanup::New();
1.328 + CActiveScheduler *activeScheduler = new CActiveScheduler;
1.329 + CActiveScheduler::Install(activeScheduler);
1.330 +
1.331 + // Create the observer instances
1.332 + CBackupTestsStateMachine* objectPtr = static_cast<CBackupTestsStateMachine*>(aPtr);
1.333 + TRAPD(error, objectPtr->CreateBackupObserverInstanceL());
1.334 + User::LeaveIfError(error);
1.335 +
1.336 + // Go to Active Scheduler main loop for this thread
1.337 + CActiveScheduler::Start();
1.338 +
1.339 + // And we're done
1.340 + delete activeScheduler;
1.341 + delete theTrapCleanup;
1.342 +
1.343 + return KErrNone;
1.344 + }
1.345 +
1.346 +// Static starting function for the file observers threads
1.347 +TInt CBackupTestsStateMachine::FileObserversThreadStartL(TAny* aPtr)
1.348 +{
1.349 + // Create the Cleanup Stack and Active Scheduler for this thread
1.350 + CTrapCleanup* theTrapCleanup = CTrapCleanup::New();
1.351 + CActiveScheduler* activeScheduler = new CActiveScheduler;
1.352 + CActiveScheduler::Install(activeScheduler);
1.353 +
1.354 + // Create the observer instances
1.355 + CBackupTestsStateMachine* objectPtr = static_cast<CBackupTestsStateMachine*>(aPtr);
1.356 + TRAPD(error, objectPtr->CreateFileObserverInstanceL());
1.357 + User::LeaveIfError(error);
1.358 +
1.359 + // Go to Active Scheduler main loop for this thread
1.360 + CActiveScheduler::Start();
1.361 +
1.362 + // And we're done
1.363 + delete activeScheduler;
1.364 + delete theTrapCleanup;
1.365 +
1.366 + return KErrNone;
1.367 +}
1.368 +
1.369 +void CBackupTestsStateMachine::CreateBackupObserverInstanceL()
1.370 + {
1.371 + iMutex.Wait();
1.372 +
1.373 + TInt count = iBackupObserverThreads.Count();
1.374 +
1.375 + // Create the new object instance (one object per thread)
1.376 + // We base the thread number of the number of thread in the RArray
1.377 + CBackupOperationObserver* newObserver = CBackupOperationObserver::NewL(count);
1.378 + iBackupObservers.AppendL(newObserver);
1.379 +
1.380 + iMutex.Signal();
1.381 + }
1.382 +
1.383 +void CBackupTestsStateMachine::CreateFileObserverInstanceL()
1.384 +{
1.385 + iMutex.Wait();
1.386 +
1.387 + TInt count = iBackupFileObservers.Count();
1.388 +
1.389 + // Create the new object instance (one object per thread)
1.390 + CBackupFileObserver* newObserver = CBackupFileObserver::NewL(count + 1);
1.391 + iBackupFileObservers.AppendL(newObserver);
1.392 +
1.393 + // Register the file for this thread / instance
1.394 + iBackupFileObservers[count]->AddFileL(count + 1);
1.395 +
1.396 + iMutex.Signal();
1.397 +}
1.398 +
1.399 +// State Machine destructor
1.400 +CBackupTestsStateMachine::~CBackupTestsStateMachine()
1.401 + {
1.402 + // Close our session into the backup server
1.403 + delete iBackupSession;
1.404 +
1.405 + // Delete all the observers (only 3 of each of by this point)
1.406 + TInt i;
1.407 +
1.408 + for (i = 0; i<3 ; i++)
1.409 + {
1.410 + iBackupObservers[i]->Kill(iBackupObserverThreads[i]);
1.411 + iBackupFileObservers[i]->Kill(iFileObserverThreads[i]);
1.412 + User::After(50000000);
1.413 + }
1.414 + iBackupObservers.Close();
1.415 + iBackupFileObservers.Close();
1.416 +
1.417 + // Kill the observer threads
1.418 + for (i = 0; i<3 ; i++)
1.419 +
1.420 + {
1.421 + iBackupObserverThreads[i]->Kill(KErrNone);
1.422 + delete iBackupObserverThreads[i];
1.423 + iFileObserverThreads[i]->Kill(KErrNone);
1.424 + delete iFileObserverThreads[i];
1.425 + }
1.426 + iBackupObserverThreads.Close();
1.427 + iFileObserverThreads.Close();
1.428 +
1.429 + // Display we're finished
1.430 + iLocalRTest->Close();
1.431 + delete iLocalRTest;
1.432 +
1.433 + // Cancel this is it's active
1.434 + if (IsActive())
1.435 + {
1.436 + Cancel();
1.437 + }
1.438 + }
1.439 +
1.440 +// Common starting function for all test-related calls to CloseAll
1.441 +void CBackupTestsStateMachine::CloseAllStartL(StateMachineState aNextState, MBackupObserver::TFileLockFlags aFlag)
1.442 + {
1.443 + StartBackupL();
1.444 + iState = aNextState;
1.445 + iBackupSession->CloseAll(aFlag, iStatus);
1.446 + }
1.447 +
1.448 +// Common ending function for all test-related calls to CloseAll
1.449 +void CBackupTestsStateMachine::CloseAllEndL(StateMachineState aNextState, TInt aExpectedNotifications)
1.450 + {
1.451 + iState = aNextState;
1.452 + SignalEndBackupL();
1.453 + EndBackup(aExpectedNotifications, ETrue);
1.454 + iLocalRTest->End();
1.455 + Complete();
1.456 + }
1.457 +
1.458 +// State machine call back - get here by calls to Complete and returns for asynchronous server calls
1.459 +void CBackupTestsStateMachine::RunL()
1.460 + {
1.461 + switch(iState)
1.462 + {
1.463 + case EStateMachineStart:
1.464 + // Create observers threads
1.465 + CreateObserversThreadsL();
1.466 + iState = ECloseAllNormalReadOnly;
1.467 + Complete();
1.468 + break;
1.469 + case ECloseAllNormalReadOnly:
1.470 + iLocalRTest->Start(_L("\nCloseAllFiles normal ReadOnly\n"));
1.471 + CloseAllStartL(ECloseAllNormalReadOnlyReturned, MBackupObserver::EReleaseLockReadOnly);
1.472 + break;
1.473 + case ECloseAllNormalReadOnlyReturned:
1.474 + CloseAllEndL(ECloseAllNormalNoAccess, 4);
1.475 + break;
1.476 + case ECloseAllNormalNoAccess:
1.477 + iLocalRTest->Start(_L("\nCloseAllFiles normal NoAccess\n"));
1.478 + CloseAllStartL(ECloseAllNormalNoAccessReturned, MBackupObserver::EReleaseLockNoAccess);
1.479 + break;
1.480 + case ECloseAllNormalNoAccessReturned:
1.481 + CloseAllEndL(ECloseAllDelayReadOnly, 4);
1.482 + break;
1.483 + case ECloseAllDelayReadOnly:
1.484 + iLocalRTest->Start(_L("\nCloseAllFiles delay ReadOnly\n"));
1.485 + iBackupFileObservers[0]->SetDelay(ETrue);
1.486 + CloseAllStartL(ECloseAllDelayReadOnlyReturned, MBackupObserver::EReleaseLockReadOnly);
1.487 + break;
1.488 + case ECloseAllDelayReadOnlyReturned:
1.489 + iBackupFileObservers[0]->SetDelay(EFalse);
1.490 + CloseAllEndL(ECloseAllDelayNoAccess, 4);
1.491 + // Nice long wait for the timer to expire in the other thread
1.492 + User::After(10000000);
1.493 + break;
1.494 + case ECloseAllDelayNoAccess:
1.495 + iLocalRTest->Start(_L("\nCloseAllFiles delay NoAccess\n"));
1.496 + iBackupFileObservers[0]->SetDelay(ETrue);
1.497 + CloseAllStartL(ECloseAllDelayNoAccessReturned, MBackupObserver::EReleaseLockNoAccess);
1.498 + break;
1.499 + case ECloseAllDelayNoAccessReturned:
1.500 + iBackupFileObservers[0]->SetDelay(EFalse);
1.501 + CloseAllEndL(ECloseAllDropFileSession, 4);
1.502 + // Nice long wait for the timer to expire in the other thread
1.503 + User::After(10000000);
1.504 + break;
1.505 + case ECloseAllDropFileSession:
1.506 + iLocalRTest->Start(_L("\nCloseAllFiles dropping file session\n"));
1.507 + // Drop one of the file registration / observer sessions
1.508 + iBackupFileObservers[0]->Kill(iFileObserverThreads[0]);
1.509 + // Nice long wait for the observer to be killed in the other thread
1.510 + User::After(10000000);
1.511 + // Remove it from the list
1.512 + iBackupFileObservers.Remove(0);
1.513 + // Kill the thread
1.514 + iFileObserverThreads[0]->Kill(KErrNone);
1.515 + delete iFileObserverThreads[0];
1.516 + iFileObserverThreads.Remove(0);
1.517 + // All done - start this sub-test
1.518 + CloseAllStartL(ECloseAllDropFileSessionReturned, MBackupObserver::EReleaseLockReadOnly);
1.519 + break;
1.520 + case ECloseAllDropFileSessionReturned:
1.521 + CloseAllEndL(ECloseAllDropBackupObserverSession, 3);
1.522 + break;
1.523 + case ECloseAllDropBackupObserverSession:
1.524 + iLocalRTest->Start(_L("\nCloseAllFiles dropping backup session\n"));
1.525 + // Drop one of the backup observer sessions
1.526 + iBackupObservers[0]->Kill(iBackupObserverThreads[0]);
1.527 + // Nice long wait for the observer to be killed in the other thread
1.528 + User::After(10000000);
1.529 + // Remove it from the list
1.530 + iBackupObservers.Remove(0);
1.531 + // Kill the thread
1.532 + iBackupObserverThreads[0]->Kill(KErrNone);
1.533 + delete iBackupObserverThreads[0];
1.534 + iBackupObserverThreads.Remove(0);
1.535 + // All done - start this sub-test
1.536 + CloseAllStartL(ECloseAllDropBackupObserverSessionReturned, MBackupObserver::EReleaseLockReadOnly);
1.537 + break;
1.538 + case ECloseAllDropBackupObserverSessionReturned:
1.539 + CloseAllEndL(ESingleFileTests, 3);
1.540 + break;
1.541 + case ESingleFileTests:
1.542 + iLocalRTest->Start(_L("\nSingle file lock tests\n"));
1.543 + StartBackupL();
1.544 + SingleFileLockTestsL();
1.545 + SignalEndBackupL();
1.546 + // Can call EndBackup synchronously here as nothing in SingleFileLockTests is asynchronous
1.547 + EndBackup(3, EFalse);
1.548 + iLocalRTest->End();
1.549 + iState = ENoBackupSessionSingleFileTests;
1.550 + Complete();
1.551 + break;
1.552 + // Required to cover the situation when the backup server is used purely for message signalling
1.553 + // For example in the LogEng compnent
1.554 + case ENoBackupSessionSingleFileTests:
1.555 + iLocalRTest->Start(_L("\nNo backup session single file lock tests\n"));
1.556 + SingleFileLockTestsL();
1.557 + // Can call EndBackup synchronously here as nothing in SingleFileLockTests is asynchronous
1.558 + EndBackup(3, EFalse);
1.559 + iLocalRTest->End();
1.560 + iState = EStateMachineEnd;
1.561 + Complete();
1.562 + break;
1.563 + case EStateMachineEnd:
1.564 + RDebug::Print(_L("\nEnd of state machine\n"));
1.565 + End();
1.566 + break;
1.567 + default:
1.568 + RDebug::Print(_L("\nCBackupTestsStateMachine::RunL problem"));
1.569 + break;
1.570 + }
1.571 + if (!IsActive())
1.572 + {
1.573 + SetActive();
1.574 + }
1.575 + }
1.576 +
1.577 +void CBackupTestsStateMachine::DoCancel()
1.578 + {
1.579 + Complete();
1.580 + }
1.581 +
1.582 +void CBackupTestsStateMachine::RunError()
1.583 + { ; }
1.584 +
1.585 +// Common function to start a backup
1.586 +void CBackupTestsStateMachine::StartBackupL()
1.587 + {
1.588 + TBackupOperationAttributes attribs;
1.589 + attribs.iFileFlag=MBackupObserver::EReleaseLockNoAccess;
1.590 + attribs.iOperation=MBackupOperationObserver::EStart;
1.591 + iBackupSession->NotifyBackupOperationL(attribs);
1.592 + RDebug::Print(_L("\nStarting backup\n"));
1.593 + }
1.594 +
1.595 +void CBackupTestsStateMachine::SignalEndBackupL()
1.596 + {
1.597 + // Tell the server the backup is over
1.598 + TBackupOperationAttributes attribs;
1.599 + attribs.iFileFlag=MBackupObserver::EReleaseLockNoAccess;
1.600 + attribs.iOperation=MBackupOperationObserver::EEnd;
1.601 + iBackupSession->NotifyBackupOperationL(attribs);
1.602 + }
1.603 +
1.604 +// This function works in two ways. If oneTimeOnly is ETrue then all file lock
1.605 +// change notifications must have been received before this function is called.
1.606 +// If oneTimeOnly is EFalse this function recursively calls itself (a finate number
1.607 +// of times) until all notifications have arrived (this happens with single file testing)
1.608 +void CBackupTestsStateMachine::EndBackup(TInt aFileLockChangesExpected, TBool oneTimeOnly)
1.609 + {
1.610 + // Get the total notification count so far
1.611 + TInt numberOfObservers = iBackupFileObservers.Count();
1.612 + TInt totalNotificationCount = 0;
1.613 + for (TInt i=0; i<numberOfObservers ; i++)
1.614 + {
1.615 + totalNotificationCount += iBackupFileObservers[i]->GetFileLocksChanged();
1.616 + }
1.617 + if (aFileLockChangesExpected == totalNotificationCount)
1.618 + {
1.619 + // Reset the recursion count
1.620 + iEndBackupRecursionCount = 0;
1.621 +
1.622 + // Zero the notification counts in the file lock observers
1.623 + for (TInt i = 0 ; i<numberOfObservers ; i++)
1.624 + {
1.625 + iBackupFileObservers[i]->ZeroFileLocksChanged();
1.626 + }
1.627 +
1.628 + // Debug output
1.629 + TBuf<100> buf;
1.630 + buf.Format(_L("\nBackup finished sucsessfully on recusion count %d of EndBackup\n"), iEndBackupRecursionCount);
1.631 + RDebug::Print(buf);
1.632 + }
1.633 + else if (oneTimeOnly)
1.634 + {
1.635 + // No second chances - fail here
1.636 + (*iLocalRTest)(EFalse);
1.637 + }
1.638 + else
1.639 + {
1.640 + // Give it 5 more seconds (in 10 .5 second iterations) for the notifications to arrive
1.641 + User::After(500000);
1.642 + // 5 seconds is more than enough (timeouts in server should have gone off by now anyway)
1.643 + iEndBackupRecursionCount++;
1.644 + if (iEndBackupRecursionCount > 10)
1.645 + {
1.646 + (*iLocalRTest)(EFalse);
1.647 + }
1.648 + // Recursively calling isn't great but it needs to leave the function so the AO can run
1.649 + EndBackup(aFileLockChangesExpected, EFalse);
1.650 + }
1.651 +
1.652 + }
1.653 +
1.654 +void CBackupTestsStateMachine::Complete()
1.655 + {
1.656 + // Trigger the Active Object locally
1.657 + TRequestStatus* tempStatus=(&iStatus);
1.658 + User::RequestComplete(tempStatus, KErrNone);
1.659 + }
1.660 +
1.661 +void CBackupTestsStateMachine::Start()
1.662 + {
1.663 + // Time to start testing
1.664 + RDebug::Print(_L("\nCBackupTestsStateMachine::Start"));
1.665 + Complete();
1.666 + }
1.667 +
1.668 +void CBackupTestsStateMachine::End()
1.669 + {
1.670 + // We're done testing - kill the Active Scheduler
1.671 + RDebug::Print(_L("\nAll test complete\n"));
1.672 + Cancel();
1.673 + CActiveScheduler::Current()->Stop();
1.674 + }
1.675 +
1.676 +void CBackupTestsStateMachine::SingleFileLockTestsL()
1.677 + {
1.678 + TFileName file;
1.679 +
1.680 + // File 1
1.681 + file.Copy(KFileName1);
1.682 + iLocalRTest->Next(file);
1.683 +
1.684 + iBackupSession->CloseFileL(KFileName1, MBackupObserver::EReleaseLockReadOnly);
1.685 + iBackupSession->RestartFile(file);
1.686 +
1.687 +// iBackupSession->CloseFileL(KFileName1, MBackupObserver::EReleaseLockNoAccess);
1.688 +// iBackupSession->RestartFile(file);
1.689 +
1.690 + // File 2
1.691 + file.Copy(KFileName2);
1.692 + iLocalRTest->Next(file);
1.693 +
1.694 + iBackupSession->CloseFileL(KFileName2, MBackupObserver::EReleaseLockReadOnly);
1.695 + iBackupSession->RestartFile(file);
1.696 +
1.697 +// iBackupSession->CloseFileL(KFileName2, MBackupObserver::EReleaseLockNoAccess);
1.698 +// iBackupSession->RestartFile(file);
1.699 +
1.700 + // File 3
1.701 + file.Copy(KFileName3);
1.702 + iLocalRTest->Next(file);
1.703 +
1.704 + iBackupSession->CloseFileL(KFileName3, MBackupObserver::EReleaseLockReadOnly);
1.705 + iBackupSession->RestartFile(file);
1.706 +
1.707 +// iBackupSession->CloseFileL(KFileName3, MBackupObserver::EReleaseLockNoAccess);
1.708 +// iBackupSession->RestartFile(file);
1.709 +
1.710 + // File 3
1.711 + file.Copy(KFileName4);
1.712 + iLocalRTest->Next(file);
1.713 +
1.714 + iBackupSession->CloseFileL(KFileName4, MBackupObserver::EReleaseLockReadOnly);
1.715 + iBackupSession->RestartFile(file);
1.716 +
1.717 +// iBackupSession->CloseFileL(KFileName4, MBackupObserver::EReleaseLockNoAccess);
1.718 +// iBackupSession->RestartFile(file);
1.719 + }
1.720 +
1.721 +/**
1.722 +@SYMTestCaseID SYSLIB-BAFL-CT-0467
1.723 +@SYMTestCaseDesc Tests the functionality of CBaBackupSessionWrapper class
1.724 +@SYMTestPriority High
1.725 +@SYMTestActions Tests for the enabling backup of files
1.726 +@SYMTestExpectedResults Test must not fail
1.727 +@SYMREQ REQ0000
1.728 +*/
1.729 +LOCAL_D void StartTestsL()
1.730 + {
1.731 + // For the sake of logging let's start off by renaming the main "command" thread
1.732 + RThread().RenameMe(_L("Main thread"));
1.733 +
1.734 + // Create state machine
1.735 + CBackupTestsStateMachine* stateMachine = CBackupTestsStateMachine::NewL();
1.736 +
1.737 + // Kick it off
1.738 + stateMachine->Start();
1.739 +
1.740 + // Start the Active Scheduler
1.741 + CActiveScheduler::Start();
1.742 +
1.743 + // Clean up the state machine
1.744 + delete stateMachine;
1.745 + }
1.746 +
1.747 +TInt E32Main()
1.748 + {
1.749 + MainTest.Title();
1.750 + MainTest.Start(_L(" @SYMTestCaseID:SYSLIB-BAFL-CT-0467 Loading Device"));
1.751 +
1.752 + __UHEAP_MARK;
1.753 +
1.754 + CTrapCleanup* theTrapCleanup=CTrapCleanup::New();
1.755 + CActiveScheduler *activeScheduler=new CActiveScheduler;
1.756 + CActiveScheduler::Install(activeScheduler);
1.757 +
1.758 + TRAPD(error, StartTestsL());
1.759 + User::LeaveIfError(error);
1.760 +
1.761 + delete activeScheduler;
1.762 + delete theTrapCleanup;
1.763 +
1.764 + __UHEAP_MARKEND;
1.765 +
1.766 + MainTest.End();
1.767 +
1.768 +
1.769 + return(KErrNone);
1.770 + }