Changeset b324a3 for src/Observer/Observable.cpp

Timestamp:

Sep 5, 2013, 2:14:06 PM (12 years ago)

Author:

Frederik Heber <heber@…>

Children:

44f368

Parents:

37d941

git-author:

Frederik Heber <heber@…> (09/05/13 14:09:44)

git-committer:

Frederik Heber <heber@…> (09/05/13 14:14:06)

Message:

Added Graveyard for to-be-destroyed Observables.

• also added Zombie class that wraps an Observable.
• Notification and Observable have new function getNumberOfObservers().
• added unit test for Graveyard.

File:

• src/Observer/Observable.cpp (modified) (5 diffs)

src/Observer/Observable.cpp

@@ -27 +27 @@
 #include "CodePatterns/Observer/Notification.hpp"
 
+//!> This function does nothing with the given Observable
+void NoOp_informer(const Observable *)
+{}
+
+Observable::graveyard_informer_t Observable::noop_informer(&NoOp_informer);
 
 // All infrastructure for the observer-pattern is bundled at a central place
@@ -271 +276 @@
     callTable.erase(const_cast<Observable *>(this));
   }
+  graveyard_informer(this);
 }
 
@@ -293 +299 @@
 #endif
   notification->removeObserver(target);
+  graveyard_informer(this);
 }
 
@@ -311 +318 @@
 }
 
+size_t Observable::getNumberOfObservers() const
+{
+  size_t ObserverCount = 0;
+  {
+    std::map<Observable*,callees_t>::const_iterator callTableiter =
+        callTable.find(const_cast<Observable *>(this));
+    // if not present, then we have zero observers
+    if (callTableiter != callTable.end())
+      ObserverCount += callTableiter->second.size();
+  }
+  {
+    const ChannelMap::const_iterator iter =
+        NotificationChannels.find(const_cast<Observable * const>(this));
+    // if not present, then we have zero observers
+    if (iter != NotificationChannels.end())
+      for (Channels::NotificationTypetoRefMap::const_iterator channeliter = iter->second->ChannelMap.begin();
+          channeliter != iter->second->ChannelMap.end();
+          ++channeliter)
+        ObserverCount += (channeliter->second)->getNumberOfObservers();
+  }
+  return ObserverCount;
+}
+
 /** Handles sub-observables that just got killed
  *  when an sub-observerable dies we usually don't need to do anything
@@ -321 +351 @@
  */
 Observable::Observable(std::string name) :
-  Observer(Observer::BaseConstructor())
+  Observer(Observer::BaseConstructor()),
+  graveyard_informer(noop_informer)
 {
 #ifdef LOG_OBSERVER