/*

* Copyright (c) 2002-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:  Subsession handles are stored here for later handling

*

*/

// INCLUDE FILES

#include "AccSrvNotificationQueue.h"

#include "acc_debug.h"

#include "AccSrvSubAudioControl.h" //for callbacks

// EXTERNAL DATA STRUCTURES

// EXTERNAL FUNCTION PROTOTYPES

// CONSTANTS

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

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

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

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

// CAccSrvNotificationQueue::CAccSrvNotificationQueue

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CAccSrvNotificationQueue::CAccSrvNotificationQueue()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CAccSrvNotificationQueue()" );

    }

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

// CAccSrvNotificationQueue::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CAccSrvNotificationQueue::ConstructL()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::ConstructL()" );

    }

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

// CAccSrvNotificationQueue::NewL

// Two-phased constructor.

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

//

CAccSrvNotificationQueue* CAccSrvNotificationQueue::NewL()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::NewL()" );

    CAccSrvNotificationQueue* self = new( ELeave ) CAccSrvNotificationQueue;

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop( self );

    return self;

    }

// Destructor

CAccSrvNotificationQueue::~CAccSrvNotificationQueue()

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::~CAccSrvNotificationQueue()" );

    iConnectAccessory.Close();

    iAccessoryAudioLinkOpenArray.Close();

    iAccessoryAudioLinkOpenedArray.Close();

    iAccessoryAudioLinkClosedArray.Close();

    iAccessoryAudioLinkCloseArray.Close();

    iBluetoothAudioLinkOpenReqArray.Close();

    iBluetoothAudioLinkCloseReqArray.Close();

    iBluetoothAudioLinkOpenRespArray.Close();

    iBluetoothAudioLinkCloseRespArray.Close();

    iNewAccessoryConnectedArray.Close();

    iAccessoryConnectionStatusChangedArray.Close();

    iGetAccessoryConnectionStatusAsyncArray.Close();

    iAccessoryDisconnectedArray.Close();

    iAccessoryModeChangedArray.Close();

    iGetAccessoryModeAsyncArray.Close();

    iNotifyProcessCommandArray.Close();

    iNotifyAccessoryValueChangedTBoolArray.Close();

    iNotifyAccessoryValueChangedTIntArray.Close();

    iNotifyAccessoryValueChangedObjectArray.Close();

    iSetValueArray.Close();

    iGetValueArray.Close();

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::~CAccSrvNotificationQueue - return" );

    }

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

// CAccSrvNotificationQueue::ControlMessageArray(

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

//

RArray<MQueueObserver*>* CAccSrvNotificationQueue::ControlMessageArray( TMsgID aMsgID )

    {

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::ControlMessageArray(0x%x)", aMsgID );

    switch ( aMsgID )

        {

        case EConnectAccessory:

            {

            return &iConnectAccessory;

            }

        case ENewAccessoryConnected:

            {

            return &iNewAccessoryConnectedArray;

            }

        case EAccessoryDisconnected:

            {

            return &iAccessoryDisconnectedArray;

            }

        case EAccessoryModeChanged:

            {

            return &iAccessoryModeChangedArray;

            }

        case EAccessoryConnectionStatusAsyncChanged:

            {

            return &iGetAccessoryConnectionStatusAsyncArray;

            }

        case EAccessoryModeAsyncChanged:

            {

            return &iGetAccessoryModeAsyncArray;

            }

        case EAccessoryConnectionStatusChanged:

            {

            return &iAccessoryConnectionStatusChangedArray;

            }

        case EAccessoryValueChangedTBool:

            {

            return &iNotifyAccessoryValueChangedTBoolArray;

            }

        case EAccessoryValueChangedTInt:

            {

            return &iNotifyAccessoryValueChangedTIntArray;

            }

        case EAccessoryValueChangedObject:

            {

            return &iNotifyAccessoryValueChangedObjectArray;

            }

        case EAccessoryAudioLinkOpen:

            {

            return &iAccessoryAudioLinkOpenArray;

            }

        case EAccessoryAudioLinkOpened:

            {

            return &iAccessoryAudioLinkOpenedArray;

            }

        case EAccessoryAudioLinkClosed:

            {

            return &iAccessoryAudioLinkClosedArray;

            }

        case EAccessoryAudioLinkClose:

            {

            return &iAccessoryAudioLinkCloseArray;

            }

        case EBluetoothAudioLinkOpenReq:

            {

            return &iBluetoothAudioLinkOpenReqArray;

            }

        case EBluetoothAudioLinkCloseReq:

            {

            return &iBluetoothAudioLinkCloseReqArray;

            }

        case EBluetoothAudioLinkOpenResp:

            {

            return &iBluetoothAudioLinkOpenRespArray;

            }

        case EBluetoothAudioLinkCloseResp:

            {

            return &iBluetoothAudioLinkCloseRespArray;

            }

        case ENotifyProcessCommand:

            {

            return &iNotifyProcessCommandArray;

            }

        case ESetValue:

            {

            return &iSetValueArray;

            }

        case EGetValue:

            {

            return &iGetValueArray;

            }

        default:

            {

            // Unknown notification type

            PANIC_ALWAYS;

            }

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::ControlMessageArray - return NULL" );

    return NULL;

    }

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

// CAccSrvNotificationQueue::RegisterControlMessage

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

//

void CAccSrvNotificationQueue::RegisterControlMessage( TMsgID aMsgID,

                                                       MQueueObserver* aCallback )

    {

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::RegisterControlMessage(%d)", aMsgID );

    ControlMessageArray( aMsgID )->Append( aCallback );

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::RegisterControlMessage - return void" );

    }

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

// CAccSrvNotificationQueue::CancelControlMessage

//

// Find the correct array and remove corresponding element (aCallback) from it.

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

//

void CAccSrvNotificationQueue::CancelControlMessage( TMsgID aMsgID,

                                                     MQueueObserver* aCallback )

    {

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::CancelNotificationRequest(%d)", aMsgID );

    TInt index( ControlMessageArray( aMsgID )->Find( aCallback ) );

    if ( KErrNotFound != index )

        {

        ControlMessageArray( aMsgID )->Remove( index );

        }

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::CancelNotificationRequest - %d return void", index );

    }

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

// CAccSrvNotificationQueue::CompleteControlMessageL

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

//

void CAccSrvNotificationQueue::CompleteControlMessageL( TMsgID aMsgID,

                                                        TInt aErrorCode,

                                                        TInt aUniqueID )

    {

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteControlMessageL(%d)", aMsgID );

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        if ( ControlMessageArray( aMsgID )->operator[]( i )->CompleteMessageL( 

                                                                aMsgID, 

                                                                aErrorCode, 

                                                                aUniqueID ) )

            {

            ControlMessageArray( aMsgID )->Remove( i );

            }

        else

            {

            // Message was not consumed by subsession in question,

            // leave it to queue

            }

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteControlMessageL - return void" );

    }

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

// CAccSrvNotificationQueue::CompleteASYCmdL

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

//

void CAccSrvNotificationQueue::CompleteASYCmdL( TMsgID aMsgID,

                                                TProcessCmdId aCmdn,

                                                TInt aTrId,

                                                TASYCommandParamRecord& aASYCommandParamRecord,

                                                TPtr8* aPtrBuf )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteASYCmdL()" );

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        if ( ControlMessageArray( aMsgID )->operator[]( i )->CompleteProcessCommandL( 

                                                                aCmdn, 

                                                                aTrId, 

                                                                aASYCommandParamRecord,

                                                                aPtrBuf ) )

            {

            ControlMessageArray( aMsgID )->Remove( i );

            }

        else

            {

            // Message was not consumed by subsession in question,

            // leave it to queue

            }

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteASYCmdL return void" );

    }

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

