| const TLitC8 < sizeof("text, TDesC8 * ) { return ( TAny *) KErrNotSupported ; }inline void CAlwaysOnlineEComInterface::SetStatusQueryObject( MAlwaysOnlineStatusQueryInterface* aStatusQueryObject ) { iStatusQueryObject = aStatusQueryObject; }inline TUid CAlwaysOnlineEComInterface::InstanceUid() { return iDtor_ID_Key; }# 97 "X:/epoc32/include/platform/mw/AlwaysOnlineEComInterface.h" 2# 32 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManager.h" 2# 1 "X:/epoc32/include/platform/mw/AlwaysOnlineStatusQueryInterface.h" 1#define __ALWAYSONLINESTATUSQUERYINTERFACE_H__class MAlwaysOnlineStatusQueryInterface {public: virtual TAny * QueryStatusL( TInt aQuery ) = 0; };# 33 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManager.h" 2# 1 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManagerDiskSpaceObserver.h" 1#define ALWAYSONLINEDISKSPACEOBSERVER_Hclass CAlwaysOnlineManager;class CAlwaysOnlineDiskSpaceObserver : public CActive { public: static CAlwaysOnlineDiskSpaceObserver* NewL( CAlwaysOnlineManager* aManager, CMsvSession & aSession ); virtual ~CAlwaysOnlineDiskSpaceObserver(); public: void SetLimitAndActivateL(); private: CAlwaysOnlineDiskSpaceObserver( CAlwaysOnlineManager* aManager, CMsvSession & aSession ); private: void RunL(); void DoCancel(); virtual TInt RunError( TInt aError ); private: void HandleLimitChange(); private: CAlwaysOnlineManager* iWatcher; CAlwaysOnlineManager& iManager; CMsvSession & iSession; TUint iNewLimit; TUint iCurrentLimit; }; # 34 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManager.h" 2class CAlwaysOnlineManagerServer;class CAOCenRepControl;class CAlwaysOnlineManager : public CBase, public MAlwaysOnlineStatusQueryInterface, public MConnectionMonitorObserver, public MMsvSessionObserver, public MMsvSingleOpWatcher, public MCenRepNotifyHandlerCallback { public: static CAlwaysOnlineManager* NewL( CAlwaysOnlineManagerServer* aServer ); ~CAlwaysOnlineManager(); void DoStartL(); TAny* QueryStatusL( TInt aQuery ); void HandleOfflineEventL( TInt aEvent ); void EventL( const CConnMonEventBase &aConnMonEvent ); void HandleDiskSpaceEventL( TInt aEvent ); private: void HandleNotifyInt( TUint32 aId, TInt aNewValue ); void HandleNotifyError( TUint32 aId, TInt aError, CCenRepNotifyHandler* aHandler ); void HandleSessionEventL(TMsvSessionEvent aEvent, TAny* aArg1, TAny* , TAny* ); public: void BroadcastClientCommandL( TAlwaysOnlineServerAPICommands aCommand, TDes8& aParameter ); virtual void OpCompleted( CMsvSingleOpWatcher& aOpWatcher, TInt aCompletionCode ); private: CAlwaysOnlineManager(); void ConstructL( CAlwaysOnlineManagerServer* aServer ); void LoadPluginsL(); void StartPluginsL(); void CheckNetworkStatusAndSetObserverL(); void HandleRegistrationStatusL( TInt aStatus ); void BroadcastCommandDirectL( TManagerServerCommands aCommand, TDes8& aParameter ); void InvokeCommandHandlerL( const TManagerServerCommands aCommand, TDes8& aParameter, TInt aIndex ); void QuerySuicideL(); void HandleStartPluginL( const TDes8& aParameter ); void HandleStopPluginL( const TDes8& aParameter ); void StopPluginL( const TUid& aPlugin ); void DisablePlugin( const TUid& aPlugin ); void HandleOpCompletionL( const TDesC8& aProgress ); TBool ParseProgressL( const TDesC8& aProgress, TUid& aUid, TInt& aCommand, TDes8& aResult ); private: TBool iOffline; TInt iNetworkStatus; TBool iPluginsLoaded; CArrayFixFlat<CAlwaysOnlineEComInterface*>* iPluginArray; CArrayFixFlat<TUid>* iDisabledPluginUidsArray; CAlwaysOnlineManagerServer* iServer; CAlwaysOnlineDiskSpaceObserver* iDiskSpaceObserver; RFs iRfs; CMsvSession* iSession; CMsvSingleOpWatcherArray* iOperations; TInt iLastDiskEvent; RConnectionMonitor iConMon; CAOCenRepControl* iCenRepControl; };# 25 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/inc/AlwaysOnlineManagerServer.h" 2const TInt KAlwaysOnlineMajorVersionNumber = 1;const TInt KAlwaysOnlineMinorVersionNumber = 0;const TInt KAlwaysOnlineVersionNumber = 0;class TOAManagerStartupSignaller;const TUint KAOMServerRangeCount = 6;const TInt KAOMServerRanges[KAOMServerRangeCount] = { 0, 3, 1000, 2000, 3000, 4000, };const TUint8 KAOMServerElementsIndex[KAOMServerRangeCount] = { 0, CPolicyServer::ENotSupported, 0, 0, 0, CPolicyServer::ENotSupported, };const CPolicyServer::TPolicyElement KAOMServerElements[] = { {{ (TUint32)( (TUint8) (TUint8)TSecurityPolicy::ETypeC3 | (TUint8) ((TUint8)(int)( ( ECapabilityWriteDeviceData )==ECapability_None ? (__invalid_capability_value(*)[1])(ECapability_None) : (__invalid_capability_value(*)[((TUint)( ECapabilityWriteDeviceData +1)<=(TUint)ECapability_Limit)?1:2])( ECapabilityWriteDeviceData ) )) << 8 | (TUint8) ((TUint8)(int)( ( ECapability_None )==ECapability_None ? (__invalid_capability_value(*)[1])(ECapability_None) : (__invalid_capability_value(*)[((TUint)( ECapability_None +1)<=(TUint)ECapability_Limit)?1:2])( ECapability_None ) )) << 16 | (TUint8) ((TUint8)(int)( ( ECapability_None )==ECapability_None ? (__invalid_capability_value(*)[1])(ECapability_None) : (__invalid_capability_value(*)[((TUint)( ECapability_None +1)<=(TUint)ECapability_Limit)?1:2])( ECapability_None ) )) << 24 ), (TUint32)0xffffffff }, CPolicyServer::EFailClient} }; const CPolicyServer::TPolicy KAOMServerPolicy = { CPolicyServer::EAlwaysPass, KAOMServerRangeCount, KAOMServerRanges, KAOMServerElementsIndex, KAOMServerElements, };class CAlwaysOnlineManagerServer : public CPolicyServer {public: enum {EAlwaysOnlineManagerServerPriority=EPriorityBackground};public: static TInt RunServer(TOAManagerStartupSignaller& aSignaller); static void RunServerL(TOAManagerStartupSignaller& aSignaller); static TInt ServerThreadFunction(TAny* aParameters); static void PanicServer(TAlwaysOnlineManagerPanic aPanic); IMPORT_C static TInt ThreadFunction(TAny* aStarted); IMPORT_C static CAlwaysOnlineManagerServer* NewL(); void ConstructL(); ~CAlwaysOnlineManagerServer(); IMPORT_C void HandleClientCommandL( TAlwaysOnlineServerAPICommands aCommand, TDes8& aParameter ); virtual CSession2* NewSessionL( const TVersion& aVersion, const RMessage2& aMessage ) const;private: CAlwaysOnlineManagerServer( TInt aPriority ); private: CAlwaysOnlineManager* iManager; };# 19 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/src/AlwaysOnlineManagerServer.cpp" 2# 1 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManagerServerSession.h" 1#define __ALWAYSONLINEMANAGERSERVERSESSION_H__# 1 "X:/epoc32/include/mw/mtclreg.h" 1#define __MTCLREG_H__ class CObserverRegistry : public CMtmDllRegistry, public MMsvSessionObserver {public: IMPORT_C virtual void HandleSessionEventL(TMsvSessionEvent aEvent, TAny* aArg1, TAny* aArg2, TAny* aArg3); IMPORT_C ~CObserverRegistry();protected: IMPORT_C CObserverRegistry(CMsvSession& aMsvSession,TUid aDllTypeUid,TTimeIntervalMicroSeconds32 aTimeoutMicroSeconds32); IMPORT_C void ConstructL();protected: CMsvSession& iMsvSession; TBool iIsAdded; };class CClientMtmRegistry : public CObserverRegistry {public: IMPORT_C static CClientMtmRegistry* NewL(CMsvSession& aMsvSession, TTimeIntervalMicroSeconds32 aTimeoutMicroSeconds32=TTimeIntervalMicroSeconds32(30000000)); IMPORT_C ~CClientMtmRegistry(); IMPORT_C CBaseMtm* NewMtmL(TUid aMtmTypeUid); protected: CClientMtmRegistry(CMsvSession& aMsvSession,TTimeIntervalMicroSeconds32 aTimeoutMicroSeconds32); void ConstructL(); private: CBaseMtm* DoNewMtmL(const RLibrary& aLib, CRegisteredMtmDll& aReg) const; };# 24 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManagerServerSession.h" 2class CAlwaysOnlineManagerServer;class CAlwaysOnlineManagerServerSession : public CSession2 {public: static CAlwaysOnlineManagerServerSession* NewL( CAlwaysOnlineManagerServer * aServer ); CAlwaysOnlineManagerServerSession( ); void ConstructL( CAlwaysOnlineManagerServer* aServer ); virtual ~CAlwaysOnlineManagerServerSession(); virtual void ServiceL( const RMessage2 &aMessage ); void DispatchMessageL( const RMessage2 &aMessage ); void PanicClient( const RMessage2& aMessage, TInt aPanic ) const;private: CAlwaysOnlineManagerServer *iAOMServer; };# 20 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/src/AlwaysOnlineManagerServer.cpp" 2# 1 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManagerStartupSignaller.h" 1class TOAManagerStartupSignaller {public: inline TOAManagerStartupSignaller(); inline TOAManagerStartupSignaller(TRequestStatus& aStatus);public: inline TPtrC AsCommand() const; TInt GetCommand(); void SignalL();private: TThreadId iThreadId; TRequestStatus* iStatus; };inline TOAManagerStartupSignaller::TOAManagerStartupSignaller() { }inline TOAManagerStartupSignaller::TOAManagerStartupSignaller(TRequestStatus& aStatus): iThreadId(RThread().Id()), iStatus(&aStatus) { aStatus = KRequestPending; }inline TPtrC TOAManagerStartupSignaller::AsCommand() const { return TPtrC( reinterpret_cast<const TText*> this ), sizeof( TOAManagerStartupSignaller ) / sizeof( TText ) ); }# 21 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/src/AlwaysOnlineManagerServer.cpp" 2# 1 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/inc/AlwaysOnlineManagerLogging.h" 1#define __ALWAYSONLINEMANAGERLOGGING_H__#define KAOMANAGER_LOGGER_DEFINE#define KAOMANAGER_LOGGER_CREATE#define KAOMANAGER_LOGGER_DELETE#define KAOMANAGER_LOGGER_FN1(a) #define KAOMANAGER_LOGGER_FN2(a) #define KAOMANAGER_LOGGER_WRITE(a) #define KAOMANAGER_LOGGER_WRITE_FORMAT(a, b) #define KAOMANAGER_LOGGER_WRITE_FORMAT8(a, b) #define KAOMANAGER_LOGGER_WRITE_TEXT(a)#define KAOMANAGER_LOGGER_WRITE_NUMBER(a)#define KAOMANAGER_LOGGER_WRITE_FORMAT2(a, b)#define KAOMANAGER_LOGGER_WRITE_BUFFER(a) # 22 "X:/sf/mw/messagingmw/messagingfw/alwaysonline/AlwaysOnlineManager/src/AlwaysOnlineManagerServer.cpp" 2CAlwaysOnlineManagerServer::CAlwaysOnlineManagerServer( TInt aPriority ) : CPolicyServer( aPriority, KAOMServerPolicy ) { ; ; } EXPORT_C CAlwaysOnlineManagerServer* CAlwaysOnlineManagerServer::NewL() { ; CAlwaysOnlineManagerServer* self = new (ELeave) CAlwaysOnlineManagerServer( EAlwaysOnlineManagerServerPriority ); CleanupStack::PushL( self ); self->ConstructL(); CleanupStack::Pop( self ); self->StartL( KAlwaysOnlineManagerServerName ); ; return self; }void CAlwaysOnlineManagerServer::ConstructL() { ; iManager = 0 ; TInt err ;{TTrap __t;if (__t.Trap( err )==0){ iManager = CAlwaysOnlineManager::NewL(this) ;TTrap::UnTrap();}}; if( err==KErrNone ) { TInt err2 ;{TTrap __t;if (__t.Trap( err2 )==0){ iManager->DoStartL() ;TTrap::UnTrap();}}; if(err2!=KErrNone) { ; PanicServer( EAOMServerStartFail ); } } else { ; PanicServer( EAOMServerStartFail ); } ; }CAlwaysOnlineManagerServer::~CAlwaysOnlineManagerServer() { ; delete iManager; ; } EXPORT_C void CAlwaysOnlineManagerServer::HandleClientCommandL( TAlwaysOnlineServerAPICommands aCommand, TDes8& aParameter ) { iManager-> | BroadcastClientCommandL | [static] |
Copyright ©2010 Nokia Corporation and/or its subsidiary(-ies).
All rights
reserved. Unless otherwise stated, these materials are provided under the terms of the Eclipse Public License
v1.0.