/*

* Copyright (c) 2006 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 "NGAPostProcHwDevice.h"

#include "NGAPostProcSessionManager.h"

#include "NGAPostProcSurfaceHandler.h"

#include "common.h"

// post-processor info

const TUid KUidVideoPostProcHwDevice = {KUidNGAPostProcHwDeviceImplUid};

_LIT(KManufacturer, "Nokia Inc.");

_LIT(KIdentifier, "Nokia S60 Video Post Processor Hardware Device Plugin");

// --- Constants ---

const TInt KMaxVBMBuffers      			= 4;

const TInt KMinVBMInputWidth   			= 32; 

const TInt KMinVBMInputHeight  			= 32;

const TInt KMaxVBMInputWidth   			= 1280; 

const TInt KMaxVBMInputHeight  			= 720;

const TInt KRenderAhead 	     		= 50000;     

const TInt KMaxRenderDelay     			= 50000;

const TInt KPostingOfset       			= 0;    

const TInt KColorConversionBuffers  	= 3;

const TInt KMaxBuffersGceCanHold    	= 3;

const TInt KDefPlayRate					= 100;

const TInt KMaxAllowedSkipInNFrames 	= 40;

#ifdef __cplusplus

extern "C"

{

#endif

int32 gColorConvYUVtoYUV422Int (tBaseVideoFrame *yuv420Frame, tBaseVideoFrame* yuv422Frame,

							   uint8 outClrFmt, int16 stride); 

#ifdef __cplusplus

}

#endif

//**************************************************

CMMFVideoPostProcHwDevice* CNGAPostProcHwDevice::NewL() 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice::NewL() ++"));

    CNGAPostProcHwDevice* self = new (ELeave) CNGAPostProcHwDevice; 

    CleanupStack::PushL(self);

    self->ConstructL(); 

    CleanupStack::Pop();

   PP_DEBUG(_L("CNGAPostProcHwDevice::NewL() --"));

    return (CMMFVideoPostProcHwDevice*)self; 

}

void CNGAPostProcHwDevice::ConstructL() 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]::ConstructL() ++"), this);

    // support for VBM buffer interface

    iVBMBufferOptions.iNumInputBuffers  = KMaxVBMBuffers; 

    iVBMBufferOptions.iBufferSize = TSize(KMaxVBMInputWidth, KMaxVBMInputHeight);

    iPostingTimer = CNGAPostProcTimer::NewL(*this);

    iWsSession.Connect();

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]::ConstructL() --"), this);

}

CNGAPostProcHwDevice::CNGAPostProcHwDevice() 

        :   iProxy(NULL), 

            iInputDecoderDevice(NULL),

            iCurrentPlaybackPosition(TTimeIntervalMicroSeconds(0)),

            iPPState(EInitializing),

            iSurfaceHandler(NULL),

            iSessionManager(NULL),

            iIsInputEnded(EFalse),

            iPostingTimer(NULL),

            iFirstPictureUpdated(EFalse),

            iUsingExternalSurface(EFalse),

            iIsColorConversionNeeded(EFalse),

            iSurfaceCreatedEventPublished(EFalse),

            iOverflowPictureCounter(0),

            iVideoFrameBufSize(0),

            iResourceLost(EFalse),

            iVBMObserver(NULL),

            count(0),

            iSurfaceMask(surfaceHints::EAllowAllExternals),

            iSurfaceKey(TUid::Uid(surfaceHints::KSurfaceProtection)),

            iVideoSurfaceObserver(NULL),

            iVPObserver(NULL),

            iPicSize(0,0),

            iStepFrameCount(0),

            iPlayRate(KDefPlayRate),

            iKeyFrameMode(EFalse),

            iFPObserver(NULL)

{

	iSurfaceId 		 = TSurfaceId::CreateNullId();

	iAttributes().iPixelFormat    = EUidPixelFormatYUV_422Interleaved;

}

CNGAPostProcHwDevice::~CNGAPostProcHwDevice()

{

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]::~CNGAPostProcHwDevice() ++"), this);

   	if (iSessionManager)

    {

        iSessionManager->CancelUpdate();

        delete iSessionManager;

        iSessionManager = NULL;

    }

   	while (iSupportedInputFormats.Count()>0)

    {

		iSupportedInputFormats.Remove(0);

    }

   	while (iProcessQ.Count()>0)

    {

		iProcessQ.Remove(0);

    }

   	if(iPostingTimer)

    {

    	iPostingTimer->Cancel();

        delete iPostingTimer;

        iPostingTimer = NULL;

    }

    while (iVBMBufferReferenceQ.Count()>0)

    {

        TVideoPicture* pic = iVBMBufferReferenceQ[0];

        iVBMBufferReferenceQ.Remove(0);

        if (pic->iHeader) delete pic->iHeader;

        delete pic->iData.iRawData;

        delete pic;

    }

    iSupportedInputFormats.Reset();

    iSupportedInputFormats.Close();

    iVBMBufferReferenceQ.Reset();

    iVBMBufferReferenceQ.Close();

    iVBMBufferQ.Reset();

    iVBMBufferQ.Close();

    iProcessQ.Reset();

    iProcessQ.Close();

    iInputQ.Reset();

    iInputQ.Close();

    if (iSurfaceHandler)

    {

    	if(!iSurfaceId.IsNull())

    	{

    		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]::UnregisterSurface"), this);

        	iSurfaceHandler->DestroySurface(iSurfaceId);

    	}

        delete iSurfaceHandler;

        iSurfaceHandler = NULL;

    }

    iWsSession.Close();

    iChunk.Close();

    RDebug::Printf("------ Statistics of Post Processor ------");

    RDebug::Printf("    Pictures Received : %d", iPictureCounters.iTotalPictures);

    RDebug::Printf("    Pictures Displayed: %d", iPictureCounters.iPicturesDisplayed);

    RDebug::Printf("    Pictures Skipped  : %d", iPictureCounters.iPicturesSkipped);

    RDebug::Printf("    Pictures overflow : %d", iOverflowPictureCounter);

    RDebug::Printf("------------------------------------------");

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:~() --"), this);

}

void CNGAPostProcHwDevice::SetInputFormatL(const TUncompressedVideoFormat&  aFormat) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputFormatL() Pattern= %x ++"), this, aFormat.iYuvFormat.iPattern);

    if (iPPState != EInitializing)

    {

				PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputFormatL() FAILED: Unexpected state"), this);

        User::Leave(KErrNotReady);

	  }

		if( ((aFormat.iYuvFormat.iPattern == EYuv420Chroma1) ||

			(aFormat.iYuvFormat.iPattern == EYuv420Chroma2) ||

    		(aFormat.iYuvFormat.iPattern == EYuv420Chroma3) ))

		{

#if defined __WINSCW__				

				iIsColorConversionNeeded = ETrue; 

#else

				iAttributes().iPixelFormat = EUidPixelFormatYUV_420Planar;

#endif //__WINSCW__

		}	

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputFormatL() WARNING: -- Not Found!"), this);

}

void CNGAPostProcHwDevice::SetInputDevice(CMMFVideoDecodeHwDevice* aDevice) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputDevice() ++"), this);

    if (iPPState != EInitializing)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputDevice() FAILED: unexpected state"), this);

        return;

	}

    iInputDecoderDevice = aDevice;

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetInputDevice() --"), this);

}

void CNGAPostProcHwDevice::GetOutputFormatListL(RArray<TUncompressedVideoFormat>& ) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:GetOutputFormatListL() ++"), this);

	PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:GetOutputFormatListL() --"), this);

}

void CNGAPostProcHwDevice::SetOutputFormatL(const TUncompressedVideoFormat&  ) 

{

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetOutputFormatL() ++"), this);

	PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetOutputFormatL() --"), this);

}

void CNGAPostProcHwDevice::SetClockSource(MMMFClockSource* aClock) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetClockSource() ++"), this);

    if (iPPState != EInitializing)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetClockSource() FAILED: Unexpected state"), this);

        return;

	}

    iClockSource = aClock;

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetClockSource() --"), this);

}

void CNGAPostProcHwDevice::SetVideoDestScreenL(TBool /*aScreen*/) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetVideoDestScreenL() ++"), this);

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetVideoDestScreenL() --"), this);

}

