--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/sysstatemgmt/systemstatemgr/cmn/src/ssmstatemonitor.cpp	Tue Feb 02 00:53:00 2010 +0200
@@ -0,0 +1,112 @@
+// Copyright (c) 2007-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 <ssm/ssmstateawaresession.h>
+#include "ssmstatemonitor.h"
+#include "cmnpanic.h"
+#include "ssmdebug.h"
+
+/**
+
+ */
+CSsmStateMonitor* CSsmStateMonitor::NewL(CSsmStateAwareSession& aObserver, TDmDomainId aId)
+	{
+	CSsmStateMonitor* self = new (ELeave) CSsmStateMonitor(aObserver);
+	CleanupStack::PushL(self);
+	self->ConstructL(aId);
+	CleanupStack::Pop(self);
+	return self;
+	}
+
+/**
+
+ */
+CSsmStateMonitor::CSsmStateMonitor(CSsmStateAwareSession& aObserver) : 
+	CActive(CActive::EPriorityStandard),
+	iObserver(aObserver)
+	{
+	CActiveScheduler::Add(this);
+	}
+
+/**
+
+ */
+CSsmStateMonitor::~CSsmStateMonitor()
+	{
+	Cancel();
+	iSas.Close();
+	}
+
+/**
+
+ */
+void CSsmStateMonitor::ConstructL(TDmDomainId aId)
+	{
+	SSMLOGLEAVEIFERROR(iSas.Connect(aId)); //will leave in release builds as well
+	
+	//Setup change subscription
+	iStatus = KRequestPending;
+	iSas.RequestStateNotification(iStatus);
+	SetActive();
+	
+	//Read current state and store locally
+	iState = iSas.State();
+	}
+
+/**
+
+ */
+void CSsmStateMonitor::DoCancel()
+	{
+	iSas.RequestStateNotificationCancel();
+	}
+
+/**
+
+ */
+void CSsmStateMonitor::RunL()
+	{
+	SSMLOGLEAVEIFERROR(iStatus.Int());
+	
+	//Re-issue a subscription request before retrieving the current value
+	iStatus = KRequestPending;
+	iSas.AcknowledgeAndRequestStateNotification(KErrNone, iStatus);
+	SetActive();
+	
+	//Update local copy
+	iState = iSas.State();
+	
+	//Notify our clients
+	iObserver.NotifySubscribers(iState);			
+	}
+
+/**
+@panic ECmnStateMonError1 if an error occurs in RunL
+ */
+TInt CSsmStateMonitor::RunError(TInt aError)
+	{
+	iSas.AcknowledgeStateNotification(aError);
+	DEBUGPRINT2A("CSsmStateMonitor::RunError: %d", aError);
+	User::Panic(KPanicSsmCmn, ECmnStateMonError1); //A panic here is easier to track than a panic in CActiveScheduler
+	return aError;  //lint !e527 Unreachable
+	}
+
+/**
+
+ */
+TSsmState CSsmStateMonitor::State() const
+	{
+	return iState;
+	}