DtSubjectAnnouncer.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 2020 MAK Technologies, Inc. 
** All rights reserved. 
******************************************************************************/ 
 
 
#pragma once 

#include <vrvCore/DtDe.h> 
#include <vrvCore/DtDisplay.h>
#include <vrvUtil/DtVirtualBaseClass.h> 

#include <vrvUtil/signalslib.h>
#include <boost/bind.hpp>
#include <list>
 
namespace makVrv 
{ 

   class DtDe;
   class DtDisplay;
   class DtDeCommunicator;

   template<class T>
   class DtSubjectAnnouncer : public DtVirtualBaseClass
   { 

   public:

      virtual ~DtSubjectAnnouncer();

      static DtSubjectAnnouncer* findInstance(DtDe& de);

      virtual void activate(T* subject) const;

      virtual void deactivate(T* subject) const;

      boost::signalslib::signal<void (T*)> signal_activate;

      boost::signalslib::signal<void (T*)> signal_deactivate;
      
      typedef std::list<T*> ActivatedList;

      virtual std::list<T*>& activatedList();      

   protected:

      DtSubjectAnnouncer(DtDe& de);

      static DtSubjectAnnouncer* create(DtDe& de);

      virtual void slot_onActivate(T* subject);

      virtual void slot_onDeactivate(T* subject);

   protected:

      ActivatedList myActivatedList;

   }; 

   template<class T>
   DtSubjectAnnouncer<T>::DtSubjectAnnouncer( DtDe& de )
   {
      signal_activate.connect(
         boost::bind(&DtSubjectAnnouncer<T>::slot_onActivate, this, _1));

      signal_deactivate.connect(
         boost::bind(&DtSubjectAnnouncer<T>::slot_onDeactivate, this, _1));
   }

   template<class T>
   DtSubjectAnnouncer<T>::~DtSubjectAnnouncer()
   {
      signal_activate.disconnect(
         boost::bind(&DtSubjectAnnouncer<T>::slot_onActivate, this, _1));

      signal_deactivate.disconnect(
         boost::bind(&DtSubjectAnnouncer<T>::slot_onDeactivate, this, _1));
   }

   template<class T>
      DtSubjectAnnouncer<T>* DtSubjectAnnouncer<T>::findInstance( DtDe& de )
   {
      DtSubjectAnnouncer* announcer = 0;
      announcer = dynamic_cast<DtSubjectAnnouncer<T>*>(de.findInstance(T::className()));
      if(!announcer)
      {
         announcer = create(de);
         de.registerInstance(T::className(),announcer);
      }

      if(!announcer)
      {
         DtTHROW_NEW(DtCorruptedState,"Unable to get an DtSubjectAnnouncer instance.");
      }
      return announcer;      
   }

   template<class T>
      DtSubjectAnnouncer<T>* DtSubjectAnnouncer<T>::create( DtDe& de )
   {
      return new DtSubjectAnnouncer<T>(de);
   }

   template<class T>
      void DtSubjectAnnouncer<T>::activate( T* subject) const
   {
      signal_activate(subject);
   }

   template<class T>
      void DtSubjectAnnouncer<T>::deactivate( T* subject) const
   {
      signal_deactivate(subject);
   }

   template<class T>
      void DtSubjectAnnouncer<T>::slot_onActivate( T* subject)
   {
      myActivatedList.remove(subject);
      myActivatedList.push_back(subject);
   }

   template<class T>
      void DtSubjectAnnouncer<T>::slot_onDeactivate( T* subject)
   {
      myActivatedList.remove(subject);
   }

   template<class T>
      std::list<T*>& DtSubjectAnnouncer<T>::activatedList()      
   {
      return myActivatedList;
   }


   typedef DtSubjectAnnouncer<DtDe> DtDeAnnouncer;
   typedef DtSubjectAnnouncer<DtDeCommunicator> DtDeCommunicatorAnnouncer;
   typedef DtSubjectAnnouncer<DtDisplay> DtDisplayAnnouncer;

}