Changeset b760ac5 for src/Patterns/Observer/Relay.cpp

Timestamp:

Dec 13, 2011, 12:02:21 PM (14 years ago)

Author:

Frederik Heber <heber@…>

Children:

3324cf

Parents:

d85532

git-author:

Frederik Heber <heber@…> (12/02/11 13:13:44)

git-committer:

Frederik Heber <heber@…> (12/13/11 12:02:21)

Message:

Relay can now also relay notifications.

• NOTE: We do not yet notify the Observables, whose update() we combine, when the Relay is destroyed. They have to signOff before by themselves (or by some other means, e.g. be destroyed before.).

File:

• src/Patterns/Observer/Relay.cpp (modified) (4 diffs)

src/Patterns/Observer/Relay.cpp

@@ -24 +24 @@
 #include "Assert.hpp"
 #include "Channels.hpp"
-#include "defs.hpp"
 #include "Notification.hpp"
 
@@ -48 +47 @@
   observerLog().addMessage() << "-- Destroying Relay " << observerLog().getName(this);
 #endif
-}
-
+  // killing subjects is done by Observables' dstor
+}
+
+
+
+/** Sign on an Observer to this Observable.
+ * Puts \a *target into Observable::callTable list.
+ * \param *target Observer
+ * \param priority number in [-20,20]
+ */
+void Relay::signOn(Observer *target, PriorityLevel priority) const
+{
+#ifdef LOG_OBSERVER
+  observerLog().addMessage() << "@@ Signing on " << observerLog().getName(target)
+      << " to "
+      << observerLog().getName(const_cast<Observable *>(static_cast<const Observable * const>(this)));
+#endif
+  bool res = false;
+  callees_t &callees = callTable[const_cast<Observable *>(static_cast<const Observable * const>(this))];
+
+  callees_t::iterator iter;
+  for(iter=callees.begin();iter!=callees.end();++iter){
+    res |= ((*iter).second == target);
+  }
+  if(!res)
+    callees.insert(std::pair<int,Observer*>(priority.level,target));
+}
+
+/** Sign off an Observer from this Observable.
+ * Removes \a *target from Observable::callTable list.
+ * \param *target Observer
+ */
+void Relay::signOff(Observer *target) const
+{
+  ASSERT(callTable.count(const_cast<Observable *>(static_cast<const Observable * const>(this))),
+      "Relay::signOff() - called for an Observable without Observers.");
+#ifdef LOG_OBSERVER
+  observerLog().addMessage() << "** Signing off " << observerLog().getName(target)
+      << " from "
+      << observerLog().getName(const_cast<Observable *>(static_cast<const Observable * const>(this)));
+#endif
+  callees_t &callees = callTable[const_cast<Observable *>(static_cast<const Observable * const>(this))];
+
+  callees_t::iterator iter;
+  callees_t::iterator deliter;
+  for(iter=callees.begin();iter!=callees.end();) {
+    if((*iter).second == target) {
+      callees.erase(iter++);
+    }
+    else {
+      ++iter;
+    }
+  }
+  if(callees.empty()){
+    callTable.erase(const_cast<Observable *>(static_cast<const Observable * const>(this)));
+  }
+}
+
+void Relay::signOn(Observer *target, size_t channelno) const
+{
+  Notification_ptr notification = getChannel(channelno);
+  notification->addObserver(target);
+}
+
+void Relay::signOff(Observer *target, size_t channelno) const
+{
+  Notification_ptr notification = getChannel(channelno);
+  notification->removeObserver(target);
+}
 
 /** Notify all Observers of changes.
@@ -125 +191 @@
       Updater = publisher;
       notifyAll();
+      Updater = NULL;
     }
     else{
@@ -135 +202 @@
 }
 
-//Notification_ptr Relay::getChannel(size_t no) const
-//{
-//  ASSERT(NotificationChannels != NULL,
-//      "Relay::getChannel() - observable has no channels.");
-//  return NotificationChannels->getChannel(no);
-//}
+/** Method for receiving specialized notifications.
+ *
+ * \param *publisher The \a *this we observe.
+ * \param notification type of notification
+ */
+void Relay::recieveNotification(Observable *publisher, Notification_ptr notification)
+{
+  Updater = publisher;
+  const Channels *myChannels = NotificationChannels[const_cast<Observable *>(static_cast<const Observable * const>(this))];
+  ASSERT(myChannels != NULL,
+      "Relay::recieveNotification() - this relay does not have any channels.");
+  const size_t channelno = notification->getChannelNo();
+  Notification_ptr mynotification = myChannels->getChannel(channelno);
+  ASSERT(mynotification != NULL,
+      "Relay::recieveNotification() - this relay does not have a notification no "+toString(channelno)+".");
+  mynotification->notifyAll(Updater);
+  Updater = NULL;
+}
 
 /** Handles sub-observables that just got killed