/*

* Copyright (c) 2008 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:   Interthread synchronization object

*

*/

#ifndef __ALF_STREAMER_BRIDGE__

#define __ALF_STREAMER_BRIDGE__

#include <e32std.h>

#include <e32base.h>

#include <fbs.h>

#include "alfbridgecommands.h"

#include "uiacceltk/HuiEnv.h"

#include "alfstreamerconsts.h"

class CAlfStreamerServer;

class CAlfCommandDebug;

const TInt KInitialVariableBufferSize = 2000;

// basic signalling for frame flow control

const TInt KRELEASEWINDOWSERVER = 0;

const TInt KRELEASEDBEFOREQUEUE = 1;

//TODO THESE SHOULD USE MWsWindowTreeNode::TType INSTEAD

enum TAlfWindowNodeType

    {

	EAlfWinTreeNodeClient = 0,	

	EAlfWinTreeNodeRoot = 1,		

	EAlfWinTreeNodeGroup = 2,		

	EAlfWinTreeNodeAnim = 16,		

	EAlfWinTreeNodeSprite = 17,

	EAlfWinTreeNodeTextCursor = 18,

	EAlfWinTreeNodeFloatingSprite = 19 // TODO SOLVE THIS. THIS IS VERY MISLEADING ARRANGAMENT!

	};

enum TAlfWindowNodeFlags

    {

    EAlfWinNodeFlagOpaque = 0x1            

    };

class TAlfWindowAttributes

    {

public:

    TAlfWindowAttributes() :    

        iWindowNodeType(0),

        iPosition(0,0),

        iSize(0,0),

        iOrdinalPosition(0),

        iOpacity(1.f),

        iRotation(0.f),

        iTransitionTime(0),

        iActive(ETrue),

        iSurfaceExtent(0,0,0,0),

        iLayerUsesAlphaFlagEnabled(EFalse),

        iClientHandle(0),

        iClientGroupHandle(0),

        iWindowNodeFlags(0),

        iScreenNumber(0),

        iSecureId(0),

        iParentNodeId(0)

#ifdef ALF_DEBUG_TRACK_DRAWING

        ,iTrackWindow(EFalse)

#endif

            {

            }

    TInt    iWindowNodeType; // MWsWindowTreeNode::TType

    TPoint  iPosition;        

    TSize   iSize;

    TInt    iOrdinalPosition;

    TReal32 iOpacity;

    TReal32 iRotation;

    TUint   iTransitionTime;

    TBool   iActive;

    TRect   iSurfaceExtent;

    TBool   iLayerUsesAlphaFlagEnabled;

    TInt    iClientHandle;

    TInt    iClientGroupHandle;

    TInt    iWindowNodeFlags;

    TInt    iScreenNumber;

    TInt    iBitmapHandle;

    TInt32  iSecureId;

    TInt    iParentNodeId;

#ifdef ALF_DEBUG_TRACK_DRAWING	

    TBool   iTrackWindow;

#endif	

    // TODO: We should refactor this to contain unions or 

    // different strcuts for different commands, 

    // every command does not use everything

    };

class TAlfCursorDataBufferAttributes

    {

public:

    TInt iColor;

    TInt iFlashInterval;

    TInt iFlags;

    TInt iScreenNumber;

    };

class TAlfWindowCommandBufferAttributes

    {

public:

    enum TAlfBufferStatus 

    {

		EPartComplete,

		ENotComplete,

		ELastPart

    }; 

    TAlfWindowCommandBufferAttributes() :    

        iBufferLength(0),

        iBuffer(NULL),

        iEmptyThisBuffer(ETrue),

        iPartStatus(EPartComplete),

        iWindowNodeFlags(0)        

            {

            }

    TInt    iBufferLength;

    TAny*   iBuffer;

    TBool   iEmptyThisBuffer;

    TAlfBufferStatus   iPartStatus;

    TInt    iWindowNodeFlags;

    TInt    iScreenNumber;

    };

class MAlfStreamerListener

    {

    public:

    virtual void HandleCallback(TInt aStatus) = 0;

    };

class MAlfBatchObs

    {

    public:

    virtual void BridgerCallback( TInt aOp = 0, TInt aInt = 0) = 0;

    virtual void BridgerCanceled() = 0;

    };

