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

#include <s32mem.h>

#include "LOGGET.H"

#include "logservpanic.h"

#include "LogServView.h"

// Constants

const TInt KLogViewWindowTransferBufferGranularity = 500;

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

// -----> CLogServViewWindowFetcher (source)

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

CLogServViewWindowFetcher::CLogServViewWindowFetcher(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

:	CLogActive(aPriority), iDatabase(aDatabase)

	{

	}

CLogServViewWindowFetcher::~CLogServViewWindowFetcher()

	{

	Cancel();

	delete iBuffer;

	delete iGetEvent;

	delete iEvent;

	}

void CLogServViewWindowFetcher::ConstructL()

	{

	iBuffer = CBufFlat::NewL(KLogViewWindowTransferBufferGranularity);

	iEvent = CLogEvent::NewL();

	iGetEvent = CLogGetEvent::NewL(iDatabase, Priority());

	}

CLogServViewWindowFetcher* CLogServViewWindowFetcher::NewL(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

	{

	CLogServViewWindowFetcher* self = new(ELeave) CLogServViewWindowFetcher(aDatabase, aPriority);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

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

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

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

void CLogServViewWindowFetcher::StartL(TRequestStatus& aStatus, const CLogServViewBase& aView, const TLogTransferWindow& aWindow, const RMessage2& aMessage)

	{

	__ASSERT_ALWAYS(iState == EStateIdle, Panic(ELogViewWindowFetcherBadState));

	//

	Queue(aStatus);

	//

	iView = &aView;

	iWindow = aWindow;

	iMessage = &aMessage;

	iBuffer->Reset();

	iWindowIndex = 0;

	iState = EStateStarting;

	//

	CompleteRequest();

	}

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

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

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

void CLogServViewWindowFetcher::DoRunL()

	{

	const TInt error = iStatus.Int();

	User::LeaveIfError(error);

	switch(iState)

		{

	case EStateStarting:

		GetNextEventL(iWindowIndex);

		iState = EStateContinuing;

		break;

	case EStateContinuing:

		ProcessEventL();

		break;

	default:

		__ASSERT_ALWAYS(0, Panic(ELogViewWindowFetcherBadState2));

		break;

		}

	}

void CLogServViewWindowFetcher::ProcessEventL()

	{

	// Try and write the event to the buffer

	const TInt sizeBefore = iBuffer->Size();

	RBufWriteStream stream(*iBuffer, iBuffer->Size());

	stream << *iEvent;

	const TInt sizeAfter = iBuffer->Size();

	//

	TBool moreToFetch = EFalse;

	const TInt numberToFetch = iWindow.Range();

	if	(sizeAfter > iWindow.iBufferSize)

		{

		//The client buffer size is too small. It should be increased, if the client wants

		//to get the server data. 

		//The server sets iServerDataSize data member with the minimal size which the client

		//side buffer should have - sizeAfter.

		TPtrC8 ptr(reinterpret_cast <TUint8*> (&iWindow), sizeof(iWindow));

		iWindow.iServerDataSize = sizeAfter;

		iMessage->WriteL(2, ptr);

		iBuffer->ResizeL(sizeBefore);

		iWindowIndex -= 1; // we didn't get this event

		}

	else if	(iWindowIndex+1 < numberToFetch)

		{

		GetNextEventL(iWindowIndex+1);

		moreToFetch = ETrue;

		}

	if	(!moreToFetch)

		{

		// Write whatever we have back to the client's address space

		TPtr8 pBuffer(iBuffer->Ptr(0));

		iMessage->WriteL(3, pBuffer);

		iState = EStateIdle;

		}

	}

void CLogServViewWindowFetcher::DoCancel()

	{

	switch(iState)

		{

	case EStateStarting:

		// Nothing to do, completed our own request status

		break;

	case EStateContinuing:

		iGetEvent->Cancel();

		break;

	default:

		__ASSERT_ALWAYS(0, Panic(ELogViewWindowFetcherBadState3));

		break;

		}

	CLogActive::DoCancel();

	}

void CLogServViewWindowFetcher::DoComplete(TInt& aCompletionCode)

	{

	// Indicates to the client side how many records we retrieved.

	if	(aCompletionCode == KErrNone)

		aCompletionCode = iWindowIndex+1;

	else

		iState = EStateIdle;

	}

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

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

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

void CLogServViewWindowFetcher::GetNextEventL(TInt aWindowIndex)

	{

	const TInt index = iWindow.iLower + aWindowIndex;

	const TInt viewCount = iView->Count();

	if	(index < 0)

		{

		::PanicClientL(*iMessage, ELogViewBadWindow);

		}

	else if (index >= viewCount)

		{

		// View is still catching up with changes which have been made in the server?

		CLogEvent* event = CLogEvent::NewL();

		delete iEvent;

		iEvent = event;

		CompleteRequest();

		iWindowIndex = aWindowIndex;

		}

	else

		{

		const TLogId id = iView->At(index);

		iEvent->SetId(id);

		iGetEvent->StartL(*iEvent, iStatus, *iMessage);

		iWindowIndex = aWindowIndex;

		SetActive();

		}

	}

void CLogServViewWindowFetcher::CompleteRequest()

	{

	TRequestStatus* status = &iStatus;

	User::RequestComplete(status, KErrNone);

	SetActive();

	}