--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dosservices/commondsy/src/CDSYController.cpp	Tue Feb 02 00:53:00 2010 +0200
@@ -0,0 +1,283 @@
+/*
+* 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 CCDSYController class
+*
+*/
+
+
+// INCLUDE FILES 
+#include "CDSYController.h"
+#include "CDSYMessage.h"
+#include "CDSYServiceLogic.h"
+#include "CDSYMessagesServiceLogic.h"
+#include "commondsy_debug.h"
+
+
+// EXTERNAL DATA STRUCTURES
+// EXTERNAL FUNCTION PROTOTYPES  
+// CONSTANTS
+const TInt KServiceLogicArrayGranularity = 100;
+
+// MACROS
+// LOCAL CONSTANTS AND MACROS
+// MODULE DATA STRUCTURES
+// LOCAL FUNCTION PROTOTYPES
+// FORWARD DECLARATIONS
+
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::CCDSYController
+// -----------------------------------------------------------------------------
+CCDSYController::CCDSYController()
+: iCurrentTransactionID( 0 )
+, iServiceLogics( KServiceLogicArrayGranularity )
+    {
+    COM_TRACE_( "CDSY - CCDSYController::CCDSYController()" );
+    COM_TRACE_( "CDSY - CCDSYController::CCDSYController - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::~CCDSYController
+// -----------------------------------------------------------------------------
+CCDSYController::~CCDSYController()
+    {
+    COM_TRACE_( "CDSY - CCDSYController::~CCDSYController()" );
+
+    iServiceLogics.ResetAndDestroy();
+
+    COM_TRACE_( "CDSY - CCDSYController::~CCDSYController - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::NewL
+// -----------------------------------------------------------------------------
+CCDSYController* CCDSYController::NewL()
+    {
+    COM_TRACE_( "CDSY - CCDSYController::NewL()" );
+
+    CCDSYController* controller = new ( ELeave ) CCDSYController();
+
+    COM_TRACE_1( "CDSY - CCDSYController::NewL - return 0x%x", controller );
+    return controller;
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::ProcessMessageL
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::ProcessMessageL( TCDSYMessage& aCDSYMessage )
+    {
+    COM_TRACE_1( "CDSY - CCDSYController::ProcessMessageL(0x%x)", &aCDSYMessage );
+
+    TUint count = 0;
+    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )
+        {
+        if ( ( ( iServiceLogics[i] )->MessageGroup() == aCDSYMessage.Group() )
+            && ( ( iServiceLogics[i] )->MessageID() == aCDSYMessage.ID() )
+            && ( ( ( iServiceLogics[i] )->DynamicRegistration() == EFalse )
+                || ( ( ( iServiceLogics[i] )->DynamicRegistration() )
+                    && ( ( iServiceLogics[i] )->MessageTransactionID() == aCDSYMessage.TransactionID() ) ) ) )
+            {
+            count++;
+            ( ( iServiceLogics[i] )->CDSYServiceLogic() )->ProcessMessageL( aCDSYMessage );
+            }
+        }
+    TRACE_ASSERT( count > 0 );
+    TRACE_ASSERT( count < 2 );
+   
+    COM_TRACE_( "CDSY - CCDSYController::ProcessMessageL - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::RegisterServiceLogicL
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::RegisterServiceLogicL( const TUint32 aMessageGroup, const TUint32 aMessageID, MCDSYServiceLogic* aCDSYServiceLogic )
+    {
+    COM_TRACE_3( "CDSY - CCDSYController::RegisterServiceLogicL(0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aCDSYServiceLogic );
+
+#ifdef _DEBUG
+
+    // Check that this hasn't been already registered
+    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )
+        {
+        if ( ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )
+            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )
+            {
+            TRACE_ASSERT_ALWAYS;
+            }
+        }
+
+#endif //#ifdef _DEBUG
+
+    CCDSYMessagesServiceLogic* serviceLogic = CCDSYMessagesServiceLogic::NewL( aMessageGroup, aMessageID, aCDSYServiceLogic );
+    TInt err = iServiceLogics.Append( serviceLogic );
+    if ( err != KErrNone )
+        {
+        TRACE_ASSERT_ALWAYS;
+        delete serviceLogic;
+        User::Leave( err );
+        }
+     
+    COM_TRACE_( "CDSY - CCDSYController::RegisterServiceLogicL - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::RegisterServiceLogicL
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::RegisterServiceLogicL( const TUint32 aMessageGroup, const TUint32 aMessageID, const TUint32 aTransactionID, MCDSYServiceLogic* aCDSYServiceLogic )
+    {
+    COM_TRACE_4( "CDSY - CCDSYController::RegisterServiceLogicL(0x%x, 0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );
+
+#ifdef _DEBUG
+
+    // Check that this hasn't been already registered
+    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )
+        {
+        if ( ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )
+            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )
+            {
+            TRACE_ASSERT_ALWAYS;
+            }
+        }
+
+#endif //#ifdef _DEBUG
+
+    CCDSYMessagesServiceLogic* serviceLogic = CCDSYMessagesServiceLogic::NewL( aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );
+    TInt err = iServiceLogics.Append( serviceLogic );
+    if ( err != KErrNone )
+        {
+        TRACE_ASSERT_ALWAYS;
+        delete serviceLogic;
+        User::Leave( err );
+        }
+   
+    COM_TRACE_( "CDSY - CCDSYController::RegisterServiceLogicL - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::UnregisterServiceLogic
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::UnregisterServiceLogic( const TUint32 aMessageGroup, const TUint32 aMessageID, const MCDSYServiceLogic* aCDSYServiceLogic )
+    {
+    COM_TRACE_3( "CDSY - CCDSYController::UnregisterServiceLogic(0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aCDSYServiceLogic );
+
+    for ( TInt i = iServiceLogics.Count() - 1; i >= 0; i-- )
+        {
+        if ( ( ( iServiceLogics[i] )->CDSYServiceLogic() == aCDSYServiceLogic )
+            && ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )
+            && ( ( iServiceLogics[i] )->MessageID() == aMessageID ) )
+            {
+            delete iServiceLogics[i];
+            iServiceLogics.Remove( i );
+            i = -1;
+            }
+        }
+
+    COM_TRACE_( "CDSY - CCDSYController::UnregisterServiceLogic - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::UnregisterServiceLogic
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::UnregisterServiceLogic( const TUint32 aMessageGroup, const TUint32 aMessageID, const TUint32 aTransactionID, const MCDSYServiceLogic* aCDSYServiceLogic )
+    {
+    COM_TRACE_4( "CDSY - CCDSYController::UnregisterServiceLogic(0x%x, 0x%x, 0x%x, 0x%x)", aMessageGroup, aMessageID, aTransactionID, aCDSYServiceLogic );
+
+    for ( TInt i = iServiceLogics.Count() - 1; i >= 0; i-- )
+        {
+        if ( ( ( iServiceLogics[i] )->CDSYServiceLogic() == aCDSYServiceLogic )
+            && ( ( iServiceLogics[i] )->MessageGroup() == aMessageGroup )
+            && ( ( iServiceLogics[i] )->MessageID() == aMessageID )
+            && ( ( iServiceLogics[i] )->MessageTransactionID() == aTransactionID ) )
+            {
+            delete iServiceLogics[i];
+            iServiceLogics.Remove( i );
+            i = -1;
+            }
+        }
+
+    COM_TRACE_( "CDSY - CCDSYController::UnregisterServiceLogic - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::ExpireMessageL
+// -----------------------------------------------------------------------------
+EXPORT_C void CCDSYController::ExpireMessageL( TCDSYMessage& aCDSYMessage )
+    {
+    COM_TRACE_1( "CDSY - CCDSYController::ExpireMessageL(0x%x)", &aCDSYMessage );
+
+    TUint count = 0;
+    for ( TInt i = 0; i < iServiceLogics.Count(); i++ )
+        {
+        if((((iServiceLogics[i])->MessageGroup() == aCDSYMessage.Group())
+                && ((iServiceLogics[i])->MessageID() == aCDSYMessage.ID())
+                && ((iServiceLogics[i])->DynamicRegistration() == EFalse))
+            || (((iServiceLogics[i])->DynamicRegistration() != EFalse)
+                && ((iServiceLogics[i])->MessageTransactionID() == aCDSYMessage.TransactionID())))
+            {
+            count++;
+            ( ( iServiceLogics[i] )->CDSYServiceLogic() )->ExpireMessageL( aCDSYMessage );
+            }
+        if(((iServiceLogics[i])->DynamicRegistration() != EFalse)
+            && ((iServiceLogics[i])->MessageTransactionID() == aCDSYMessage.TransactionID()))
+            {
+            delete iServiceLogics[i];
+            iServiceLogics.Remove( i );
+            i--;
+            }
+        }
+    TRACE_ASSERT( count > 0 );
+    TRACE_ASSERT( count < 2 );
+
+    COM_TRACE_( "CDSY - CCDSYController::ExpireMessageL - return void" );
+    }
+
+
+
+// -----------------------------------------------------------------------------
+// CCDSYController::GetNewTransactionID
+// -----------------------------------------------------------------------------
+EXPORT_C TUint8 CCDSYController::GetNewTransactionID()
+    {
+    COM_TRACE_( "CDSY - CCDSYController::GetNewTransactionID()" );
+
+    iCurrentTransactionID++;
+
+    COM_TRACE_1( "CDSY - CCDSYController::GetNewTransactionID - return 0x%x", iCurrentTransactionID );
+    return iCurrentTransactionID;
+    }
+