/*

* Copyright (c) 2002-2004 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:  ?Description

*

*/

// INCLUDE FILES

#include "DownloadMgrEventQueue.h"

#include "DownloadMgrLogger.h"

#include "HttpDownload.h"

#ifdef __DOWNLOADMGR_LOG__

//#define __DUMP_EVENT_QUEUE

#ifdef __DUMP_EVENT_QUEUE

#pragma message ("Dump event queue!!!")

#endif /* __DUMP_EVENT_QUEUE */

#endif /*__DOWNLOADMGR_LOG__*/

// ============================= LOCAL FUNCTIONS ===============================

// ---------------------------------------------------------

// CDownloadMgrEventQueue::CDownloadMgrEventQueue

// ---------------------------------------------------------

//

CDownloadMgrEventQueue::CDownloadMgrEventQueue()

	{

	__DECLARE_NAME( _S( "CDownloadMgrEventQueue" ) );

	CLOG_CREATE;

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::~CDownloadMgrEventQueue

// ---------------------------------------------------------

//

CDownloadMgrEventQueue::~CDownloadMgrEventQueue()

	{

	iEventQueue.ResetAndDestroy();

	CLOG_CLOSE;

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::In

// ---------------------------------------------------------

//

TBool CDownloadMgrEventQueue::In( CHttpDownload* aDownload, 

                                  THttpDownloadState aDlState,

                                  THttpProgressState aProgState,

                                  TInt32 aMoIndex )

	{

    CLOG_ENTERFN( "CDownloadMgrEventQueue::In" );

    if( aDlState == EHttpDlInprogress && 

        aProgState == EHttpProgResponseBodyReceived && 

        iEventQueue.Count() )

        // If EHttpDlInprogress-EHttpProgResponseBodyReceived is last

        // event in the queue, it doesn't need to be appended again.

        {

        CLOG_WRITE( "In-progress filter" );

        TInt count = iEventQueue.Count();

        TInt32 dlState;

        TInt32 progState;

        TInt32 moIndex;

        CEventRecord* record = iEventQueue[count-1];

        record->States( dlState, progState, moIndex );

        if( aDlState == dlState &&

            aProgState == progState &&

            aMoIndex == moIndex &&

            aDownload == record->Download())

            {

            CLOG_WRITE( "Event filtered" );

            return ETrue;

            }

        }

    CEventRecord* record = new CEventRecord( aDownload, aDlState, aProgState, aMoIndex );

    if( record == NULL )

        {

        return EFalse;

        }

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::In: 0x%x", record );

    TInt err = iEventQueue.Append( record );

    if( KErrNone != err )

        {

        delete record;

        return EFalse;

        }

#ifdef __DUMP_EVENT_QUEUE

    CLOG_WRITE( "=====================>>>>" );

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::In Download: 0x%x", aDownload )

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::In State: %d", aDlState )

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::In Progress: %d",aProgState )

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::In Media Index: %d",aMoIndex )

    CLOG_WRITE( "Dump event queue---------" );

    for( TInt i = 0; i < iEventQueue.Count(); i++ )

        {

        CLOG_WRITE_FORMAT( "i= %d", i )

        CEventRecord* r = iEventQueue[i];

        CLOG_WRITE_FORMAT( "Download: 0x%x", r->Download() )

        TInt32 state;

        TInt32 progress;

        TInt32 mediaIndex;

        r->States( state, progress, mediaIndex );

        CLOG_WRITE_FORMAT( "Download: 0x%x", r->Download() )

        CLOG_WRITE_FORMAT( "State: %d", state )

        CLOG_WRITE_FORMAT( "Progress: %d", progress )        

        CLOG_WRITE_FORMAT( "Media Index: %d", mediaIndex ) 

        }

    CLOG_WRITE( "=====================>>>>" );

#endif /* __DUMP_EVENT_QUEUE */

    return ETrue;

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::Next

// ---------------------------------------------------------

//

CHttpDownload* CDownloadMgrEventQueue::Next( TInt32& aDownloadState,

                                             TInt32& aProgressState,

                                             TInt32& aMoIndex )

	{

    CLOG_ENTERFN( "CDownloadMgrEventQueue::Next" );

    CEventRecord* record = iEventQueue[ 0 ];

    record->States( aDownloadState, aProgressState, aMoIndex );

    CLOG_WRITE( "Next=====================" );

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Next Download: 0x%x", record->Download() )

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Next State: %d", aDownloadState )

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Next Progress: %d",aProgressState ) 

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Next Media Index: %d",aMoIndex ) 

#ifdef __DUMP_EVENT_QUEUE

    CLOG_WRITE( "Dump event queue---------" );

    for( TInt i = 0; i < iEventQueue.Count(); i++ )

        {

        CLOG_WRITE_FORMAT( "i= %d", i )

        CEventRecord* r = iEventQueue[i];

        TInt32 dlState;

        TInt32 progState;

        TInt32 mediaIndex;

        r->States( dlState, progState, mediaIndex );

        CLOG_WRITE_FORMAT( "Download: 0x%x", r->Download() )

        CLOG_WRITE_FORMAT( "State: %d", dlState )

        CLOG_WRITE_FORMAT( "Progress: %d", progState )

        CLOG_WRITE_FORMAT( "Media Index: %d", mediaIndex )

        }

    CLOG_WRITE( "Next=====================" );    

#endif /* __DUMP_EVENT_QUEUE */

	return record->Download();

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::Out

// ---------------------------------------------------------

//

void CDownloadMgrEventQueue::Out()

	{

    CLOG_ENTERFN( "CDownloadMgrEventQueue::Out" );

    CEventRecord* record = iEventQueue[ 0 ];

    iEventQueue.Remove( 0 );

    CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Out Download: 0x%x", record->Download() )

    delete record;

    iEventQueue.Compress();

#ifdef __DUMP_EVENT_QUEUE

    CLOG_WRITE( "<<<<=====================" );

    CLOG_WRITE( "Dump event queue---------" );

    for( TInt i = 0; i < iEventQueue.Count(); i++ )

        {

        CLOG_WRITE_FORMAT( "i= %d", i )

        CEventRecord* r = iEventQueue[i];

        TInt32 dlState;

        TInt32 progState;

        r->States( dlState, progState );        

        CLOG_WRITE_FORMAT( "Download: 0x%x", r->Download() )

        CLOG_WRITE_FORMAT( "State: %d", dlState )

        CLOG_WRITE_FORMAT( "Progress: %d", progState )

        }

    CLOG_WRITE( "<<<<=====================" );

#endif /* __DUMP_EVENT_QUEUE */

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::IsEmpty

// ---------------------------------------------------------

//	

TBool CDownloadMgrEventQueue::IsEmpty() const

	{

    CLOG_WRITE( "CDownloadMgrEventQueue::IsEmpty" );

    return ( iEventQueue.Count() ? EFalse : ETrue );

	}

// ---------------------------------------------------------

// CDownloadMgrEventQueue::Remove

// ---------------------------------------------------------

//	

void CDownloadMgrEventQueue::Remove( CHttpDownload* aDownload )

	{

    CLOG_WRITE( "CDownloadMgrEventQueue::Remove" );

    for( TInt i = 0; i < iEventQueue.Count(); i++ )

        {

        if( iEventQueue[i]->IsDownload( aDownload ) )

            {

            CEventRecord* record = iEventQueue[i];

            CLOG_WRITE_FORMAT( "CDownloadMgrEventQueue::Remove Download: 0x%x", record->Download() )

            iEventQueue.Remove( i );

            delete record;

            record = NULL;

            iEventQueue.Compress();

            i--;

            }

        }

	}

// ---------------------------------------------------------

// CEventRecord::CEventRecord

// ---------------------------------------------------------

//

CEventRecord::CEventRecord( CHttpDownload* aDownload, 

                            TInt32 aDownloadState,

                            TInt32 aProgressState,

                            TInt32 aMoIndex )

:iDownloadState( aDownloadState )

,iProgressState( aProgressState )

,iMoIndex( aMoIndex )

    {

    iDownload = aDownload;

    }

// ---------------------------------------------------------

// CEventRecord::~CEventRecord

// ---------------------------------------------------------

//

CEventRecord::~CEventRecord()

    {

    }

// ---------------------------------------------------------

// CEventRecord::States

// ---------------------------------------------------------

//

void CEventRecord::States( TInt32& aDownloadState,

                           TInt32& aProgressState,

                           TInt32& aMoIndex )

    {

    aDownloadState = iDownloadState;

    aProgressState = iProgressState;

    aMoIndex = iMoIndex;

    }

// ---------------------------------------------------------

// CEventRecord::Download

// ---------------------------------------------------------

//

CHttpDownload* CEventRecord::Download()

    {

    return iDownload;

    }

// ---------------------------------------------------------

// CEventRecord::IsDownload

// ---------------------------------------------------------

//

TBool CEventRecord::IsDownload( CHttpDownload* aDownload )

    {

    return (iDownload == aDownload) ? ETrue : EFalse;

    }

//  End of File