callbackmanager.hh

Go to the documentation of this file.

#ifndef __CALLBACK_MANAGER__ 
#define __CALLBACK_MANAGER__

#include <global-types.h>
#include <os.h>

#include <callback.hh>
#include <callbacktimer.hh>
#include <device-corba.hh>
#include <map>
#include <deque>

#include <platform.h>

using namespace std;

namespace DeviceAccess {

  class E_API CallbackManager {
    private:
      // for singleton
      static CallbackManager* _instance;
      CallbackManager() : _devices(),
                          _conPerDev(),
                          _callbacks(),
                          _counter(),
                          _timerActivated(false), 
                          _connectionsMu(), 
                          _tbrMu(), 
                          _cbt(), 
                          _toBeRemoved(){
      }
      CallbackManager(const CallbackManager&){}
      ~CallbackManager(); 
      // Time to wait for new life sign for the connection until error() is called
      static const SLong _LIFESIGN_TIMEOUT = 10;

      // Copy of obeserved devices with nomenclature string
      map<string, Device*> _devices;
      // Actual number of connections for nomenclature string
      map<string, int> _conPerDev;
      // Observed callbacks with asynchID+nomenclature string
      map<string, Callback*> _callbacks;
      // Individual timer for each connection with asynchID+nomenclature string
      map<string, SLong> _counter;
      // TimerActivated
      bool _timerActivated;
      
      // Mutex for the connections list
      omni_mutex _connectionsMu; 
      // Mutex for deleting elements
      omni_mutex _tbrMu;
      // Pointer to timer instance (is omnithread, so it deletes itself)
      CallbackTimer* _cbt;
      // List of connections which should be removed
      deque<string> _toBeRemoved;
      // Removes the connections listed in _toBeRemoved
      void removeConnections();
      // extracts nomenclature from asynchid and nomenclature
      string getNomen(const string& key);
      // removes entry from list with nomenclature keys
      void removeDeviceRelated(const string& nomen);
    public:
      static CallbackManager* getInstance();
      static void destroy();

      void decrementLifeSignCounter();
      

      void resetLifeSignCounter(const AsynchId& id);
      

      void addConnection(Callback* callback, const AsynchId& id, Device& device);
      

      void connectionToBeRemoved(const AsynchId& id);


      void removeConnectionsOfCb(Callback* cb);

  };
}

#endif

---