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

	}