sl@0: // Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include "LogClientObserver.h"
sl@0: 
sl@0: // System includes
sl@0: #include <s32mem.h>
sl@0: 
sl@0: // User includes
sl@0: #include <logwrap.h>
sl@0: #include <logcli.h>
sl@0: #include "logservcli.h"
sl@0: #include <logclientchangeobserver.h>
sl@0: 
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: // -----> CLogClientObserver (source)
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: CLogClientObserver::CLogClientObserver(CLogClient& aClient, MLogClientChangeObserver& aObserver, TInt aPriority)
sl@0: :	CActive(aPriority), iClient(aClient), iObserver(aObserver)
sl@0: 	{
sl@0: 	CActiveScheduler::Add(this);
sl@0: 	}
sl@0: 
sl@0: CLogClientObserver::~CLogClientObserver()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: CLogClientObserver* CLogClientObserver::NewL(CLogClient& aClient, MLogClientChangeObserver& aObserver, TInt aPriority)
sl@0: 	{
sl@0: 	CLogClientObserver* self = new(ELeave) CLogClientObserver(aClient, aObserver, aPriority);
sl@0: 	self->RequestChanges();
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void CLogClientObserver::RunL()
sl@0: 	{
sl@0: 	if	(iStatus.Int() == KErrNone)
sl@0: 		NotifyObserverL();
sl@0: 	RequestChanges();
sl@0: 	}
sl@0: 
sl@0: void CLogClientObserver::DoCancel()
sl@0: 	{
sl@0: 	RequestChangesCancel();
sl@0: 	}
sl@0: 
sl@0: TInt CLogClientObserver::RunError(TInt /*aError*/)
sl@0: 	{
sl@0: 	// Ignore any leave when notifying the client
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void CLogClientObserver::RequestChanges()
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(!IsActive(), User::Invariant());
sl@0: 	iClient.Session().Send(ELogNotifyExtended, TIpcArgs(&iContextBuf,&iParamBuf1,&iParamBuf2,&iParamBuf3), iStatus);
sl@0: 	SetActive();
sl@0: 	}
sl@0: 
sl@0: void CLogClientObserver::RequestChangesCancel()
sl@0: 	{
sl@0: 	iClient.Session().Send(ELogNotifyExtendedCancel, TIpcArgs());
sl@0: 	}
sl@0: 
sl@0: void CLogClientObserver::NotifyObserverL()
sl@0: 	{
sl@0: 	const TUid contextUid = { iContextBuf() };
sl@0: 	const TInt param1 = iParamBuf1();
sl@0: 	const TInt param2 = iParamBuf2();
sl@0: 	const TInt param3 = iParamBuf3();
sl@0: 	//
sl@0: 	iObserver.HandleLogClientChangeEventL(contextUid, param1, param2, param3);
sl@0: 	}