1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/centralrepository/cenrepsrv/install.cpp Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,578 @@
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 +// Implements installed file notification
1.18 +//
1.19 +//
1.20 +
1.21 +/**
1.22 + @internalComponent
1.23 +*/
1.24 +
1.25 +#include "install.h"
1.26 +#include "srvrepos_noc.h"
1.27 +#include "srvres.h"
1.28 +#include "srvparams.h"
1.29 +#include "cachemgr.h"
1.30 +
1.31 +CCentRepSWIWatcher* CCentRepSWIWatcher::NewL(RFs& aFs)
1.32 + {
1.33 + CCentRepSWIWatcher* self = new(ELeave) CCentRepSWIWatcher(aFs);
1.34 + CleanupStack::PushL(self);
1.35 + self->ConstructL();
1.36 + CleanupStack::Pop(self);
1.37 + return self;
1.38 + }
1.39 +
1.40 +void CCentRepSWIWatcher::ConstructL()
1.41 + {
1.42 + // Attach to SWI property
1.43 + User::LeaveIfError(iSWIKey.Attach( KUidSystemCategory, KSAUidSoftwareInstallKeyValue));
1.44 +
1.45 + // Initialise SWI operation and status
1.46 + TInt swiProperty;
1.47 + const TInt error = iSWIKey.Get(KUidSystemCategory, KSAUidSoftwareInstallKeyValue, swiProperty);
1.48 +
1.49 + if (error == KErrNone)
1.50 + {
1.51 + iSWIOperation=swiProperty & KSASwisOperationMask;
1.52 + iSWIStatus= swiProperty & KSASwisOperationStatusMask;
1.53 + }
1.54 + else if (error != KErrNotFound)
1.55 + {
1.56 + User::LeaveIfError(error);
1.57 + }
1.58 +
1.59 + // Get last saved contents of install directory
1.60 + GetInstallDirL();
1.61 +
1.62 + // Do any actions required by pre server start-up SWI activity
1.63 + TRAP_IGNORE(FindChangedEntriesL(ETrue));
1.64 + }
1.65 +
1.66 +CCentRepSWIWatcher::CCentRepSWIWatcher(RFs& aFs) :
1.67 + CActive(EPriorityStandard),
1.68 + iInstallDir(*TServerResources::iInstallDirectory),
1.69 + iFs(aFs),
1.70 + iSWIOperation( ESASwisNone),
1.71 + iSWIStatus( ESASwisStatusSuccess)
1.72 + {
1.73 + CActiveScheduler::Add(this);
1.74 + }
1.75 +
1.76 +CCentRepSWIWatcher::~CCentRepSWIWatcher()
1.77 + {
1.78 + Cancel();
1.79 + if(iSWIKey.Handle() != KNullHandle)
1.80 + {
1.81 + iSWIKey.Cancel();
1.82 + iSWIKey.Close();
1.83 + }
1.84 + iInstallEntryArray.ResetAndDestroy();
1.85 + iCurrentInstallDirEntries.ResetAndDestroy();
1.86 + }
1.87 +
1.88 +void CCentRepSWIWatcher::Start()
1.89 + {
1.90 + if(IsActive())
1.91 + return;
1.92 +
1.93 + NotifyChange();
1.94 + }
1.95 +
1.96 + void CCentRepSWIWatcher::NotifyChange()
1.97 + {
1.98 +
1.99 + // Register for P&S of SWI flag
1.100 + iSWIKey.Subscribe(iStatus);
1.101 +
1.102 + SetActive();
1.103 + }
1.104 +
1.105 +void CCentRepSWIWatcher::RunL()
1.106 + {
1.107 + NotifyChange();
1.108 +
1.109 + // Get SWI Key
1.110 + TInt swiProperty;
1.111 + User::LeaveIfError(iSWIKey.Get(KUidSystemCategory, KSAUidSoftwareInstallKeyValue, swiProperty));
1.112 +
1.113 + HandleSWIEventL(swiProperty);
1.114 + }
1.115 +
1.116 +void CCentRepSWIWatcher::HandleSWIEventL(TInt aSWIProperty)
1.117 + {
1.118 + iSWIOperation=aSWIProperty & KSASwisOperationMask;
1.119 + iSWIStatus= aSWIProperty & KSASwisOperationStatusMask;
1.120 +
1.121 + // Need to handle successful and aborted install/uninstall and successful restore
1.122 + // Can't handle aborted restore
1.123 + switch(iSWIOperation)
1.124 + {
1.125 + case ESASwisNone:
1.126 + break;
1.127 + case ESASwisInstall:
1.128 + case ESASwisUninstall:
1.129 + if(iSWIStatus==ESASwisStatusSuccess)
1.130 + {
1.131 + // Handle SWI events
1.132 + FindChangedEntriesL();
1.133 + }
1.134 + else if(iSWIStatus==ESASwisStatusAborted)
1.135 + {
1.136 + // Update directory to reset timestamps
1.137 + ReadInstallDirL(iInstallEntryArray);
1.138 + SaveInstallDirL();
1.139 + }
1.140 + break;
1.141 + case ESASwisRestore:
1.142 + break;
1.143 + default:
1.144 + break;
1.145 + }
1.146 + }
1.147 +
1.148 +// Catch leaves so they don't stop the server
1.149 +TInt CCentRepSWIWatcher::RunError( TInt aError)
1.150 + {
1.151 + static_cast<void>(aError);
1.152 +
1.153 + RDebug::Print(_L("Run error %d"), aError);
1.154 +
1.155 + // Reinitialise directory list
1.156 + iInstallEntryArray.ResetAndDestroy();
1.157 +
1.158 + if(!IsActive())
1.159 + {
1.160 + NotifyChange();
1.161 + }
1.162 +
1.163 + // Renable cache activity in case of errors during SWI events
1.164 + TServerResources::iCacheManager->EnableCache();
1.165 +
1.166 + return KErrNone;
1.167 + }
1.168 +
1.169 +void CCentRepSWIWatcher::DoCancel()
1.170 + {
1.171 + // Cancel subscription to SW P&S flag
1.172 + iSWIKey.Cancel();
1.173 + iSWIKey.Close();
1.174 + }
1.175 +
1.176 +void CCentRepSWIWatcher::ReadInstallDirL(RPointerArray<CInstallEntry> &aEntryArray)
1.177 + {
1.178 + RDir dir;
1.179 + CleanupClosePushL(dir);
1.180 +
1.181 + //Empty contents of directory
1.182 + aEntryArray.ResetAndDestroy();
1.183 +
1.184 + // Read contents of install directory
1.185 + User::LeaveIfError(dir.Open(iFs, iInstallDir, KEntryAttNormal));
1.186 +
1.187 + TEntryArray dirEntries;
1.188 + TInt readError = KErrNone;
1.189 +
1.190 + while (readError != KErrEof)
1.191 + {
1.192 + readError = dir.Read(dirEntries);
1.193 +
1.194 + if(readError != KErrNone && readError != KErrEof)
1.195 + {
1.196 + User::Leave(readError);
1.197 + }
1.198 + else
1.199 + {
1.200 + const TInt dirCount = dirEntries.Count();
1.201 + for (TInt i=0; i<dirCount; i++)
1.202 + {
1.203 + CInstallEntry* installEntry = CInstallEntry::NewL();
1.204 + CleanupStack::PushL(installEntry);
1.205 + installEntry->SetL(const_cast<TEntry&>(dirEntries[i]));
1.206 + if (installEntry->FileExt()==EUnknown)
1.207 + {
1.208 + CleanupStack::PopAndDestroy();
1.209 + }
1.210 + else
1.211 + {
1.212 + User::LeaveIfError(aEntryArray.Append(installEntry));
1.213 + CleanupStack::Pop(installEntry);
1.214 + }
1.215 + }
1.216 + }
1.217 + }
1.218 +
1.219 + CleanupStack::PopAndDestroy(&dir);
1.220 + }
1.221 +
1.222 +TBool CCentRepSWIWatcher::MatchEntries( const CInstallEntry &aSource, const CInstallEntry &aTarget)
1.223 + {
1.224 + return((aSource.Uid()==aTarget.Uid()) &&
1.225 + (aSource.FileExt()==aTarget.FileExt()));
1.226 + }
1.227 +
1.228 +void CCentRepSWIWatcher::FindChangedEntriesL(TBool aStartup)
1.229 + {
1.230 + // Find added or updated entries
1.231 + ReadInstallDirL(iCurrentInstallDirEntries);
1.232 +
1.233 + // We don't want cache activity during SWI operations
1.234 + TServerResources::iCacheManager->DisableCache();
1.235 +
1.236 + TRAPD(err, HandleFileChangesL(aStartup));
1.237 +
1.238 + // SWI operations finished, enable cache
1.239 + TServerResources::iCacheManager->EnableCache();
1.240 + User::LeaveIfError(err);
1.241 + }
1.242 +
1.243 +void CCentRepSWIWatcher::HandleFileChangesL(TBool aStartup)
1.244 + {
1.245 + TInt newCount=iCurrentInstallDirEntries.Count();
1.246 + TInt currentCount=iInstallEntryArray.Count();
1.247 + TInt i;
1.248 + TInt r;
1.249 + TInt operation;
1.250 +
1.251 + // If both counts are 0, we shouldn't have been notified, just return
1.252 + if( (newCount==0) && (currentCount==0))
1.253 + return;
1.254 +
1.255 + if(aStartup)
1.256 + {
1.257 + operation=ESASwisNone;
1.258 + }
1.259 + else
1.260 + {
1.261 + operation=iSWIOperation;
1.262 + }
1.263 +
1.264 + if( newCount==0) // currentCount > 0, newCount = 0
1.265 + { // All installed files have been deleted
1.266 + // Handle deletes of all files
1.267 + for(i=0;i<currentCount;i++)
1.268 + {
1.269 + iInstallEntryArray[i]->HandleFileDeleteL(operation);
1.270 + }
1.271 + // Free memory of elements
1.272 + iInstallEntryArray.ResetAndDestroy();
1.273 + }
1.274 + else
1.275 + {
1.276 + if( currentCount==0) // currentCount = 0, newCount > 0
1.277 + { // All new files need to be handled
1.278 + for(i=0;i<newCount;i++)
1.279 + {
1.280 + CInstallEntry* newEntry=iCurrentInstallDirEntries[i];
1.281 + newEntry->HandleFileCreateL(operation);
1.282 + }
1.283 + }
1.284 + else // currentCount > 0, newCount > 0
1.285 + {
1.286 + // Find added and modified entries by going through new entries and
1.287 + // looking for them in current array
1.288 + for(i=0;i<newCount;i++)
1.289 + {
1.290 + CInstallEntry* newEntry=iCurrentInstallDirEntries[i];
1.291 + r=iInstallEntryArray.Find( newEntry, MatchEntries);
1.292 + // If we find new entry in current array, check modification date
1.293 + if(r>=KErrNone)
1.294 + {
1.295 + CInstallEntry* currentEntry=iInstallEntryArray[r];
1.296 + if( newEntry->Modified() > currentEntry->Modified())
1.297 + {
1.298 + // Deal with newly installed file, note use newEntry
1.299 + // so we use new timestamp
1.300 + newEntry->HandleFileUpdateL(operation);
1.301 + }
1.302 + }
1.303 + else if(r==KErrNotFound) // File has been added
1.304 + {
1.305 + // Handle add
1.306 + newEntry->HandleFileCreateL(operation);
1.307 + // Don't leave on KErrNotFound
1.308 + r=KErrNone;
1.309 + }
1.310 + User::LeaveIfError(r);
1.311 + }
1.312 +
1.313 + // Find deleted entries by going through current entries and looking for them
1.314 + // in new array
1.315 + for(i=0;i<currentCount;i++)
1.316 + {
1.317 + CInstallEntry* currentEntry=iInstallEntryArray[i];
1.318 + r=iCurrentInstallDirEntries.Find( currentEntry, MatchEntries);
1.319 + // If we don't find current entry in new array, it's been deleted
1.320 + if(r==KErrNotFound)
1.321 + {
1.322 + // Deal with uninstalls
1.323 + currentEntry->HandleFileDeleteL(operation);
1.324 + // Don't leave on KErrNotFound
1.325 + r=KErrNone;
1.326 + }
1.327 + User::LeaveIfError(r);
1.328 + }
1.329 + }
1.330 +
1.331 + // Clear out old list
1.332 + iInstallEntryArray.ResetAndDestroy();
1.333 +
1.334 + // Re-read directory - if any files were corrupt they have been deleted
1.335 + // during the merge, so we need to re-read in case this has occurred
1.336 + ReadInstallDirL(iInstallEntryArray);
1.337 + }
1.338 +
1.339 + SaveInstallDirL();
1.340 + iCurrentInstallDirEntries.ResetAndDestroy();
1.341 + }
1.342 +
1.343 +CInstallEntry::CInstallEntry() :
1.344 + iUid(KNullUid),
1.345 + iModified(0),
1.346 + iFileExt(EUnknown)
1.347 + {
1.348 + }
1.349 +
1.350 +CInstallEntry::~CInstallEntry()
1.351 + {
1.352 + if( iRepository)
1.353 + {
1.354 + iRepository->Close();
1.355 + delete iRepository;
1.356 + }
1.357 + delete iNotifier;
1.358 + }
1.359 +
1.360 +void CInstallEntry::SetL(TEntry& aEntry)
1.361 + {
1.362 + // Get uid from file name
1.363 + const TInt KUidLen = 8;
1.364 + TPtrC uidPtr=aEntry.iName.Des().LeftTPtr(KUidLen);
1.365 + TLex lex=uidPtr;
1.366 +
1.367 + TUint32 uid;
1.368 + User::LeaveIfError(lex.Val(uid,EHex));
1.369 + iUid.iUid=static_cast<TInt32>(uid);
1.370 +
1.371 + // save extension type
1.372 + _LIT(KIniFileExtension, ".txt");
1.373 + _LIT(KExternalizedFileExt, ".cre");
1.374 +
1.375 + const TInt KExtLen = 4;
1.376 + TPtrC extPtr=aEntry.iName.Des().RightTPtr(KExtLen);
1.377 +
1.378 + if(extPtr.Compare(KIniFileExtension)==0)
1.379 + {
1.380 + iFileExt=EIni;
1.381 + }
1.382 + else if(extPtr.Compare(KExternalizedFileExt)==0)
1.383 + {
1.384 + iFileExt=ECre;
1.385 + }
1.386 + else
1.387 + {
1.388 + iFileExt=EUnknown;
1.389 + }
1.390 +
1.391 + iModified=aEntry.iModified;
1.392 + }
1.393 +
1.394 +void CInstallEntry::ConstructL()
1.395 + {
1.396 + // Create repository object
1.397 + iRepository = new(ELeave) CServerRepository;
1.398 + // Notifier needed to open repositories.
1.399 + iNotifier = new(ELeave)CSessionNotifier ;
1.400 + }
1.401 +
1.402 +CInstallEntry* CInstallEntry::NewL()
1.403 + {
1.404 + CInstallEntry* self=new(ELeave)CInstallEntry();
1.405 + CleanupStack::PushL(self);
1.406 + self->ConstructL();
1.407 + CleanupStack::Pop(self);
1.408 + return self;
1.409 + }
1.410 +
1.411 +TUid CInstallEntry::Uid() const
1.412 + {
1.413 + return iUid;
1.414 + }
1.415 +
1.416 +TTime CInstallEntry::Modified() const
1.417 + {
1.418 + return iModified;
1.419 + }
1.420 +
1.421 +TCentRepFileType CInstallEntry::FileExt() const
1.422 + {
1.423 + return iFileExt;
1.424 + }
1.425 +
1.426 +void CInstallEntry::ExternalizeL(RWriteStream& aStream) const
1.427 + {
1.428 + aStream << iUid.iUid;
1.429 + aStream << iModified.Int64();
1.430 + TUint32 fileExt=iFileExt;
1.431 + aStream << fileExt;
1.432 + }
1.433 +
1.434 +void CInstallEntry::InternalizeL(RReadStream& aStream)
1.435 + {
1.436 + aStream >> iUid.iUid;
1.437 + TInt64 time;
1.438 + aStream >> time;
1.439 + iModified=time;
1.440 + TUint32 fileExt;
1.441 + aStream >> fileExt;
1.442 + iFileExt = static_cast<TCentRepFileType>(fileExt);
1.443 + }
1.444 +
1.445 +
1.446 +void CCentRepSWIWatcher::ReadAndInternalizeInstallDirL(const TDesC& aInstallDirFilePath)
1.447 + {
1.448 + RFile file;
1.449 + User::LeaveIfError(file.Open(TServerResources::iFs,aInstallDirFilePath, EFileRead|EFileShareReadersOnly));
1.450 + CleanupClosePushL(file);
1.451 +
1.452 + CDirectFileStore* store = CDirectFileStore::FromLC (file);
1.453 + if(store->Type()[0] != KDirectFileStoreLayoutUid)
1.454 + {
1.455 + User::Leave(KErrCorrupt);
1.456 + }
1.457 +
1.458 + iInstallEntryArray.ResetAndDestroy();
1.459 +
1.460 + // Get the root stream and attempt to read the index from it
1.461 + TStreamId rootStreamId = store->Root() ;
1.462 + RStoreReadStream rootStream ;
1.463 + rootStream.OpenLC(*store, rootStreamId);
1.464 +
1.465 + // Internalize the repository
1.466 + TUint32 count;
1.467 + rootStream >> count;
1.468 + for(TUint i=0; i<count;i++)
1.469 + {
1.470 + CInstallEntry* installEntry = CInstallEntry::NewL();
1.471 + CleanupStack::PushL(installEntry);
1.472 + rootStream >> *installEntry;
1.473 + User::LeaveIfError(iInstallEntryArray.Append(installEntry));
1.474 + CleanupStack::Pop(installEntry);
1.475 + }
1.476 +
1.477 + CleanupStack::PopAndDestroy(&rootStream);
1.478 + CleanupStack::PopAndDestroy(store);
1.479 + CleanupStack::PopAndDestroy();
1.480 + }
1.481 +
1.482 +void CCentRepSWIWatcher::GetInstallDirL()
1.483 + {
1.484 + _LIT(KInstallDirFile, "installdir.bin");
1.485 + HBufC* filePath = HBufC::NewLC(TServerResources::iDataDirectory->Length() + KInstallDirFile().Length());
1.486 + TPtr installDirFilePath(filePath->Des());
1.487 + installDirFilePath.Append(*TServerResources::iDataDirectory);
1.488 + installDirFilePath.Append(KInstallDirFile);
1.489 +
1.490 + TRAPD(err, ReadAndInternalizeInstallDirL(installDirFilePath)); // try to open installdir file and internalize its contents
1.491 + if (err != KErrNone)
1.492 + {
1.493 + TInt fileDeleteErr = TServerResources::iFs.Delete(installDirFilePath);
1.494 + // If a debug build - record error
1.495 + #ifdef _DEBUG
1.496 + if (fileDeleteErr != KErrNone && err != KErrNotFound)
1.497 + {
1.498 + RDebug::Print(_L("CCentRepSWIWatcher::GetInstallDirL - Failed to delete file. Error = %d"), fileDeleteErr);
1.499 + }
1.500 + #else
1.501 + (void)fileDeleteErr;
1.502 + #endif
1.503 +
1.504 + // No file saved - read initial contents of directory
1.505 + ReadInstallDirL(iInstallEntryArray);
1.506 + SaveInstallDirL();
1.507 + }
1.508 + CleanupStack::PopAndDestroy(filePath);
1.509 + }
1.510 +
1.511 +void CCentRepSWIWatcher::SaveInstallDirL()
1.512 + {
1.513 + _LIT(KInstallDirFile, "installdir.bin");
1.514 + _LIT(KInstallDirTmpFile, "installdir.tmp");
1.515 +
1.516 + TBuf<KMaxFileName> installDirTrnsFilePath;
1.517 + installDirTrnsFilePath.Append(*TServerResources::iDataDirectory);
1.518 + installDirTrnsFilePath.Append(KInstallDirTmpFile);
1.519 +
1.520 + // Create file store
1.521 + CDirectFileStore* store = CDirectFileStore::ReplaceLC(TServerResources::iFs, installDirTrnsFilePath,
1.522 + (EFileWrite | EFileShareExclusive));
1.523 + const TUid uid2 = KNullUid ;
1.524 + store->SetTypeL(TUidType(KDirectFileStoreLayoutUid, uid2, KServerUid3)) ;
1.525 +
1.526 + // Write the stream index/dictionary as root stream within the store
1.527 + // so we can access it when we do a restore later on
1.528 + RStoreWriteStream rootStream ;
1.529 + TStreamId rootStreamId = rootStream.CreateLC(*store) ;
1.530 +
1.531 + TUint32 count=iInstallEntryArray.Count();
1.532 + rootStream << count;
1.533 + for(TUint i=0; i<count;i++)
1.534 + {
1.535 + rootStream << *iInstallEntryArray[i];
1.536 + }
1.537 +
1.538 + rootStream.CommitL() ;
1.539 +
1.540 + CleanupStack::PopAndDestroy(&rootStream) ;
1.541 + store->SetRootL(rootStreamId);
1.542 + store->CommitL();
1.543 + CleanupStack::PopAndDestroy(store) ;
1.544 +
1.545 + TBuf<KMaxFileName> installDirFilePath;
1.546 + installDirFilePath.Append(*TServerResources::iDataDirectory);
1.547 + installDirFilePath.Append(KInstallDirFile);
1.548 +
1.549 + User::LeaveIfError(TServerResources::iFs.Replace(installDirTrnsFilePath, installDirFilePath));
1.550 + }
1.551 +
1.552 +
1.553 +void CInstallEntry::HandleFileDeleteL(TInt aOperation)
1.554 + {
1.555 + // File should only have been deleted if operation was uninstall
1.556 + // or in startup case
1.557 + if((aOperation!=ESASwisNone) && (aOperation!=ESASwisUninstall))
1.558 + User::Leave(KErrAbort);
1.559 +
1.560 + iRepository->HandleSWIDeleteL(Uid(), *iNotifier);
1.561 + }
1.562 +
1.563 +void CInstallEntry::HandleFileCreateL(TInt aOperation)
1.564 + {
1.565 + // File should only have been created if operation was install
1.566 + // or in startup case
1.567 + if((aOperation!=ESASwisNone) && (aOperation!=ESASwisInstall))
1.568 + User::Leave(KErrAbort);
1.569 +
1.570 + iRepository->HandleSWIUpdateL(Uid(), Modified(), *iNotifier);
1.571 + }
1.572 +
1.573 +void CInstallEntry::HandleFileUpdateL(TInt aOperation)
1.574 + {
1.575 + // File should only have been modified if operation was install
1.576 + // or in startup case
1.577 + if((aOperation!=ESASwisNone) && (aOperation!=ESASwisInstall))
1.578 + User::Leave(KErrAbort);
1.579 +
1.580 + iRepository->HandleSWIUpdateL(Uid(), Modified(), *iNotifier);
1.581 + }