/*

* 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:

*

*/

#include "harvesterlog.h"

#include "cclientkeywatcherao.h"

#include "crestorewatcher.h"

CClientKeyWatcherAO* CClientKeyWatcherAO::NewL( CRestoreWatcher* aRestoreWatcher )

	{

	WRITELOG("CClientKeyWatcherAO::NewL()");

	CClientKeyWatcherAO* self = new (ELeave) CClientKeyWatcherAO( aRestoreWatcher );

	CleanupStack::PushL( self );

	self->ConstructL();

	CleanupStack::Pop( self );

	return self;

	}

CClientKeyWatcherAO::~CClientKeyWatcherAO()

	{

	Cancel();

	iClientsProperty.Close();

	iRestoreWatcher = NULL;

	}

CClientKeyWatcherAO::CClientKeyWatcherAO( CRestoreWatcher* aRestoreWatcher ) :

		CActive( CActive::EPriorityUserInput )

	{

	CActiveScheduler::Add( this );

	iRestoreWatcher = aRestoreWatcher;

	}

void CClientKeyWatcherAO::ConstructL()

	{

	WRITELOG("CClientKeyWatcherAO::ConstructL()");

	User::LeaveIfError( iClientsProperty.Attach( KPSRestoreWatcherCategory, 

			KPSRestoreWatcherClientsKey, EOwnerThread ) );

	iClientsProperty.Subscribe( iStatus );

    SetActive();

    WRITELOG("CClientKeyWatcherAO::ConstructL() - ends");

	}

void CClientKeyWatcherAO::RunL()

	{

	WRITELOG("CClientKeyWatcherAO::RunL()");

	if( iStatus.Int() != KErrNone )

        {

#ifdef _DEBUG

        WRITELOG1("CClientKeyWatcherAO::RunL() - error: %d", iStatus.Int());

#endif

        return;

        }

	TInt clients = 0;

	iClientsProperty.Get( clients );

	if ( clients < iClients )

		{

		WRITELOG("CClientKeyWatcherAO::RunL() - unregistering");

		iRestoreWatcher->UnregisterL();

		}

	else if ( clients > iClients )

		{

		WRITELOG("CClientKeyWatcherAO::RunL() - registering");

		iRestoreWatcher->Register();

		}

	iClients = clients;

	iClientsProperty.Subscribe( iStatus );

	SetActive();

	}

void CClientKeyWatcherAO::DoCancel()

	{

	iClientsProperty.Cancel();

	}

TInt CClientKeyWatcherAO::RunError( TInt )

	{

	return KErrNone;

	}