void CNGAPostProcHwDevice::SetProxy(MMMFDevVideoPlayProxy& aProxy) 

{ 

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetProxy() ++"), this);

    if (iPPState != EInitializing)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetProxy() FAILED: Unexpected state"), this);

        return;

	}

    iProxy = &aProxy;

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:SetProxy() --"), this);

}

void CNGAPostProcHwDevice::Initialize() 

{

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:Initialize ++"));

	TInt err = KErrNone;

    if (iPPState != EInitializing)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:Initialize() FAILED: Unexpected state"), this);

        return;

	}

	if (!iSurfaceHandler)

    {

    	TRAP(err, iSurfaceHandler = CNGAPostProcSurfaceHandler::NewL());

    	if (err != KErrNone)

    	{

    	   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:Initialize -- failed to create SurfaceHandler."), this);

    	    return;

    	}

    }

    if (!iSessionManager)

    {

    	TRAP(err, iSessionManager = CNGAPostProcSessionManager::NewL());

    	if (err != KErrNone)

    	{

    	   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:Initialize -- failed to create SessionManager."), this);

    	    return;

    	}

    	iSessionManager->SetObserver(*this);

    }

  	if (iInputDecoderDevice)

	{

		MMmfVideoResourceHandler* handler = NULL;

		handler = (MMmfVideoResourceHandler*)iInputDecoderDevice->CustomInterface(KUidMmfVideoResourceManagement);

		if (handler)

		{

			handler->MmvrhSetObserver((MMmfVideoResourceObserver*)this);

		}

		else

		{

			PP_DEBUG(_L("ppHwDev[%x]:Initialize() decoder yet to implement MMmfVideoResourceHandler CI"), this);

		}

		MMmfVideoPropertiesNotifier* VPHandler = NULL;

		VPHandler = (MMmfVideoPropertiesNotifier*)iInputDecoderDevice->CustomInterface(KUidMmfVideoPropertiesManagement);

		if (VPHandler)

		{

			PP_DEBUG(_L("ppHwDev[%x]:Initialize() Register for video property changes"), this);

			VPHandler->MmvpnSetObserver((MMmfVideoPropertiesObserver*)this);

		}

		else

		{

			PP_DEBUG(_L("ppHwDev[%x]:Initialize() decoder yet to implement MMmfVideoPropertiesNotifier CI"), this);

		}

	}

    // Initialize picture counters

	iPictureCounters.iPicturesSkipped 	= 0;

	iPictureCounters.iPicturesDisplayed = 0;

	iPictureCounters.iTotalPictures = 0;

	iOverflowPictureCounter = 0;

	if (iProxy)

	{

		iProxy->MdvppInitializeComplete(this, err);

	}

	iPPState = EInitialized;	

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:Initialize --"), this);

}

