/*

* 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:  Implementation of CCDSYDOSServerRequestManager class

*

*/

// INCLUDE FILES 

#include "CDSYDOSServerRequestManager.h"

#include "CDSYMessageBufferItem.h"

#include "CDSYMessage.h"

#include "CDSYController.h"

#include "CDSYMessageIDs.h"

#include "commondsy_debug.h"

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES  

// CONSTANTS

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

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

// ============================ MEMBER FUNCTIONS ===============================

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

// CCDSYDOSServerRequestManager::CCDSYDOSServerRequestManager

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

CCDSYDOSServerRequestManager::CCDSYDOSServerRequestManager( CCDSYController& aCDSYController )

: iCDSYController( aCDSYController )

, iLDSYFind( ETrue )

    {

    COM_TRACE_1( "CDSY - CCDSYDOSServerRequestManager::CCDSYDOSServerRequestManager(0x%x)", &aCDSYController );

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::CCDSYDOSServerRequestManager - return void" );

    }

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

// CCDSYDOSServerRequestManager::~CCDSYDOSServerRequestManager

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

CCDSYDOSServerRequestManager::~CCDSYDOSServerRequestManager()

    {

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::~CCDSYDOSServerRequestManager()" );

#ifndef RD_STARTUP_CHANGE

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGetStartupReasonReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgInitiateDSYStartupReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgExecuteSelfTestReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGetSoftwareResetReasonReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSetSoftwareResetReasonReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgIndicatePowerOnReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSwitchOffPowerReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGetSoftwareResetStatusReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgExecuteSoftwareResetReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSendStartupSyncReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgExecuteDeepRfsReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgExecuteNormalRfsReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgCheckTimeValidityReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSetWakeupAlarmReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgCancelWakeupAlarmReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSendShutdownSyncReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSetDomesticOSStatusReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgSetOfflineStatusReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGetOfflineStatusReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGetPreferredLanguageReturn, this );

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgGenerateGripEventReturn, this );

#endif //RD_STARTUP_CHANGE    

    iCDSYController.UnregisterServiceLogic( KCDSYMsgGroup, KCDSYMsgInitializeExtensionReturn, this );

    iMessages.ResetAndDestroy();

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::~CCDSYDOSServerRequestManager - return void" );

    }

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

// CCDSYDOSServerRequestManager::ConstructL

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

void CCDSYDOSServerRequestManager::ConstructL()

    {

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::ConstructL()" );

#ifndef RD_STARTUP_CHANGE

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGetStartupReasonReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgInitiateDSYStartupReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgExecuteSelfTestReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGetSoftwareResetReasonReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSetSoftwareResetReasonReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgIndicatePowerOnReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSwitchOffPowerReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGetSoftwareResetStatusReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgExecuteSoftwareResetReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSendStartupSyncReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgExecuteDeepRfsReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgExecuteNormalRfsReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgCheckTimeValidityReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSetWakeupAlarmReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgCancelWakeupAlarmReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSendShutdownSyncReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSetDomesticOSStatusReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgSetOfflineStatusReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGetOfflineStatusReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGetPreferredLanguageReturn, this );

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgGenerateGripEventReturn, this );

#endif // RD_STARTUP_CHANGE

    iCDSYController.RegisterServiceLogicL( KCDSYMsgGroup, KCDSYMsgInitializeExtensionReturn, this );

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::ConstructL - return void" );

    }

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

// CCDSYDOSServerRequestManager::NewL

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

CCDSYDOSServerRequestManager* CCDSYDOSServerRequestManager::NewL( CCDSYController& aCDSYController )

    {

    COM_TRACE_1( "CDSY - CCDSYDOSServerRequestManager::NewL(0x%x)", &aCDSYController );

    CCDSYDOSServerRequestManager* requestManager = new ( ELeave ) CCDSYDOSServerRequestManager( aCDSYController );

    CleanupStack::PushL( requestManager );

    requestManager->ConstructL();

    CleanupStack::Pop( requestManager );

    COM_TRACE_1( "CDSY - CCDSYDOSServerRequestManager::NewL - return 0x%x", requestManager );

    return requestManager;

    }

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

// CCDSYDOSServerRequestManager::ProcessMessageL

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

void CCDSYDOSServerRequestManager::ProcessMessageL( TCDSYMessage& aCDSYMessage )

    {

    COM_TRACE_1( "CDSY - CCDSYDOSServerRequestManager::ProcessMessageL(0x%x)", &aCDSYMessage );

    TUint32 count = 0;

    TBool asyncMessage = EFalse;

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

        {

        // Check the transaction ID's

        if ( ( iMessages[i] )->TransactionID() == aCDSYMessage.TransactionID() )

            {

            // The asyncMessage check is performed before ProcessResponseL

            // is called because ProcessResponseL might clear the async flag

            asyncMessage = iMessages[i]->IsAsyncMessage();

            ( iMessages[i] )->ProcessResponseL( aCDSYMessage );

            count++;

            // Delete the message from the message list

            if ( asyncMessage )

                {

                delete iMessages[i];

                iMessages.Remove( i );

                i--;

                }

            }

        }

    TRACE_ASSERT( count == 1 );

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::ProcessMessageL - return void" );

    }

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

