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