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

_LIT(KErrDialogTimestampCheckFailed, "A timestamp check failed on Component: %S, Port: %d.  Expected time: %u +/- %u, actual: %Lu");
_LIT(KErrDialogTimestampComparisonFailed, "A timestamp compare with clock media time failed on Component: %S, Port: %d. Media time: %Lu, delay allowed: %u, actual: %Lu");

CBaseProfileTimestampHandling::CBaseProfileTimestampHandling(ROmxScriptTest& aTestOwner, RASBreakEventHandler& aParentEventHandler)
: CBaseProfileHandler(aTestOwner, aParentEventHandler)
    {
    }

CBaseProfileTimestampHandling::~CBaseProfileTimestampHandling()
    {
    iPendingTimestampChecks.Close();
    }
    
void CBaseProfileTimestampHandling::SetClockComponent(OMX_COMPONENTTYPE* aClockComponent)
    {
    iClockComponent = aClockComponent;
    }

void CBaseProfileTimestampHandling::QueueTimestampCheckL(TInt aPortIndex, TUint aTime, TUint aTolerance)
    {
    TTimestampCheckingInfo timestampCheck;
    timestampCheck.iPortIndex = aPortIndex;
    timestampCheck.iExpectedTime = aTime;
    timestampCheck.iTolerance = aTolerance;
    timestampCheck.iCompareWithRefClock = EFalse;
    
    iPendingTimestampChecks.AppendL(timestampCheck);
    }

void CBaseProfileTimestampHandling::QueueCompareWithRefClockL(TInt aPortIndex, TUint aTolerance)
    {
    TTimestampCheckingInfo timestampCheck;
    timestampCheck.iPortIndex = aPortIndex;
    timestampCheck.iExpectedTime = 0;
    timestampCheck.iTolerance = aTolerance;
    timestampCheck.iCompareWithRefClock = ETrue;
    
    iPendingTimestampChecks.AppendL(timestampCheck);   
    } 

void CBaseProfileTimestampHandling::DoFillBufferDone(OMX_BUFFERHEADERTYPE* aFilledBuffer)
    {
    CheckTimestamp(aFilledBuffer);
    }

void CBaseProfileTimestampHandling::DoEmptyBufferDone(OMX_BUFFERHEADERTYPE* aEmptiedBuffer)
    {
    CheckTimestamp(aEmptiedBuffer);
    }

void CBaseProfileTimestampHandling::CheckTimestamp(OMX_BUFFERHEADERTYPE* aBuffer)
    {
    TInt bufferIndex = iBufferHeaders.Find(*aBuffer, CBaseProfileHandler::BufferHeaderMatchComparison);
    
    for (TInt index=0; index < iPendingTimestampChecks.Count(); index++)
        {
        if (iBufferHeaders[bufferIndex]->iPortIndex != iPendingTimestampChecks[index].iPortIndex)
            {
            continue;
            }
        TTimestampCheckingInfo passCriteria = iPendingTimestampChecks[index];
        iPendingTimestampChecks.Remove(index);
        
        if (passCriteria.iCompareWithRefClock)
            {
            OMX_TIME_CONFIG_TIMESTAMPTYPE timeInfo;
            timeInfo.nSize = sizeof(timeInfo);
            timeInfo.nVersion = KOmxVersion;
            timeInfo.nPortIndex = passCriteria.iPortIndex;

            OMX_ERRORTYPE error = iClockComponent->GetConfig(iClockComponent, OMX_IndexConfigTimeCurrentMediaTime, &timeInfo);
            
            if (error != OMX_ErrorNone)
                {
                iErrorCallbacks.FailWithOmxError(_L("OMX_GetConfig(OMX_IndexConfigTimeCurrentMediaTime)"), error);
                }
            else if ((aBuffer->nTimeStamp > timeInfo.nTimestamp) || (aBuffer->nTimeStamp < (timeInfo.nTimestamp - passCriteria.iTolerance)))
                {
                TBuf<200> errorString;
                errorString.Format(KErrDialogTimestampComparisonFailed, iXmlName, passCriteria.iPortIndex, timeInfo.nTimestamp, passCriteria.iTolerance, aBuffer->nTimeStamp);
                iErrorCallbacks.FailTest(errorString);  
                }
            }
        else
            {
            if ((aBuffer->nTimeStamp < (passCriteria.iExpectedTime - passCriteria.iTolerance)) || (aBuffer->nTimeStamp > (passCriteria.iExpectedTime + passCriteria.iTolerance)))
                {
                TBuf<200> errorString;
                errorString.Format(KErrDialogTimestampCheckFailed, iXmlName, passCriteria.iPortIndex, passCriteria.iExpectedTime, passCriteria.iTolerance, aBuffer->nTimeStamp);
                iErrorCallbacks.FailTest(errorString);
                }
            }
        
        break;
        }
    }