// CCDSYDOSServerRequestManager::SendMessageL

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

void CCDSYDOSServerRequestManager::SendMessageL( TCDSYMessage& aCDSYMessage )

    {

    COM_TRACE_1( "CDSY - CCDSYDOSServerRequestManager::SendMessageL(0x%x)", &aCDSYMessage );

    aCDSYMessage.SetTransactionID( iCDSYController.GetNewTransactionID() );

    CCDSYMessageBufferItem* messageBufferItem = CCDSYMessageBufferItem::NewL( iCDSYController, *this, aCDSYMessage );

    TUint32 count = 0;

#ifdef _DEBUG

    // Check that same transaction id is not in the buffer.

    for ( TInt j = 0; j < iMessages.Count(); j++ )

        {

        if ( ( iMessages[j] )->TransactionID() == aCDSYMessage.TransactionID() )

            {

            count++;

            TRACE_ASSERT( count == 0 );

            }

        }

#endif //#ifdef _DEBUG

    TInt err = iMessages.Append( messageBufferItem );

    if ( err != KErrNone )

        {

        TRACE_ASSERT_ALWAYS;

        delete messageBufferItem;

        User::Leave( err );

        }

    TRAP( err, messageBufferItem->SendMessageL() );

    count = 0;

    // Remove the message from the list.

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

        {

        if ( ( iMessages[i] )->TransactionID() == aCDSYMessage.TransactionID() )

            {

            delete iMessages[i];

            iMessages.Remove( i );

            i--;

            count++;

            }

        }

    TRACE_ASSERT( count <= 1 );

    User::LeaveIfError( err );

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::SendMessageL - return void" );

    }

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

// CCDSYDOSServerRequestManager::SendMessageL

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

void CCDSYDOSServerRequestManager::SendMessageL( TCDSYMessage& aCDSYMessage, RMessagePtr2 aMessage )

    {

    COM_TRACE_2( "CDSY - CCDSYDOSServerRequestManager::SendMessageL(0x%x, 0x%x)", &aCDSYMessage, &aMessage );

    aCDSYMessage.SetTransactionID( iCDSYController.GetNewTransactionID() );

    CCDSYMessageBufferItem* messageBufferItem = CCDSYMessageBufferItem::NewL( iCDSYController, *this, aCDSYMessage, aMessage );

    TUint32 count = 0;

#ifdef _DEBUG

    // Check that same transaction id is not in the buffer.

    for ( TInt j = 0; j < iMessages.Count(); j++ )

        {

        if ( ( iMessages[j] )->TransactionID() == aCDSYMessage.TransactionID() )

            {

            count++;

            TRACE_ASSERT( count == 0 );

            }

        }

#endif //#ifdef _DEBUG

    TInt err = iMessages.Append( messageBufferItem );

    if ( err != KErrNone )

        {

        TRACE_ASSERT_ALWAYS;

        delete messageBufferItem;

        User::Leave( err );

        }

    TRAP( err, messageBufferItem->SendMessageL() );

    if ( err != KErrNone )

        {

        // Remove the message from the list.

        count = 0;

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

            {

            if ( ( iMessages[i] )->TransactionID() == aCDSYMessage.TransactionID() )

                {

                delete iMessages[i];

                iMessages.Remove( i );

                i--;

                count++;

                }

            }

        TRACE_ASSERT( count <= 1 );

        }

    User::LeaveIfError( err );

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::SendMessageL - return void" );

    }

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

// CCDSYDOSServerRequestManager::Cancel

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

void CCDSYDOSServerRequestManager::Cancel( TUint32 aTransactionID, TInt aReason )

    {

    COM_TRACE_2( "CDSY - CCDSYDOSServerRequestManager::Cancel(0x%x, 0x%x)", aTransactionID, aReason );

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

        {

        if ( ( iMessages[i] )->TransactionID() == aTransactionID )

            {

            iMessages[i]->CancelAsyncCommand( aReason );

            delete iMessages[i];

            iMessages.Remove( i );

            i = iMessages.Count();

            }

        }

    COM_TRACE_( "CDSY - CCDSYDOSServerRequestManager::Cancel - return void" );

    }

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

// CCDSYDOSServerRequestManager::ExpireMessageL

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

void CCDSYDOSServerRequestManager::ExpireMessageL( TCDSYMessage& /*aCDSYMessage*/ )

    {

    }