// 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;
	}