// 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:
// contentupdateproxy.cpp
// Proxy object for receiving SUS surface content update notifications and rerouting them to nativestream 
//


#include <e32def.h>
#include <graphics/suerror.h>
#include "streammap.h"
#include "surfacestream.h"
#include "contentupdateproxy.h"

CExtensionContainer* CContentUpdateProxy::NewL(TInt aScreenNum, COpenWfcStreamMap*	aSingleton,TInt aInternalVersion,TInt aPriority)
	{
	CContentUpdateProxy* pInstance = new(ELeave) CContentUpdateProxy();
	CleanupStack::PushL(pInstance);
	pInstance->ConstructL(aScreenNum,aSingleton,aInternalVersion,aPriority);
	CleanupStack::Pop(pInstance);
	return pInstance;
	}
void CContentUpdateProxy::ConstructL(TInt aScreenNum, COpenWfcStreamMap*	aSingleton,TInt aInternalVersion,TInt aPriority)
	{
	iScreenNum=aScreenNum;
	iSingleton=aSingleton;
	iInternalVersion=aInternalVersion;
	iPriority=aPriority;
	}
CContentUpdateProxy::CContentUpdateProxy():
iHeap(User::Heap())
	{
	}
CContentUpdateProxy::~CContentUpdateProxy()
	{
	
	}

TInt CContentUpdateProxy::Extension_(TUint aExtensionId, TAny*& aRetPtr, TAny* a1)
	{
	switch (aExtensionId)
		{
		case MCompositionSurfaceUpdate::ETypeId:
			{
			aRetPtr=static_cast<MCompositionSurfaceUpdate*>(this);
			return KErrNone;
			}
		default:
			{
			return CExtensionContainer::Extension_(aExtensionId,aRetPtr,a1);
			}
		}
	}

TInt CContentUpdateProxy::ApiVersion()
	{
	return KContentUpdateProxyVersion;
	}

TVersion CContentUpdateProxy::InternalVersion()
	{
	return TVersion(iInternalVersion>>24,(iInternalVersion>>16)&0xff,iInternalVersion&0xffff);
	}

void CContentUpdateProxy::ContentUpdated      
	(	const TSurfaceId&  aSurface,     		TInt		aBuffer,
		const TRegion*     aRegion,
		TRequestStatus*    aStatusConsumed,
		TRequestStatus*    aStatusDisplayed,	TUint32*	aTimeStamp,
		TRequestStatus*    aStatusDispXTimes,	TInt*		aDisplayedXTimes)
	{
    NFLOG(("### CContentUpdateProxy srf(0x%x:0x%x:0x%x:0x%x),"
            "\n\t\t buff(%d),\n\t\t rg(0x%x),\n\t\t rsConsumed(0x%x),\n\t\t rsDsp(0x%x),\n\t\t ts(0x%x),"
            "\n\t\t rsDXT(0x%x),\n\t\t dXT(%d)", 
            aSurface.iInternal[0], aSurface.iInternal[1], aSurface.iInternal[2], aSurface.iInternal[3],
            aBuffer, aRegion, aStatusConsumed, aStatusDisplayed, aTimeStamp, aStatusDispXTimes, aDisplayedXTimes ? *aDisplayedXTimes: 0));
    
    COpenWfcStreamMap* stream = NULL;
    TRAPD(err,stream = &COpenWfcStreamMap::InstanceL());
    if (err != KErrNone)
        {
        NFLOG(("### ERROR - EARLY EXIT * CContentUpdateProxy::ContentUpdated()"));
        // cancel notifications
        CompleteStatus(
                aStatusConsumed,
                aStatusDisplayed,
                aStatusDispXTimes,
                err);
        return;
        }
    RHeap* oldHeap = NULL;
	if (&iHeap != &(User::Heap()))
	    {
	    oldHeap = User::SwitchHeap(stream->GetMainHeap());
	    }
	CSurfaceStream* ns = NULL;
	ns = stream->Find(aSurface);

	if (ns)
		{
		RegisterNotifications(*ns,
                              aBuffer,
                              aStatusDisplayed, aTimeStamp,
                              aStatusDispXTimes, aDisplayedXTimes,
                              aStatusConsumed, aRegion);
		
		ns->ReleaseReference();
		}
	else
	    {
	    // cancel notifications
	    CompleteStatus(aStatusConsumed,
	            aStatusDisplayed,
	            aStatusDispXTimes,
	            KErrSurfaceNotRegistered);
	    }
	if (oldHeap)
	    {
	    (void)User::SwitchHeap(oldHeap);
	    }
    NFLOG(("### EXIT * CContentUpdateProxy::ContentUpdated()"));
	}

void CContentUpdateProxy::CompleteStatus(
        TRequestStatus*    aStatusConsumed,
        TRequestStatus*    aStatusDisplayed,
        TRequestStatus*    aStatusDispXTimes,
        TInt aReason)
    {
    if (aStatusConsumed)
        {
        User::RequestComplete(aStatusConsumed, aReason);
        }
    if (aStatusDisplayed)
        {
        User::RequestComplete(aStatusDisplayed, aReason);
        }
    if (aStatusDispXTimes)
        {
        User::RequestComplete(aStatusDispXTimes, aReason);
        }
    }

void CContentUpdateProxy::RegisterNotifications(CSurfaceStream& aNs,
                                                 TInt            aBuffer,
                                                 TRequestStatus* aStatusDisplayed, TUint32* aTimeStamp,
                                                 TRequestStatus* aStatusDispXTimes, TInt* aDisplayedXTimes,
                                                 TRequestStatus* aStatusConsumed, const TRegion* aRegion)
    {
    if (KErrNone != aNs.CheckBufferNumber(aBuffer, aStatusDisplayed, aStatusDispXTimes, aStatusConsumed))
        {
        return;
        }
    
    TInt updateFlag = 0;
    if (aStatusConsumed)
        {
        *aStatusConsumed = KRequestPending;
        updateFlag |= ESOWF_EventAvailable;
        }
    if (aStatusDisplayed)
        {
        *aStatusDisplayed = KRequestPending;
        updateFlag |= ESOWF_EventDisplayed;
        }
    if (aStatusDispXTimes)
        {
        *aStatusDispXTimes = KRequestPending;
        updateFlag |= ESOWF_EventDisplayedX;
        }
    
    aNs.SetNewNotifications(aBuffer, 
                            aStatusDisplayed, 
                            aTimeStamp, 
                            aStatusDispXTimes, 
                            aDisplayedXTimes, 
                            aStatusConsumed, 
                            aRegion,
                            iScreenNum);
    }