sl@0: // Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0:  
sl@0: #ifndef OBSRVR_H
sl@0: #define OBSRVR_H
sl@0: 
sl@0: #include <e32base.h>
sl@0: 
sl@0: class CSharedRepository;
sl@0: class CServerRepository;
sl@0: class CRepositoryTransactor;
sl@0: 
sl@0: #include "inifile.h"
sl@0: 
sl@0: #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS
sl@0: class CHeapRepository;
sl@0: /**
sl@0: This simple T class is used to store information regarding
sl@0: the keyspace entry in the rofs list with respect to the
sl@0: extension used and the mount id order
sl@0: */
sl@0: class TRofsFlag
sl@0: {
sl@0: public:
sl@0: 	TRofsFlag(const TDesC& aExt,TUint8 aMountId):iFlag(aMountId)
sl@0: 		{
sl@0: 		if (aExt.Compare(_L("txt"))==0)
sl@0: 			{
sl@0: 			iFlag |=0x80000000;
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: 	static TInt CompareFlag(const TRofsFlag& aFlag1, const TRofsFlag& aFlag2)
sl@0: 		{
sl@0: 		return (aFlag1.iFlag & 0xFF)-(aFlag2.iFlag & 0xFF);
sl@0: 		}
sl@0: 
sl@0: public:
sl@0: 	//the 16 bit flag in format of |8bit cre/txt flag|8bit mount_id|
sl@0: 	//obviously this is assuming the format of the mangled file
sl@0: 	//granulatiry currently set to default of 8 which is reasonable
sl@0: 	//MSB=1 indicates this is txt
sl@0: 	TUint32 iFlag;	
sl@0: };
sl@0: 
sl@0: /**
sl@0: This class is used to store information about potentially multiple
sl@0: files(in diffeernt rofs) used for a centrep keyspace
sl@0: */
sl@0: class TMultiRofsList
sl@0: 	{
sl@0: public:
sl@0: 	TMultiRofsList(TUid aUid):iRepUid(aUid){}
sl@0: 	
sl@0: public:
sl@0: 	//repository uid
sl@0: 	TUid iRepUid;
sl@0: 	//list of the mount ids together with the extension(cre/txt)
sl@0: 	RArray<TRofsFlag> iMountFlagList;		
sl@0: 	};
sl@0: #endif	
sl@0: 
sl@0: class MObserver
sl@0: 	{
sl@0: public:
sl@0: 	virtual void Notify(TUint32 aId) = 0;
sl@0: 	};
sl@0: 
sl@0: class CObservable : public CBase
sl@0: 	{
sl@0: public:
sl@0: 	static CObservable* NewLC();
sl@0: 	
sl@0: 	~CObservable();
sl@0: 
sl@0: 	void AddObserverL(TUid aUid, CServerRepository* aRepositoryPointer);
sl@0: 	void RemoveObserver(TUid aUid, CServerRepository* aRepositoryPointer, TInt aInMemoryIndex);
sl@0: 
sl@0: 	void Notify(TUid aUid, TUint32 aVal) const;
sl@0: 	
sl@0: 	void ReleaseTransactionLock(CRepositoryTransactor& aTransactor,TUid aRepositoryUid);
sl@0: 	void CancelTransaction(CRepositoryTransactor& aTransactor,TUid aRepositoryUid);	
sl@0: 	TInt FindOpenRepository(TUid aUid) const;
sl@0: 	void RemoveOpenRepository(CSharedRepository* aRepository);
sl@0: 	
sl@0: 	inline CSharedRepository*& GetOpenRepository(TInt aIndex) 
sl@0: 		{
sl@0: 		ASSERT((aIndex>=0)&&(aIndex<iOpenRepositories.Count()));
sl@0: 		return iOpenRepositories[aIndex];
sl@0: 		}
sl@0: 	inline void AddOpenRepositoryL(CSharedRepository* aRepository)
sl@0: 		{
sl@0: 		iOpenRepositories.AppendL(aRepository);
sl@0: 		}
sl@0: 	
sl@0: 	TInt FindConnectedRepository(TUid aUid) const;
sl@0: 			
sl@0: #ifdef CACHE_OOM_TESTABILITY
sl@0: 	void CloseiOpenRepositories();
sl@0: 	void CloseiRepositoryInfo();
sl@0: 	void Reset();
sl@0: 	TBool iTrapOOMOnOpen;
sl@0: #endif	
sl@0: 	
sl@0: 	CSharedRepository* AccessL(TUid aUid, TBool aFailIfNotFound = ETrue);
sl@0: 	void LoadRepositoryLC(TUid aUid, TBool aFailIfNotFound, CSharedRepository*& aRepository, CIniFileIn::TIniFileOpenMode aIniFileOpenMode);
sl@0: 
sl@0: 	/**
sl@0: 	@internalTechnology
sl@0: 	This is the class/structure which keeps shared non-persisted repository data 
sl@0: 	*/
sl@0: 	class TSharedRepositoryInfo
sl@0: 		{
sl@0: 	public:
sl@0: 		TSharedRepositoryInfo(TUid aUid);
sl@0: 		TUid iRepositoryUid;
sl@0: 		// all transactors in the order added
sl@0: 		TSglQue<CRepositoryTransactor> iTransactors;
sl@0: 		// combined read/write lock for pessimistic transactions.
sl@0: 		// -1 if in EReadWriteTransaction, otherwise non-negative number of EReadTransactions.
sl@0: 		TInt iPessimisticTransactionLockCount;
sl@0: 		// count of active concurrent read/write transactions:
sl@0: 		TInt iNumActiveConcurrentReadWriteTransactions;
sl@0: 		
sl@0: 
sl@0: 		};
sl@0: 
sl@0: 	TSharedRepositoryInfo* SharedRepositoryInfo(TUid aUid);		
sl@0: 	void AddSharedRepositoryInfoL(TUid aUid);
sl@0: 	void RemoveSharedRepositoryInfo(TUid aUid);
sl@0: 	TInt CreateRepositoryL(CSharedRepository* aRepository, TCentRepLocation aLocation);
sl@0: #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS	
sl@0: 	void ProcessMultiRofsListL(const CDir& aList);	
sl@0: 	static TInt CompareUid(const TMultiRofsList& aUid1, const TMultiRofsList& aUid2);		
sl@0: 	RArray<TMultiRofsList>& GetMultiRofsList()
sl@0: 		{
sl@0: 		return iMultiRofsUidList;	
sl@0: 		}
sl@0: #endif		
sl@0: 	
sl@0: 	/**
sl@0: 	@internalTechnology
sl@0: 	This is the class/structure which keeps notification-related data 
sl@0: 	*/
sl@0: 	class TRepositoryObserverInfo
sl@0: 		{
sl@0: 	public:
sl@0: 		TUid iRepositoryUid;
sl@0: 		CServerRepository* iRepositoryPointer; 
sl@0: 		};
sl@0: 	RArray<TRepositoryObserverInfo> iObservers;		
sl@0: private:
sl@0: 	static TInt ObserverSortOrder(const TRepositoryObserverInfo &aRepository1, const TRepositoryObserverInfo &aRepository2);
sl@0: 	static TInt InfoSortOrder(const TSharedRepositoryInfo &aRepository1, const TSharedRepositoryInfo &aRepository2);
sl@0: 	static TInt CompareTUidValues(TInt aUid1, TInt aUid2);
sl@0: 	
sl@0: 	TInt ReadIniFileL(CSharedRepository*& aRepository,TCentRepLocation aLocation);
sl@0: 	TInt CreateRepositoryL(CSharedRepository*& aRepository, CIniFileIn::TIniFileOpenMode aIniFileOpenMode);
sl@0: 	TInt ReadSettingsL(CIniFileIn* aIniFileIn, CSharedRepository* aRep);
sl@0: 
sl@0: 	TInt FindRepositoryInfo(TUid aUid);
sl@0: 	void RefreshTransactorAccessPolicies(CSharedRepository* aRepository, const TInt offset);
sl@0: #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS	
sl@0: 	//Multi ROFS stuff
sl@0: 	void ConstructL();
sl@0: 	void OverrideSettingL(TServerSetting& aBaseSetting,const TServerSetting& aOvSetting,CSharedRepository* aCoreRepository,TBool aNewOv,TBool aNewOvIndivPolicy);	
sl@0: 	void MergeRepositoryL(CSharedRepository* aCoreRepository,CHeapRepository* aOverrideRepository);
sl@0: 	void MergeMultiRofsL(TBool aCoreInitialized,CSharedRepository* aCoreRepository,const RArray<TRofsFlag>& aOverridingFileList);
sl@0: #endif
sl@0: 	
sl@0: private:
sl@0: 	enum {KGranularity=8};	
sl@0: 	RPointerArray<CSharedRepository> iOpenRepositories;	
sl@0: 	RPointerArray<TSharedRepositoryInfo> iRepositoryInfo;
sl@0: #ifdef SYMBIAN_CENTREP_SUPPORT_MULTIROFS	
sl@0: 	RArray<TMultiRofsList> iMultiRofsUidList;
sl@0: #endif		
sl@0: 	};
sl@0: 
sl@0: #endif // OBSRVR_H