// Copyright (c) 1998-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:
//
#include "UF_STD.H"
#include <e32math.h>
const TUid KUidDictionaryFile={0x100000E4};
_LIT(KSystemIniFileLocationSpec,"Z:\\System\\System.ini");
const TUid KSystemIniFileUid = {0x1000010C};
// Thread contention resolution constants
const TInt KSpinCount=40;
const TInt KLockoutLimit=0xc0000; // to keep the lock-out time down to ~1sec (this is microseconds)
const TInt KFailTime=0x1000; // ~ time to fail to open file
const TInt KSpinLimit=KLockoutLimit-KSpinCount*KFailTime;
LOCAL_C TUint8 const WaitDistribution[8]={0,0,0,0,0x1f,0x3f,0x7f,0xff}; // wait-time distribution mask
class RYieldThread : public RThread
{
public:
inline void Yield() const {SetPriority(Priority());}
};
/////////////////////////////////////////////
// CDictionaryFileStore
/////////////////////////////////////////////
LOCAL_C void EnsurePathL(RFs& aFs,const TDesC& aName)
{
TInt r=aFs.MkDirAll(TParsePtrC(aName).DriveAndPath());
if (r!=KErrAlreadyExists)
User::LeaveIfError(r);
}
EXPORT_C CDictionaryFileStore* CDictionaryFileStore::SystemL(RFs& aFs)
/** Opens the system dictionary file store.
@param aFs Handle to a file server session.
@return A pointer to the system file based dictionary store object. */
{
CDictionaryFileStore* store=SystemLC(aFs);
CleanupStack::Pop();
return store;
}
EXPORT_C CDictionaryFileStore* CDictionaryFileStore::SystemLC(RFs& aFs)
/** Opens the system dictionary file store and puts the pointer to the file store
object onto the cleanup stack.
@param aFs Handle to a file server session.
@return A pointer to the system file based dictionary store object. */
{
TDriveUnit drive(static_cast<TUint>(RFs::GetSystemDrive()));
TParse parse;
User::LeaveIfError(parse.Set(drive.Name(), &KSystemIniFileLocationSpec, NULL));
EnsurePathL(aFs, parse.FullName());
return OpenLC(aFs, parse.FullName(), KSystemIniFileUid);
}
EXPORT_C CDictionaryFileStore* CDictionaryFileStore::OpenL(RFs& aFs,const TDesC& aName,TUid aFileId)
/** Creates a file based dictionary store object.
If the file with the specified full path name exists, then an attempt is made
to open an existing file store contained within this file. Any existing file
store must satisfy the following conditions:
it must be a valid dictionary store
the third UID component of the file store type must match the specified UID;
this UID serves to differentiate between dictionary stores
otherwise the function leaves with KErrCorrupt.
If the file with the specified full path name does not exist, then an attempt
is made to create a new file and to create a file based dictionary within
it. The third UID component of the file store type is set to the specified
UID value.
Note that the file is opened in exclusive access mode.
@param aFs Handle to a file server session.
@param aName The full path name of the file.
@param aUid3 The UID used to differentiate between dictionary stores.
@return A pointer to the file based dictionary store object.
@see TUid
@see TUidType */
{
CDictionaryFileStore* self = CDictionaryFileStore::OpenLC(aFs,aName,aFileId);
CleanupStack::Pop();
return self;
}
EXPORT_C CDictionaryFileStore* CDictionaryFileStore::OpenLC(RFs& aFs,const TDesC& aName,TUid aFileId)
/** Creates a file based dictionary store object and puts the pointer onto the
cleanup stack.
If the file with the specified full path name exists, then an attempt is made
to open an existing file store contained within this file. Any existing file
store must satisfy the following conditions:
it must be a valid dictionary store
the third UID component of the file store type must match the specified UID;
this UID serves to differentiate between dictionary stores
otherwise the function leaves with KErrCorrupt.
If the file with the specified full path name does not exist, then an attempt
is made to create a new file and to create a file based dictionary within
it. The third UID component of the file store type is set to the specified
UID value.
Note that the file is opened in exclusive access mode.
@param aFs Handle to a file server session.
@param aName The full path name of the file.
@param aUid3 The UID used to differentiate between dictionary stores.
@return A pointer to the file based dictionary store object.
@see TUid
@see TUidType */
{
CDictionaryFileStore* self = new(ELeave) CDictionaryFileStore();
CleanupStack::PushL(self);
self->ConstructL(aFs,aName,aFileId);
return self;
}
void CDictionaryFileStore::ConstructL(RFs& aFs,const TDesC& aName,TUid aFileId)
//
// try to open the file - if this fails KErrNotFound try to create it
// if the file is in use retry after a pause
//
{
RYieldThread thread;
TInt64 seed;
const TUidType type(KPermanentFileStoreLayoutUid,KUidDictionaryFile,aFileId);
for (TInt wait=KLockoutLimit;;)
{
RFile file;
// When the file server write caching is enabled, the order of file write operations is not guaranteed.
// This could cause data inconsistency in some circumstances,for example, when the power is lost in the
// middle of a database transaction.Therefore, the file write caching is disabled for this file to maintain integrity.
TInt r=file.Open(aFs,aName,EFileShareExclusive|EFileWrite|EFileWriteDirectIO);
switch (r)
{
case KErrNone:
{
TInt size;
if (file.Size(size)==KErrNone && size!=0)
{
CFileStore* store=NULL;
TRAP(r,store=CPermanentFileStore::FromL(file));
if (r==KErrNotSupported||r==KErrEof)
r=KErrCorrupt; // treat a bad store file as corrupt
else if (r==KErrNone && store->Type()!=type)
{
// treat a wrong 3rd UID as corrupt
delete store;
store = NULL;
r=KErrCorrupt;
}
if (r==KErrCorrupt)
{
// silently replace the entire file if it is corrupt
// When the file server write caching is enabled, the order of file write operations is not guaranteed.
// This could cause data inconsistency in some circumstances,for example, when the power is lost in the
// middle of a database transaction.Therefore, the file write caching is disabled for this file to maintain integrity.
r=file.Replace(aFs,aName,EFileShareExclusive|EFileWrite|EFileWriteDirectIO);
if (r==KErrInUse)
break; // try again later...
if (r==KErrNone)
{
CreateStoreL(file,type);
return;
}
}
__LEAVE_IF_ERROR(r);
__ASSERT_DEBUG(store != NULL, User::Invariant());
//coverity[use_after_free]
iStore = store;
if (store->Root()==KNullStreamId)
CDictionaryStore::ConstructL();
}
else
CreateStoreL(file,type);
return;
}
case KErrNotFound:
// When the file server write caching is enabled, the order of file write operations is not guaranteed.
// This could cause data inconsistency in some circumstances,for example, when the power is lost in the
// middle of a database transaction.Therefore, the file write caching is disabled for this file to maintain integrity.
r=file.Create(aFs,aName,EFileShareExclusive|EFileWrite|EFileWriteDirectIO);
if (r==KErrNone)
{
CreateStoreL(file,type);
return;
}
else if (r==KErrAlreadyExists)
; // try and open after delay
else
__LEAVE(r);
break;
case KErrInUse:
break;
default:
__LEAVE(r);
}
wait-=KFailTime;
if (wait<=0)
break; // waited too long
if (wait>KSpinLimit)
{ // straight back to retry
thread.Yield(); // force another reschedule
continue;
}
// random wait time...
if (wait==KSpinLimit)
{ // initialise random number generator
TThreadId id=thread.Id();
TUint idVal=*(const TUint*)&id;
seed = MAKE_TINT64(idVal^TUint(this),idVal^TUint(&id));
Math::Rand(seed);
Math::Rand(seed);
}
TInt pause=Math::Rand(seed)>>11;
pause=(pause&WaitDistribution[(pause>>8)&0x7])<<10;
if (pause)
{
wait-=pause;
User::After(pause);
}
}
__LEAVE(KErrInUse);
}
void CDictionaryFileStore::CreateStoreL(RFile& aFile,const TUidType& aType)
{
CFileStore* store = CPermanentFileStore::NewL(aFile);
iStore = store;
store->SetTypeL(aType);
CDictionaryStore::ConstructL();
}