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

equal deleted inserted replaced

-:a0713522ab97
+:b276298d5729
 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
 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();
 // Activate the publisher
 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::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
 //
 // ---------------------------------------------------------------------------
 //
 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 16	b276298d5729
parent 15	a0713522ab97
child 19	edd621764147