--- a/homescreensrv_plat/sapi_contentpublishing/src/cpclientactivenotifier.cpp	Mon May 03 12:48:45 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,342 +0,0 @@
-/*
-* Copyright (c) 2006 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:  
- *
-*/
-
-
-#include <s32mem.h>
-#include <liwcommon.h>
-#include "cpclientactivenotifier.h"
-#include "ccontentmap.h"
-#include "cpdebug.h"
-#include "cpglobals.h"
-#include "cpserverdef.h"
-#include "cdatasourceinterface.h"
-
-using namespace LIW;
-
-// ======== MEMBER FUNCTIONS ========
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-CCPActiveNotifier* CCPActiveNotifier::NewL( RCPServerClient& aServerClient )
-    {
-    CCPActiveNotifier* self = new( ELeave ) 
-            CCPActiveNotifier ( aServerClient );
-    CleanupStack::PushL( self );
-    self->ConstructL( );
-    CleanupStack::Pop( self );
-    return self;
-    }
-
-// ---------------------------------------------------------------------------
-// destructor
-// ---------------------------------------------------------------------------
-CCPActiveNotifier::~CCPActiveNotifier()
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::CCPActiveNotifier()" ) );
-    Cancel( );
-    iObservers.Close( );
-    delete iObserverBuf;
-    delete iSizeDes;
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::RegisterL( MLiwNotifyCallback* aObserver, 
-		TInt32 aTransactionId, CCPLiwMap* aMap )
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::RegisterL()" ) );
-    TIpcArgs args;
-    
-   	if(iObservers.Find( aTransactionId ))
-   		{
-   		User::Leave( KErrInUse );
-   		}
-    
-   	iObservers.InsertL( aTransactionId, aObserver );
-	delete iObserverBuf;
-	iObserverBuf = NULL;
- 	iObserverBuf = aMap->PackForServerLC( );
-   	CleanupStack::Pop( iObserverBuf );
-   	args.Set( KDescriptorPosition, &*iObserverBuf );
-	args.Set( KTransactionPosition, aTransactionId );
-    
-    if ( !IsActive( ) )
-        {
-        iSizeDes = new (ELeave) TPckgBuf<TInt>( );
-        args.Set( KReturnPosition, iSizeDes );
-        iServerClient.RegisterObserverL( iStatus, args );
-        SetActive( );
-        }
-    else
-        {
-        iServerClient.AddObserver( args );
-        }
-    }
-
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::UnregisterL()
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterL()" ) );
-    if ( !IsActive( ) )
-        {
-        User::Leave( KErrNotFound );
-        }
-    else
-        {
-        Cancel( );
-        delete iSizeDes;
-        iSizeDes = NULL;
-        }
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-TBool CCPActiveNotifier::UnregisterL( TInt32 aTransactionId )
-    {
-    TBool last(EFalse);
-    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterL()" ) );
-
-    MLiwNotifyCallback** observer = iObservers.Find(aTransactionId);
-    if (observer)
-        {
-        CLiwGenericParamList* changeInfoList = 
-                 CLiwGenericParamList::NewL( );
-        CleanupStack::PushL( changeInfoList );
-        CLiwGenericParamList* inParamList = CLiwGenericParamList::NewL( );
-        CleanupStack::PushL( inParamList );
-        
-        changeInfoList->AppendL(TLiwGenericParam(EGenericParamError,
-                TLiwVariant(CDataSourceInterface::ErrCodeConversion(KErrNone))));
-        changeInfoList->AppendL(TLiwGenericParam(KErrorCode, TLiwVariant(
-                CDataSourceInterface::ErrCodeConversion(KErrNone))));
-        
-		(*observer)->HandleNotifyL( aTransactionId, KLiwEventCanceled, *changeInfoList,
-            *inParamList );     
-        
-        CleanupStack::PopAndDestroy( inParamList );
-        CleanupStack::PopAndDestroy( changeInfoList );
-        }
-    else
-        {
-        User::Leave(KErrNotFound);
-        }
-    
-    TIpcArgs args;
-	args.Set( KTransactionPosition, aTransactionId );
-    iServerClient.RemoveObserver( args );
-
-    iObservers.Remove( aTransactionId );
-        
-	if( !iObservers.Count() )
-		{
-		UnregisterL();
-		last = ETrue;
-		}
-	return last;
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::UnregisterAllL(  )
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterAllL()" ) );
-    if (!iObservers.Count())
-    	{
-    	User::Leave( KErrNotFound );
-    	}
-    THashMapIter<TInt32, MLiwNotifyCallback*> iter( iObservers );
-    const TInt32* transaction = iter.NextKey();
-    while( transaction )
-        {
-        UnregisterL( *transaction );
-        transaction = iter.NextKey( );
-        }    
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::RunL()
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::RunL()" ) );
-    CLiwGenericParamList* eventParamList = CLiwGenericParamList::NewL();
-    CleanupStack::PushL(eventParamList);
-
-    TInt error = iStatus.Int();
-    if (KErrNone == error)
-        {
-        RBuf8 outbuf;
-        outbuf.CleanupClosePushL();
-        outbuf.CreateL((*iSizeDes)());
-        error = iServerClient.GetChangeInfoData(outbuf);
-        RDesReadStream stream(outbuf);
-        CleanupClosePushL(stream);
-        eventParamList->InternalizeL(stream);
-        CleanupStack::PopAndDestroy(&stream);
-        delete iSizeDes;
-        iSizeDes = NULL;
-        CleanupStack::PopAndDestroy(&outbuf);
-        }
-    RegisterAgainL();
-
-    NotifyObserversL(error, eventParamList);
-    CleanupStack::PopAndDestroy(eventParamList);
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::NotifyObserversL( TInt aErrorCode, 
-		CLiwGenericParamList* aEventParamList  )
-	{
-    TInt event( KLiwEventInProgress );
-    if ( aErrorCode == KErrCancel )
-        {
-        event = KLiwEventCanceled;
-        }
-    else if ( aErrorCode != KErrNone )
-        {
-        event = KLiwEventStopped;
-        }	
- 
-    for ( TInt i = 0; i<aEventParamList->Count(); i++ )
-    	{
-    	TLiwGenericParam param;
-    	param.PushL();
-    	TLiwVariant mapsV;
-    	mapsV.PushL();
-    	aEventParamList->AtL( i, param );
-    	mapsV = param.Value();
-    	CLiwDefaultList* listOfMatchingMaps = CLiwDefaultList::NewLC( );
-    	if (mapsV.Get( *listOfMatchingMaps ))
-    		{
-    		TLiwVariant transV;
-    		transV.PushL();
-    		TInt transIndex (listOfMatchingMaps->Count()-1);
-    		listOfMatchingMaps->AtL(transIndex ,transV);
-    		TInt32 transactionId ( KErrNotFound );
-    		transV.Get( transactionId );
-    		MLiwNotifyCallback** observer = iObservers.Find( transactionId );
-    		
-    		if ( observer )
-    			{
-    			listOfMatchingMaps->Remove( transIndex );
-    			CLiwGenericParamList* changeInfoList = 
-											CLiwGenericParamList::NewL( );
-    			CleanupStack::PushL( changeInfoList );
-    		    CLiwGenericParamList* inParamList = CLiwGenericParamList::NewL( );
-    		    CleanupStack::PushL( inParamList );
-    			
-    			changeInfoList->AppendL( TLiwGenericParam( KChangeInfo,
-    							TLiwVariant( listOfMatchingMaps ) ) );
-    			
-    			changeInfoList->AppendL( TLiwGenericParam( EGenericParamError,
-    			    TLiwVariant( CDataSourceInterface::ErrCodeConversion( aErrorCode ) ) ) );
-    			changeInfoList->AppendL( TLiwGenericParam( KErrorCode,
-    			    TLiwVariant( CDataSourceInterface::ErrCodeConversion( aErrorCode ) ) ) );
-    			(*observer)->HandleNotifyL( transactionId, event, *changeInfoList,
-    			        *inParamList );
-    			
-    		    CleanupStack::PopAndDestroy( inParamList );
-    		    CleanupStack::PopAndDestroy( changeInfoList );
-    			}//if
-
-    		CleanupStack::PopAndDestroy( &transV );
-    		}//if
-    	CleanupStack::PopAndDestroy( listOfMatchingMaps );
-    	CleanupStack::PopAndDestroy( &mapsV );
-    	CleanupStack::PopAndDestroy( &param );
-    	}//for
-	}
-
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::DoCancel()
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::DoCancel()" ) );
-    iServerClient.UnregisterObserver( );
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-TInt CCPActiveNotifier::RunError( TInt /*aError*/)
-    {
-    TRAP_IGNORE( RegisterAgainL( ) );
-    return KErrNone;
-    }
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-CCPActiveNotifier::CCPActiveNotifier( RCPServerClient& aServerClient ) :
-    CActive(EPriorityStandard)
-    {
-    iServerClient = aServerClient;
-    CActiveScheduler::Add( this );
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::ConstructL()
-    {
-
-    }
-
-// ----------------------------------------------------------------------------
-//
-// ----------------------------------------------------------------------------
-//
-void CCPActiveNotifier::RegisterAgainL()
-    {
-    CP_DEBUG( _L8("CCPActiveNotifier::RegisterAgainL()" ) );
-
-    if (!IsActive())
-        {
-        TIpcArgs args;
-        args.Set(KTransactionPosition, KErrAlreadyExists);
-        if (iSizeDes)
-            {
-            delete iSizeDes;
-            iSizeDes = NULL;
-            }
-        iSizeDes = new (ELeave) TPckgBuf<TInt> ();
-        args.Set(KReturnPosition, iSizeDes);
-        iServerClient.RegisterObserverL(iStatus, args);
-        SetActive();
-        }
-    }