--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/syncmlfw/dm/dmnetworkmon/inc/DMNetworkMon.h	Thu Dec 17 09:07:52 2009 +0200
@@ -0,0 +1,281 @@
+/*
+* Copyright (c) 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:  SyncML DM NetMon 
+*
+*/
+
+#ifndef C_NETMON_H
+#define C_NETMON_H
+
+// INCLUDE FILES
+#include <e32base.h>
+#include <rconnmon.h>
+#include <SyncMLClient.h>
+#include <SyncMLClientDS.h>
+#include <SyncMLObservers.h>
+#include <e32property.h>
+#include <centralrepository.h>
+#include <DevManInternalCRKeys.h>
+
+// USER INCLUDES
+#include "nsmldebug.h"
+//#include "NsmlProfileUtil.h"
+
+// NetMon states
+enum TNetMonStates { ERegister = 0, 
+                     EMonitor, 
+                     ENetworkUp, 
+                     EDMJobOk,
+                     EInitSync,
+                     EComplete,
+                     ENetworkDown};
+
+/** 
+ * Monitors the network for availability and starts any pending 
+ * data sync sessions.
+ */
+class CDMNetworkMon : public CActive,
+                public MConnectionMonitorObserver,
+                public MSyncMLEventObserver,
+                public MSyncMLProgressObserver
+{
+    public:
+    
+		/**
+		 * Two phase construction
+		 */
+		static CDMNetworkMon* NewL();
+		
+		/**
+		 * Destructor
+		 */
+		~CDMNetworkMon();   
+
+    protected: 
+
+		// From base class CActive
+
+		/**
+		 * Implements cancellation of an outstanding request
+		 */
+		void DoCancel();
+
+		/**
+		 * Handles an active objects request completion event.
+		 */
+		void RunL();
+
+		/**
+		 * If the RunL function leaves, then the active scheduler call
+		 * RunError() to handle the leave.
+		 * @param aError - The error code
+		 */
+		TInt RunError ( TInt aError );
+	    
+    private:
+    
+		/**
+		 * Constructor
+		 */
+		CDMNetworkMon();
+		
+		/**
+		 * Second phase constructor
+		 */
+		void ConstructL();
+
+		/**
+		 * Resgiter for events
+		 */
+		void RegisterL();
+
+		/**
+		 * Trigger Device Management Session
+		 */
+		void StartDeviceManagementSessionL();
+
+		/** 
+		 * Close the server
+		 */
+		void Complete();
+
+		/**
+		 * Set active
+		 */
+		void IssueRequest();
+		
+		
+		
+	    /**
+		 * Cancels global auto restart timer
+		 */
+		void CancelGlobalTimer();
+		
+		/**
+		 * Checks if packet data is available using conmon
+		 */
+		TBool PacketDataAvailable();
+		
+		/**
+		 * Moves the state to NetworkUp2 since it is stable
+		 */
+		void NetworkStable();
+		
+		/**
+		 * Check if network is already up
+		 */
+		void StartOperationL();
+		
+	    /**
+		 * Check if network is really up. Callback method
+		 */
+		static TInt NetworkUp(TAny* arg);
+		
+		/**
+		 * Check if any other sync is in progress
+		 */
+		void OtherSyncStatus();
+				 
+		
+		/**
+		 * Global timeout for auto restart has expired.
+		 */
+		static TInt Timeout(TAny* arg);                		
+				
+		/**
+		 * Read the Global timeout from cenrep.
+		 */	
+		TInt ReadTimeoutFromCenrepL();
+		
+		/**
+		 * Create the Sync Job.
+		 */	
+		void CreateDeviceManagementSessionL();
+		
+		/**
+		 * From base class MConnectionMonitorObserver
+		 */
+        void EventL ( const CConnMonEventBase& aConnMonEvent );
+ 
+        /**
+         * From base class MSyncMLEventObserver
+         */
+        void OnSyncMLSessionEvent(TEvent aEvent, 
+                                  TInt aIdentifier, 
+                                  TInt aError, 
+                                  TInt aAdditionalData); 
+        
+        //from MSyncMLProgressObserver
+	    
+	    /**
+	    * Receives notification of a synchronisation error.
+        * @param aErrorLevel  The error level.
+	    * @param aError		  The type of error. This is one of the SyncMLError error values.	
+	    * @param aTaskId      The ID of the task for which the error occurred.
+	    * @param aInfo1       An integer that can contain additional information about the error. Normally 0.
+	    * @param aInfo2       An integer that can contain additional information about the error. Normally 0.
+	    * @return             None.
+	    */
+	    void OnSyncMLSyncError(TErrorLevel aErrorLevel, TInt aError, TInt aTaskId, TInt aInfo1, TInt aInfo2);
+       	
+       	/**
+	    * Receives notification of synchronisation progress.
+	    * @param aStatus	The current status, e.g. 'Connecting'.
+	    * @param aInfo1	An integer that can contain additional information about the progress.
+	    * @param aInfo2	An integer that can contain additional information about the progress.
+	    */
+	    void OnSyncMLSyncProgress(TStatus aStatus, TInt aInfo1, TInt aInfo2);
+	    
+	    /**
+	    * Receives notification of modifications to synchronisation tasks.
+        * @param aTaskId               The ID of the task.
+	    * @param aClientModifications  Modifications made on the clients Data Store.
+	    * @param aServerModifications  Modifications made on the server Data Store.
+	    */
+	    void OnSyncMLDataSyncModifications(TInt aTaskId, const TSyncMLDataSyncModifications& aClientModifications, const TSyncMLDataSyncModifications& aServerModifications);
+                          
+		                                  
+        /**
+         * Set/Reset the interrupt flag in the CenRep
+         */	
+		TBool IsRoamingDisabled();                                  	
+		void OpenSyncSessionL();
+		
+		void CloseSyncSession();
+		
+    private:
+
+		/**
+		 * Connection Monitor Server Instance
+		 */
+		RConnectionMonitor iConnectionMonitor;
+	   
+		/**
+		 * States
+		 */
+		TNetMonStates iState;
+
+		TNetMonStates iPrevState;
+		
+		/**
+		 * SyncML session
+		 */
+		RSyncMLSession iSyncSession;
+		
+		/**
+		 * Data sync job
+		 */
+		RSyncMLDataSyncJob iSyncJob;
+		
+		/**
+		 * Stability Timer
+		 */
+		CPeriodic* iStabilityTimer;
+		
+	    /**
+		 * Global Timer
+		 */
+		CPeriodic* iGlobalTimer;
+		
+		/**
+		 * Profile id to be used
+		 */
+		TSmlProfileId iLastUsedProfileId;	
+		
+		/**
+		 * Sync status P&S keys
+		 */	
+		RProperty iProperty;
+	
+		/**
+		 * Connection Id used for the Sync Session
+		 */
+		TConnMonBearerId iConMonBearerId;
+		/**
+		 * Global timeout from cenrep.
+		 */	
+		TInt iGlobalTimeout;
+		
+		/**
+		 * Timer count
+		 */	
+		TInt iTimerCount;
+
+		TBool iSyncSessionOpen;
+		
+		TInt iError;
+          TBool iCancelledNWEvent;
+};
+
+#endif // End of file