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

//

#ifndef __TESTASYNCCONVERT_H__

#define __TESTASYNCCONVERT_H__

#include "imageconversion.h"

#include "TestAsyncCodec.h"

#include <icl/imageplugin.h>

// forward refs

class CTestAsyncReadCodec;

class CTestAsyncWriteCodec;

// MAsyncSchedulerObserver

// mixin class to handle callbacks from an CAsyncScheduler object

class MAsyncSchedulerObserver

	{

public:

	virtual void MasoProcessL(TInt error) = 0;

	};

class CAsyncScheduler : public CActive

	{

public:

	CAsyncScheduler(MAsyncSchedulerObserver& aSchedulerObserver);

	void Start();

	// From CActive

	virtual void RunL();

	virtual void DoCancel() {};

private:

	MAsyncSchedulerObserver& iSchedulerObserver;

	};

class CTestAsyncDecoder : public CImageDecoderPlugin, 

	public MAsyncSchedulerObserver

	{

public:

	static CTestAsyncDecoder* NewL();

	virtual ~CTestAsyncDecoder();

	virtual void ImageType(TInt aFrameNumber, TUid& aImageType, TUid& aImageSubType) const;

	CFrameInfoStrings* FrameInfoStringsL(RFs& aFs, TInt aFrameNumber);

	// From CImageDecoderPlugin

	virtual void DoConvert();

	virtual TInt NumberOfImageComments() const;

	virtual HBufC* ImageCommentL(TInt aCommentNumber) const;

	virtual TInt NumberOfFrameComments(TInt aFrameNumber) const;

	virtual HBufC* FrameCommentL(TInt aFrameNumber, TInt aCommentNumber) const;

	void ScanDataL();

	virtual void Cleanup();

	// from MAsyncSchedulerObserver

	virtual void MasoProcessL(TInt aError);

	// callback from CTestAsyncReadCodec to indicate completion

	// of CTestAsyncReadCodec::ProcessFrameL()

	void ProcessFrameComplete(TInt aError);

private:

	CTestAsyncDecoder();

	void ConstructL();

private:

	enum TDecodeState

		{

		EDecodeInit,

		EDecodeInProgress,

		EDecodeFinished

		};

	TDecodeState iDecodeState;

	CTestAsyncReadCodec* iImageReadCodec;	// not owned

	TInt iDecodeIterations;

	TInt iMaxValue;

	TBool iReadHeaders;

	CAsyncScheduler* iScheduler;

	TInt iError;

	};

class CTestAsyncEncoder : public CImageEncoderPlugin, public MAsyncSchedulerObserver

	{

public:

	static CTestAsyncEncoder* NewL();

	virtual ~CTestAsyncEncoder();

	// From CImageEncoderPlugin

	virtual void DoConvert();

	void PrepareEncoderL(const CFrameImageData* aFrameImageData);

	virtual void Cleanup();

	void UpdateHeaderL();

	// from MAsyncSchedulerObserver

	virtual void MasoProcessL(TInt aError);

	// callback from CTestAsyncWriteCodec to indicate completion

	// of CTestAsyncWriteCodec::ProcessFrameL()

	void ProcessFrameComplete(TInt aError);

private:

	CTestAsyncEncoder();

	void ConstructL();

private:

	enum TEncodeState

		{

		EEncodeInit,

		EEncodeInProgress,

		EEncodeFinished

		};

	TEncodeState iEncodeState;

	CTestAsyncWriteCodec* iImageWriteCodec;	// not owned

	TInt iEncodeIterations;

	TInt iMaxValue;

	TBool iReadHeaders;

	CAsyncScheduler* iScheduler;

	TInt iError;

	};

#endif