activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp
changeset 80 397d00875918
parent 73 4bc7b118b3df
--- a/activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp	Fri May 14 16:10:06 2010 +0300
+++ b/activityfw/activitydatabase/hsactivitydbserver/src/activitystoragesynctask.cpp	Thu May 27 13:11:12 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);
+    }
+}