class TAlfBridgerData

    {

    private:

    public:

    TAlfBridgerData()

        {

        ResetEntry();

        }

    void Set(TAlfDecoderServerBindings aOp,TInt aI1,TInt aI2,TAny* aPtr)

        {

        iOp=aOp;

        iInt1=aI1;

        iInt2=aI2;

        iPtr=aPtr;        

        }

    void ResetEntry()

        {

        Set(KUnInitialized,0,0,0);

        }    

    TBool IsEmpty()

        {

        return iOp == KUnInitialized;        

        }

    TAlfDecoderServerBindings iOp;

    TInt iInt1;

    TInt iInt2;

    TAny* iPtr;

    };

NONSHARABLE_CLASS(CAlfStreamerBridge): public CActive, public CHuiEnv::MHuiSwapObserver

    {

    public:

    CAlfStreamerBridge(MAlfStreamerListener* aObserver);

    static CAlfStreamerBridge* NewL( MAlfStreamerListener* aObserver );

private:

    void ConstructL();

    ~CAlfStreamerBridge();

public:

    /**

     * SetBatchObserver

     *

     * @since S60 5.0

     * @param aWindow

     */

    void SetBatchObserver(MAlfBatchObs* aBatchObserver);

    /**

     * Activate

     *

     * @since S60 5.0

     * @param aWindow

     */    

    void Activate();

    /**

     * Trigger

     *

     * @since S60 5.0

     */

    TInt Trigger(TInt aStatus);

    /**

     * AddData

     *

     * @since S60 5.0

     * @param aWindow

     */

    TInt AddData( TAlfDecoderServerBindings aOp,TInt aI1 = 0,TInt aI2 = 0,TAny* aPtr =0);

    /**

     * GetData

     *

     * @since S60 5.0

     * @param aWindow

     */

    TAlfBridgerData GetData(TInt aIndex);

    /**

     * StartNewBlock

     *

     * @since S60 5.0

     */

    void StartNewBlock();

    /**

     * StartNewBlock

     *

     * @since S60 5.0

     * @param aLastReadOffset

     */

    void RequestCommandReadNotification( 

            TInt aLastReadOffset, 

            TAlfDecoderServerBindings aCommand = EAlfRequestCommandReadNotification );

    // AppendDataL and GetVarDataL are for keeping the memory allocations inside one thread.    

    IMPORT_C const TAny* AppendVarDataL( TInt aSize, TInt& aIndex );

    // Effect data is not synchronized to window server data

    // It can be safely applied only when refresh is not active in hitchcock scene    

    IMPORT_C const TAny* AppendEffectsDataL( TInt aSize, TInt& aIndex );

    const TAny* GetEffectsDataL( TInt aIndex );

    /**

     * GetVarDataL

     *

     * @since S60 5.0

     * @param aIndex Offset to the data struct  (relative to iDataBuf)

     * @return Pointer to the data struct 

     */

    const TAny* GetVarDataL( TInt aIndex );

	/**

     * SetStreamerServer()

     *

     * Sets Streamserver instance. 

     */

    void SetStreamerServer( CAlfStreamerServer& aStreamerServer );

    /**

     * StreamerServer()

     *

     * Gets Streamserver instance set with set functionality.

	 * @see SetStreamerServer()

     */

    CAlfStreamerServer* StreamerServer();

    IMPORT_C TUid FindAppUidForWgId(TInt aWgId);

    IMPORT_C TInt FindWgForAppUid(TUid aAppUid);

public: // from CActive

    void RunL();

    void DoCancel();

public: // from SwapObserver

    void PrepareSwap();

    void SwapComplete();

    void ReleaseWindowServer(TBool aRelease = ETrue);

    void SetWgIdArray(TInt* aArray); 

private:

    MAlfStreamerListener* iObserver;

    MAlfBatchObs* iBatchObserver;

    TThreadId iThread;

    RArray<TAlfBridgerData> iMessages;

    RArray<TInt> iQueue;

    RCriticalSection iQueueSema;

    RBuf8 iDataBuf;

    TInt iItemsInBuffer;

    RArray<TAlfBridgerData> iFxMessages;

    RArray<TInt> iFxQueue;

    RBuf8 iFxBuf;

    TInt iFxItemsInBuffer;

    CAlfStreamerServer* iStreamerServer;

#ifdef ALF_DEBUG_TRACK_DRAWING    

    CAlfCommandDebug* iCommandDebugger;

#endif

    volatile TBool iSwapActive;

    volatile TBool iMakeCurrentActive;

    TBool iFxQueueActive;

    TInt* iWgArray;

    TBool iVarDataAddedButNotPosted;

public:

    TAlfNativeWindowData iAlfWindowData;

    };

#endif // __ALF_STREAMER_BRIDGE__