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

	}