baciEvent.h

Go to the documentation of this file.

#ifndef baciEvent_H
#define baciEvent_H

/*******************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2003 
*
*This library is free software; you can redistribute it and/or
*modify it under the terms of the GNU Lesser General Public
*License as published by the Free Software Foundation; either
*version 2.1 of the License, or (at your option) any later version.
*
*This library is distributed in the hope that it will be useful,
*but WITHOUT ANY WARRANTY; without even the implied warranty of
*MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
*Lesser General Public License for more details.
*
*You should have received a copy of the GNU Lesser General Public
*License along with this library; if not, write to the Free Software
*Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
*
* "@(#) $Id: baciEvent.h,v 1.100 2011/09/02 11:39:00 bjeram Exp $"
*
* who       when        what
* --------  ----------  ----------------------------------------------
* msekoran  2001/03/11  modified
*/

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <acsutil.h>
#include <baci.h>
#include <baciS.h>
#include <vector>
#include <baciRecoverableObject.h>

#include <ace/Synch.h>

namespace baci {

// forward
class EventStrategy;

// get rid of this stl!!!
typedef std::vector<EventStrategy*> EventStrategyVector;  

class baci_EXPORT EventDispatcher
{

public:

  EventDispatcher();

  virtual ~EventDispatcher();

  int subscribe(EventStrategy * event);

  int unsubscribe(EventStrategy * event);

  virtual EventStrategyVector& getSubscribers();

  virtual ACE_Recursive_Thread_Mutex& getMutex();

  virtual void suspend() = 0;

  virtual void resume() = 0;

protected:

  virtual void destroyEvents();

  EventStrategyVector events_m;

  int active_m;

  ACE_Recursive_Thread_Mutex mutex_m;

  bool shutdown_m;
  
};

class baci_EXPORT EventStrategy : public virtual PortableServer::RefCountServantBase,
                      public POA_ACS::Subscription,
                      public RecoverableObject
{

public:

  EventStrategy() {}

  EventStrategy(BACIProperty * property, EventDispatcher * eventDispatcher) {
    ACE_UNUSED_ARG(property);
    ACE_UNUSED_ARG(eventDispatcher);
  }
 
  virtual ~EventStrategy() {}

  virtual void check(BACIValue &value,
                     const ACSErr::Completion & c,
                     const ACS::CBDescOut & desc) = 0;

  virtual bool isSuspended() = 0;

  /* ------------------- [ Recoverable interface ] --------------------*/

  virtual int getId(void) = 0;
  virtual const char* getName(void) = 0;
  virtual const char* getObjectState(void) = 0;
  virtual void setObjectState(const char * state) = 0;

  /* ------------------ [ Subscription interface ] -------------------- */ 
  
  virtual void suspend () = 0;
  
  virtual void resume () = 0;
  
  virtual void destroy () = 0;
  
};

 }; 

#endif  /* baciEvent_H */