// 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 "LogViewObserver.h"

 // System includes

 #include <s32mem.h>

 // User includes

 #include <logwrap.h>

 #include <logcli.h>

 #include "logclipanic.h"

 #include "logservcli.h"

 #include "LogChangeDefinition.h"

 #include "LogViewChangeObserverInternal.h"

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

 // -----> CLogViewObserver (source)

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

 CLogViewObserver::CLogViewObserver(CLogView& aView, CLogClient& aClient, MLogViewChangeObserverInternal& aObserver, TLogViewId aViewId, TInt aPriority)

 :	CActive(aPriority), iClient(aClient), iObserver(aObserver), iViewId(aViewId), iView(aView)

 	{

 	CActiveScheduler::Add(this);

 	}

 CLogViewObserver::~CLogViewObserver()

 	{

 	Cancel();

 	//

 	delete iChanges;

 	}

 void CLogViewObserver::ConstructL()

 	{

 	iChanges = CLogChangeDefinition::NewL();

 	RequestChanges();

 	}

 CLogViewObserver* CLogViewObserver::NewL(CLogView& aView, CLogClient& aClient, MLogViewChangeObserverInternal& aObserver, TLogViewId aViewId, TInt aPriority)

 	{

 	CLogViewObserver* self = new(ELeave) CLogViewObserver(aView, aClient, aObserver, aViewId, aPriority);

 	CleanupStack::PushL(self);

 	self->ConstructL();

 	CleanupStack::Pop(self);

 	return self;

 	}

 void CLogViewObserver::RequestChanges()

 	{

 	iClient.Session().Send(ELogViewChangeNotificationsRequest, TIpcArgs(iViewId), iStatus);

 	SetActive();

 	}

 void CLogViewObserver::RunL()

 	{

 	const TInt error = iStatus.Int();

 	if (error == KErrServerTerminated)

 		{

 		// Effectively does a "delete this"

 		iView.NotifyLogServerTerminatedL();

 		}

 	else if (error < KErrNone)

 		{

 		// Don't request any further changes.

 		}

 	else

 		{

 		const TInt changesSize = iStatus.Int();

 		User::LeaveIfError(changesSize);

 		FetchChangesL(changesSize);

 		RequestChanges();

 		NotifyObserverL();

 		}

 	}

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

 	{

 	// This point can be reached when RequestChanges has already been 

 	// called, for example when an observer leaves when it is notified of 

 	// a change.

 	// Check IsActive() before calling RequestChanges to avoid calling it 

 	// twice in a row and causing a E32USER-CBase:42 panic.

 	if (!IsActive())

 		{

 		RequestChanges();	

 		}

 	return KErrNone;

 	}

 void CLogViewObserver::DoCancel()

 	{

 	RequestChangesCancel();

 	}

 void CLogViewObserver::RequestChangesCancel()

 	{

 	iClient.Session().Send(ELogViewChangeNotificationsCancel, TIpcArgs(iViewId));

 	}

 void CLogViewObserver::FetchChangesL(TInt aBufferSizeRequired)

 	{

 	HBufC8* buffer = HBufC8::NewLC(aBufferSizeRequired);

 	TPtr8 pBuffer(buffer->Des());

 	//

 	User::LeaveIfError(iClient.Session().Send(ELogViewFetchChanges, TIpcArgs(iViewId,aBufferSizeRequired,&pBuffer)));

 	//

 	iChanges->Reset();

 	RDesReadStream stream(*buffer);

 	stream >> *iChanges;

 	CleanupStack::PopAndDestroy(buffer);

 	}

 void CLogViewObserver::NotifyObserverL()

 	{

 	TLogId id;

 	TInt viewIndex;

 	// Copy the changes

 	const TInt count = iChanges->Count();

 	if	(!count)

 		return;

 	//

 	CLogChangeDefinition* changes = CLogChangeDefinition::NewL(*iChanges);

 	CleanupStack::PushL(changes);

 	iChanges->Reset();

 	//

 	for(TInt i=0; i<count; i++)

 		{

 		const TLogDatabaseChangeType type = changes->At(i, id, viewIndex);

 		//

 		switch(type)

 			{

 		case ELogChangeTypeEventAdded:

 			iObserver.HandleLogViewChangeEventAddedL(id, viewIndex, i, count);

 			break;

 		case ELogChangeTypeEventChanged:

 			iObserver.HandleLogViewChangeEventChangedL(id, viewIndex, i, count);

 			break;

 		case ELogChangeTypeEventDeleted:

 			iObserver.HandleLogViewChangeEventDeletedL(id, viewIndex, i, count);

 			break;

 		case ELogChangeTypeLogCleared:

 			iObserver.HandleLogViewChangeEventLogClearedL();

 			break;

 		default:

 		case ELogChangeTypeUndefined:

 			__ASSERT_DEBUG(EFalse, Panic(ELogUnexpectedChangeType));

 			}

 		}

 	CleanupStack::PopAndDestroy(changes);

 	}