// Copyright (c) 2004-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:
//

/** 	@file
	@internalTechnology */
#include <e32base.h>
#include "InputStream.h"

#include "ChunkProcessor.h"

CChunkProcessor::CChunkProcessor(CMngPlayer& aMngPlayer):
								CActive(EPriorityIdle),
								iMngPlayer(aMngPlayer)
	{
	CActiveScheduler::Add(this);
	}

void CChunkProcessor::DoCancel()
	{
	if (iCallerRequest != NULL)
		{
		User::RequestComplete(iCallerRequest, KErrCancel);
		}
		
	if (iStatus.Int() == KRequestPending)
		{
		TRequestStatus* pReq=&iStatus;
		User::RequestComplete(pReq, KErrCancel);
		}
	}

TInt CChunkProcessor::RunError(TInt aError)
	{
	NotifyCaller(aError);
	return KErrNone;
	}

void CChunkProcessor::RunAgain()
	{
	if (iIsPaused)
		{
		ASSERT(EFalse==iNeedRunAfterResume);
		iNeedRunAfterResume = ETrue;
		}
	else
		{
		iNeedRunAfterResume = EFalse;
		SetActive();
		TRequestStatus* pReq=&iStatus;
		User::RequestComplete(pReq, KErrNone);
		}
	}

void CChunkProcessor::Pause()
	{
	iIsPaused = ETrue;
	if (iSubProcessor)
		{
		iSubProcessor->Pause();
		}
	}

void CChunkProcessor::Resume()
	{
	iIsPaused=EFalse;
	if (iSubProcessor)
		{
		iSubProcessor->Resume();
		}
		
	if (iNeedRunAfterResume)
		{
		RunAgain();
		}
	}

void CChunkProcessor::Stop()
	{
	if (iInputStream != NULL)
		{
		iInputStream->Release();
		}
	iInputStream = NULL;
	if (iSubProcessor != NULL)
		{
		iSubProcessor->Stop();
		}
	Cancel();
	iNeedRunAfterResume = EFalse;
	}

void CChunkProcessor::NotifyCaller(TInt aErrCode)
	{
	User::RequestComplete(iCallerRequest, aErrCode);
	if (iInputStream != NULL)
		{
		iInputStream->Release();
		}
	iInputStream = NULL;
	}

void CChunkProcessor::RunL()
	{
	if (iStatus != KErrNone)
		{
		User::Leave(iStatus.Int());
		}
	if (iIsPaused)
		{
		ASSERT(EFalse==iNeedRunAfterResume);
		iNeedRunAfterResume = ETrue;
		}
	else
		{
		DoRunL();
		}
	}