// CAccSrvNotificationQueue::CompleteValueMessageL

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

//

void CAccSrvNotificationQueue::CompleteValueMessageL( TMsgID aMsgID,

                                                      TAccValueTypeTBool aCmdResponse,

                                                      TInt aErrorCode,

                                                      TInt aTrId )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL() - TBool" );

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        ControlMessageArray( aMsgID )->operator[]( i )->HandleValueMessageL( 

                                                            aMsgID, 

                                                            aCmdResponse, 

                                                            aErrorCode, 

                                                            aTrId );

        ControlMessageArray( aMsgID )->Remove( i );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL - TBool - return void" );

    }

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

// CAccSrvNotificationQueue::CompleteValueMessageL

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

//

void CAccSrvNotificationQueue::CompleteValueMessageL( TMsgID aMsgID,

                                                      TAccValueTypeTInt aCmdResponse,

                                                      TInt aErrorCode,

                                                      TInt aTrId )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL() - TInt" );

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        ControlMessageArray( aMsgID )->operator[]( i )->HandleValueMessageL( 

                                                            aMsgID, 

                                                            aCmdResponse,

                                                            aErrorCode, 

                                                            aTrId );

        ControlMessageArray( aMsgID )->Remove( i );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL - TInt- return void" );

    }

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

// CAccSrvNotificationQueue::CompleteValueMessageL

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

//

void CAccSrvNotificationQueue::CompleteValueMessageL( TMsgID aMsgID,

                                                      TDesC8& aCmdResponse,

                                                      TInt aErrorCode,

                                                      TInt aTrId )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL() - TDesC8" );

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        ControlMessageArray( aMsgID )->operator[]( i )->HandleValueMessageL( 

                                                            aMsgID, 

                                                            aCmdResponse, 

                                                            aErrorCode, 

                                                            aTrId );

        ControlMessageArray( aMsgID )->Remove( i );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL - TDesC8 - return void" );

    }

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

// CAccSrvNotificationQueue::CompleteValueMessageL

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

//

void CAccSrvNotificationQueue::CompleteValueMessageL( TMsgID aMsgID,

                                                      TInt aTrId,

                                                      TPtr8* aPtrBuf,

                                                      TInt aErrorCode )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL() - Object" );    

    for ( TInt i( ControlMessageArray( aMsgID )->Count()-1 ); i >= 0; --i )

        {

        ControlMessageArray( aMsgID )->operator[]( i )->HandleValueMessageL( 

                                                            aMsgID, 

                                                            aTrId,

                                                            aPtrBuf, 

                                                            aErrorCode );

        ControlMessageArray( aMsgID )->Remove( i );

        }

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::CompleteValueMessageL - Object - return void" );

    }

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

// CAccSrvNotificationQueue::ControlMessagesWaiting

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

//

TInt CAccSrvNotificationQueue::ControlMessagesWaiting( TMsgID aMsgID )

    {

    COM_TRACE_( "[AccFW:AccServer] CAccSrvNotificationQueue::ControlMessagesWaiting()" );

    TInt ret( ControlMessageArray( aMsgID )->Count() );

    COM_TRACE_1( "[AccFW:AccServer] CAccSrvNotificationQueue::ControlMessagesWaiting - return %d", ret );

    return ret;

    }

//  End of File