// Copyright (c) 2002-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 "LogClientObserver.h"

// System includes

#include <s32mem.h>

// User includes

#include <logwrap.h>

#include <logcli.h>

#include "logservcli.h"

#include <logclientchangeobserver.h>

/////////////////////////////////////////////////////////////////////////////////////////

// -----> CLogClientObserver (source)

/////////////////////////////////////////////////////////////////////////////////////////

CLogClientObserver::CLogClientObserver(CLogClient& aClient, MLogClientChangeObserver& aObserver, TInt aPriority)

:	CActive(aPriority), iClient(aClient), iObserver(aObserver)

	{

	CActiveScheduler::Add(this);

	}

CLogClientObserver::~CLogClientObserver()

	{

	Cancel();

	}

CLogClientObserver* CLogClientObserver::NewL(CLogClient& aClient, MLogClientChangeObserver& aObserver, TInt aPriority)

	{

	CLogClientObserver* self = new(ELeave) CLogClientObserver(aClient, aObserver, aPriority);

	self->RequestChanges();

	return self;

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogClientObserver::RunL()

	{

	if	(iStatus.Int() == KErrNone)

		NotifyObserverL();

	RequestChanges();

	}

void CLogClientObserver::DoCancel()

	{

	RequestChangesCancel();

	}

TInt CLogClientObserver::RunError(TInt /*aError*/)

	{

	// Ignore any leave when notifying the client

	return KErrNone;

	}

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

/////////////////////////////////////////////////////////////////////////////////////////

void CLogClientObserver::RequestChanges()

	{

	__ASSERT_DEBUG(!IsActive(), User::Invariant());

	iClient.Session().Send(ELogNotifyExtended, TIpcArgs(&iContextBuf,&iParamBuf1,&iParamBuf2,&iParamBuf3), iStatus);

	SetActive();

	}

void CLogClientObserver::RequestChangesCancel()

	{

	iClient.Session().Send(ELogNotifyExtendedCancel, TIpcArgs());

	}

void CLogClientObserver::NotifyObserverL()

	{

	const TUid contextUid = { iContextBuf() };

	const TInt param1 = iParamBuf1();

	const TInt param2 = iParamBuf2();

	const TInt param3 = iParamBuf3();

	//

	iObserver.HandleLogClientChangeEventL(contextUid, param1, param2, param3);

	}