void CNGAPostProcHwDevice::WritePictureL(TVideoPicture* aPicture) 

{ 

	PP_DEBUG(_L("CNGAPostProcHwDevice:WritePicture ++"));

	TVideoPicture* pic;

	if (iPPState==EInitializing || iPPState==EStopped || iIsInputEnded)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePictureL() FAILED: Unexpected state"), this);

        User::Leave(KErrNotReady);

	}

    if(!aPicture)

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePictureL() FAILED: Invalid argument"), this);

		User::Leave(KErrArgument);

	}

	pic = aPicture;	

    if (iInputQ.Count() > 0)

    {

        AddToQ(pic);

        AttemptToPost();

    }

    else

    {

		PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePicture bufId = %d"), this,GetID(pic));

		iPictureCounters.iTotalPictures++;

		TInt64 delta = 0;

		TTimeToPost iTimeToPost = (TTimeToPost)IsTimeToPost(pic, delta);

		if(!IsGceReady())

	    {  

			PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePictureL GCE not ready"), this );

			if(iTimeToPost == EPostIt)

			{

					iTimeToPost = EDelayIt;

			}

	    }

	    if (delta > 0x7FFFFFFF)

	    {

	         PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePictureL Too large delta .. skipping"), this ); 

	         iTimeToPost = ESkipIt;

	    }

		switch(iTimeToPost)

		{

			case EDelayIt:

			{

				if(AddToQ(pic) != 0)

				{

					break;

				}

				iPostingTimer->Cancel();

				SetTimer(delta);

			}

			break;

			case EPostIt:

			{

				if(iIsColorConversionNeeded)

				{

					TVideoPicture* ccPic;				

	    			ccPic = DoColorConvert(pic); // output will be in ccPic

	    			pic = ccPic;			   

				}

				iProcessQ.Append(pic);

				#ifdef _DUMP_YUV_FRAMES

				captureYuv(pic);

				#endif

				iSessionManager->PostPicture(iSurfaceId, GetID(pic), iInfo().iBuffers, ETrue);	

				iCurrentPlaybackPosition = pic->iTimestamp;			

				if(!iFirstPictureUpdated)

				{

					iFirstPictureUpdated = ETrue;

					PublishSurfaceCreated();

				}

			}

			break;

			case ESkipIt:

			{

				ReleasePicture(pic); 

				PicturesSkipped();

			}

			break;

		}

    }

	PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:WritePicture --"), this);

}

CPostProcessorInfo* 

CNGAPostProcHwDevice::PostProcessorInfoLC() 

{

   PP_DEBUG(_L("CNGAPostProcHwDevice[%x]:PostProcessorInfoLC() ++"), this);

    TUncompressedVideoFormat yuvFormat;

    RArray<TUint32>                     SupportedPostProcess;

    TBool                               SupportedHwAcceleration = ETrue;   //Non-Accelerated ETrue, 

    TYuvToRgbCapabilities               SupportedYuvToRgbCapab; 

    TInt32                              SupportedRotations = ERotateNone; // no rotation supported

    TBool                               SupportedArbitraryScaling = EFalse; // no scaling supported

    RArray<TScaleFactor>                SupportedScaleFactors;

    TBool                               SupportedAntiAliasing = EFalse;

    //default

    yuvFormat.iDataFormat                     = EYuvRawData;

    yuvFormat.iYuvFormat.iYuv2RgbMatrix       = 0;

    yuvFormat.iYuvFormat.iRgb2YuvMatrix       = 0;

    yuvFormat.iYuvFormat.iAspectRatioNum      = 1;

    yuvFormat.iYuvFormat.iAspectRatioDenom    = 1;

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt709Range1;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout          = EYuvDataInterleavedBE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt709Range0;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedBE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt709Range0;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedLE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

	yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt709Range1;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedLE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt601Range0;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedBE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt601Range1;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedBE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma2;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));

    yuvFormat.iYuvFormat.iCoefficients  	  = EYuvBt601Range0;

    yuvFormat.iYuvFormat.iPattern       	  = EYuv422Chroma1;

    yuvFormat.iYuvFormat.iDataLayout    	  = EYuvDataInterleavedLE;

    User::LeaveIfError(iSupportedInputFormats.Append(yuvFormat));