activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp
changeset 94 dbb8300717f7
parent 93 82b66994846c
--- a/activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp	Fri Apr 30 15:22:08 2010 +0300
+++ b/activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp	Fri May 14 17:24:44 2010 +0300
@@ -23,7 +23,9 @@
 //
 // -----------------------------------------------------------------------------
 //
-void ActivityStorageSyncTask::ExecuteL(CActivityStorage& dataStorage, const RMessage2& msg)
+void ActivityStorageSyncTask::ExecuteL(MActivityTaskStorage& observers,
+                                       CActivityStorage& dataStorage, 
+                                       const RMessage2& msg)
 {
     switch (msg.Function()) {
     case AddActivity: 
@@ -43,6 +45,7 @@
         User::Panic(KUnsupportedStorageSyncTask, KErrGeneral);
     };
     msg.Complete(KErrNone);
+    NotifyChangeL(observers, msg);
 }
 
 // -----------------------------------------------------------------------------
@@ -124,3 +127,16 @@
     msg.ReadL(KRequestAppIdOffset, appId);
     dataStorage.DeleteActivitiesL(appId());
 }
+
+// -----------------------------------------------------------------------------
+//
+// -----------------------------------------------------------------------------
+//
+void ActivityStorageSyncTask::NotifyChangeL(MActivityTaskStorage& observers,
+                          const RMessage2& msg)
+{
+    const RPointerArray<CActivityTask> &table(observers.StorageData());
+    for (TInt iter(table.Count() - 1); 0 <= iter; --iter) {
+        table[iter]->BroadcastReceivedL(msg);
+    }
+}