MCL/sf/mw/homescreensrv: comparison idlefw/plugins/wrtdataplugin/src/wrtdataplugin.cpp

equal deleted inserted replaced

-:c2817bb2a55c
+:cb506ec2d869
 #include <aicontentobserver.h>
 #include <aiutility.h>
 #include <aipspropertyobserver.h>
 #include <aipluginsettings.h>
 #include <activeidle2domainpskeys.h>
+#include <debug.h>
 #include "wrtdatapluginconst.h"
 #include "wrtdatapluginuids.hrh"
 #include "wrtdataplugin.h"
 #include "wrtdata.h"
 // Constants
 const TImplementationProxy KImplementationTable[] =
 {
 IMPLEMENTATION_PROXY_ENTRY( KImplUidDataPlugin, CWrtDataPlugin::NewL )
 };
+const TInt KTryAgainDelay( 3000000 ); // 3 sec
 // ======== MEMBER FUNCTIONS ========
 // ---------------------------------------------------------------------------
 // ImplementationGroupProxy
 //
 // Deletes all data created to heap
 // ---------------------------------------------------------------------------
 //
 CWrtDataPlugin::~CWrtDataPlugin()
 {
+if ( iTimer )
+{
+iTimer->Cancel();
+delete iTimer;
+}
 delete iData;
 iObservers.Close();
 Release( iContent );
 iDataArray.ResetAndDestroy();
 void CWrtDataPlugin::Start( TStartReason aReason )
 {
 if( aReason == ESystemStartup ||
 aReason == EPluginStartup )
 {
-// publish the initial data
+// Publish the initial data
-TRAP_IGNORE( PublishL());
+TRAP_IGNORE( PublishInitialDataL() );
 }
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::Stop
 void CWrtDataPlugin::Stop( TStopReason aReason )
 {
 if( aReason == EPluginShutdown ||
 aReason == ESystemShutdown )
 {
-TRAP_IGNORE(iData->DeActivateL());
+TRAP_IGNORE(iData->NotifyPublisherL( KDeActive ));
 }
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::Resume
 {
 if ( aReason == EForeground )
 {
 iPluginState = EResume;
-TRAP_IGNORE( iData->ResumeL() );
+TRAP_IGNORE( iData->NotifyPublisherL( KResume ));
 }
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::Suspend
 {
 if ( aReason == EBackground )
 {
 iPluginState = ESuspend;
-TRAP_IGNORE ( iData->SuspendL() );
+TRAP_IGNORE ( iData->NotifyPublisherL( KSuspend ));
 }
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::SetOnline
 //
 // ----------------------------------------------------------------------------
 //
 void CWrtDataPlugin::SetOnline()
 {
-if ( iNetworkStatus != EOnline )
+iNetworkStatus = EOnline;
-{
+TRAP_IGNORE( iData->NotifyPublisherL( KOnLine ));
-iNetworkStatus = EOnline;
-TRAP_IGNORE( iData->OnLineL() );
-}
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::SetOffline
 //
 // ----------------------------------------------------------------------------
 //
 void CWrtDataPlugin::SetOffline()
 {
-if ( iNetworkStatus != EOffline )
+iNetworkStatus = EOffline;
-{
+TRAP_IGNORE( iData->NotifyPublisherL( KOffLine ));
-iNetworkStatus = EOffline;
-TRAP_IGNORE( iData->OffLineL() );
-}
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::SubscribeL
 //
 return;
 }
 RAiSettingsItemArray contentItemsArr;
 RAiSettingsItemArray configurationItemsArr;
-RAiSettingsItemArray settingItemsArr;
 TInt count( aSettings.Count() );
 for ( TInt i = 0; i < count; i++ )
 {
 MAiPluginSettings* setting( aSettings[i] );
 contentItemsArr.Append( setting );
 }
 else if( setting->AiPluginItemType() == EAiPluginConfigurationItem )
 {
 configurationItemsArr.Append( setting );
-}
-else
-{
-settingItemsArr.Append( setting );
 }
 }
 iDataCount = contentItemsArr.Count();
 // Register for notifications
 iData->RegisterL();
 // Activate the publisher
-iData->ActivateL();
+iData->NotifyPublisherL( KActive );
 }
-settingItemsArr.Reset();
 contentItemsArr.Reset();
 configurationItemsArr.Reset();
+// We own the array so destroy it
-// We own the array so destroy it
 aSettings.ResetAndDestroy();
+}
+// ----------------------------------------------------------------------------
+// CWrtDataPlugin::SetProperty
+//
+// ----------------------------------------------------------------------------
+//
+void CWrtDataPlugin::SetProperty( TProperty aProperty, TAny* aAny )
+{
+if (aProperty == ECpsCmdBuffer )
+{
+iData->SetCommandBuffer( aAny, PublisherInfo().Namespace() );
+}
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::GetProperty
 //
 //
 void CWrtDataPlugin::HandleEvent( const TDesC& aEventName,
 const TDesC& aParam )
 {
 TRAP_IGNORE( iData->ExecuteActionL( aEventName , aParam ) );
-}
-// ----------------------------------------------------------------------------
-// CWrtDataPlugin::HasMenuItem
-//
-// ----------------------------------------------------------------------------
-//
-TBool CWrtDataPlugin::HasMenuItem( const TDesC& aMenuItem )
-{
-return iData->HasMenuItem ( aMenuItem );
 }
 // ----------------------------------------------------------------------------
 // CWrtDataPlugin::IsActive
 //
 }
 CleanupStack::PopAndDestroy( objectId );
 }
 // ---------------------------------------------------------------------------
-//Refresh a specific image of text in the widget
+//Refresh a specific image or text in the widget
 // ---------------------------------------------------------------------------
 //
 void CWrtDataPlugin::RefreshL( TDesC16& aOperation, CLiwDefaultMap* aDataMap )
 {
+__PRINTS("*** CWrtDataPlugin::RefreshL ***");
+__PRINT( __DBG_FORMAT( "* Publisher name: %S, uid: 0x%x, operation: %S" ),
+&PublisherInfo().Name(), PublisherInfo().Uid().iUid, &aOperation );
 TInt observers( iObservers.Count() );
 TInt transactionId = reinterpret_cast<TInt>( this );
 for ( TInt obsIndex = 0; obsIndex < observers; obsIndex++ )
 {
 // Relese memory of the published text
 iDataArray.ResetAndDestroy();
 // Release memory of the published icons
 iIconArray.Reset();
 }
+__PRINTS("*** CWrtDataPlugin::RefreshL - done ***");
 }
 // ---------------------------------------------------------------------------
 // Publish a specific text of the widget
 // ---------------------------------------------------------------------------
 // ---------------------------------------------------------------------------
 //
 void CWrtDataPlugin::HideLoadingIcon(MAiContentObserver* aObserver)
 {
 aObserver->SetProperty( *this, KElement , KDisplay , KHide );
+// Do not try to publish initial data anymore
+StopTimer();
 }
 // ---------------------------------------------------------------------------
 // Publishes widget's texts and images
 // ---------------------------------------------------------------------------
 //
-void CWrtDataPlugin::PublishL()
+void CWrtDataPlugin::PublishInitialDataL()
 {
 TInt observers( iObservers.Count() );
 TInt transactionId = reinterpret_cast<TInt>( this );
 for ( int i = 0; i < observers; i++ )
 {
 MAiContentObserver* observer = iObservers[i];
+CleanupStack::PushL( TCleanupItem( CancelTransaction, observer ) );
 if ( observer->StartTransaction( transactionId ) == KErrNone )
 {// Publish default data
-iData->PublishDefaultImageL(observer);
+iData->PublishInitialDataL(observer);
 observer->Commit( transactionId );
 }
+		CleanupStack::Pop( observer );
 // Release memory of the published text
 iDataArray.ResetAndDestroy();
 // Release memory of the published icons
 iIconArray.Reset();
 }
 }
 return (error == KErrNone );
 }
+// ---------------------------------------------------------------------------
+// Cleanup callback for cancelling a transactions in case of leave
+// ---------------------------------------------------------------------------
+//
+void CWrtDataPlugin::CancelTransaction( TAny* aObserver )
+{
+if ( aObserver )
+{
+MAiContentObserver* obs = reinterpret_cast< MAiContentObserver*>( aObserver );
+TInt transactionId = reinterpret_cast<TInt>( aObserver );
+obs->CancelTransaction( transactionId );
+}
+}
+// ---------------------------------------------------------------------------
+// Create and start republish timer
+// ---------------------------------------------------------------------------
+//
+void CWrtDataPlugin::StartTimer()
+{
+TRAP_IGNORE(
+if ( !iTimer )
+{
+iTimer = CPeriodic::NewL( CActive::EPriorityStandard );
+}
+if ( !iTimer->IsActive() )
+{
+TTimeIntervalMicroSeconds32 delay( KTryAgainDelay );
+iTimer->Start( delay, delay, TCallBack( Timeout, this ) );
+}
+);
+}
+// ---------------------------------------------------------------------------
+// Cancel republish timer
+// ---------------------------------------------------------------------------
+//
+void CWrtDataPlugin::CancelTimer()
+{
+if ( iTimer )
+{
+iTimer->Cancel();
+}
+}
+// ---------------------------------------------------------------------------
+// Stop and delete republish timer
+// ---------------------------------------------------------------------------
+//
+void CWrtDataPlugin::StopTimer()
+{
+if ( iTimer )
+{
+iTimer->Cancel();
+delete iTimer;
+iTimer = NULL;
+}
+}
+// ---------------------------------------------------------------------------
+// Initial data republish callback
+// ---------------------------------------------------------------------------
+//
+TInt CWrtDataPlugin::Timeout( TAny* aPtr )
+{
+CWrtDataPlugin* self = static_cast<CWrtDataPlugin*>( aPtr );
+// Cancel timer before publishing
+self->CancelTimer();
+TInt observers( self->iObservers.Count() );
+TInt transactionId = reinterpret_cast<TInt>( self );
+TBool success( ETrue );
+// Publish for each observer
+for ( int i = 0; i < observers; i++ )
+{
+MAiContentObserver* observer = self->iObservers[i];
+if ( observer->StartTransaction( transactionId ) == KErrNone )
+{
+// Publish default image
+TRAPD( err, self->iData->PublishDefaultImageL( observer ) );
+if ( KErrNone != err )
+{
+observer->CancelTransaction( transactionId );
+success = EFalse;
+}
+else
+{
+//
+observer->Commit( transactionId );
+}
+}
+}
+// Start timer again if there is error in publishing
+if ( !success )
+{
+self->StartTimer();
+}
+else
+{
+self->StopTimer();
+}
+// Release memory of the published icons
+self->iIconArray.Reset();
+return KErrNone;
+}
 // End of file

branch	RCL_3
changeset 17	cb506ec2d869
parent 16	b276298d5729
child 19	edd621764147