enumpropRWImpl.h

Go to the documentation of this file.

#ifndef RWENUM_IMPL_H
#define RWENUM_IMPL_H
/*******************************************************************************
* E.S.O. - ACS project
*
* "@(#) $Id: enumpropRWImpl.h,v 1.47 2008/10/09 05:06:11 cparedes Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* bjeram 2004-01-12 changed m_value type from pattern to T
* bjeram 2003-03-14 changed defaultValue_m from ACS::pattern type to type T
* bjeram 2002-11-18 create_monitr returns Monitorpattern (onchange)
* bjeram 2001-11-28 RWEnumImpl derives virtaully out of  PortableServer::RefCountServantBase
* bjeram  05/11/01  created
*/

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

#include <baciDB.h>
#include <logging.h>
#include <baciROpattern.h>
#include <baciRecovery.h>
#include <enumpropAlarm.h>
#include <baciErrTypeProperty.h>
#include <baciCharacteristicModelImpl.h>

#define HISTORY_SIZE 32


#define ACS_ENUM_T(T) T, T##CB, T##Seq, T##Seq_out, T##Alarm
#define ACS_ENUM_C class T, class TCB, class TSeq, class TSeq_out, class TAlarm, class SK

template <ACS_ENUM_C>
class RWEnumImpl: public virtual PortableServer::RefCountServantBase,
                  public SK, 
                  public baci::CharacteristicModelImpl,
                  public baci::PropertyImplementator,
                  public baci::ActionImplementator 
{

public:


  RWEnumImpl(const ACE_CString& name, baci::BACIComponent *cob, DevIO<T> *devIO=0, bool flagdeldevIO=false);
   
  virtual ~RWEnumImpl();

  virtual int initialization() { return initialization_m; }

  CORBA::Object_ptr getCORBAReference() const 
  { 
    return reference_mp;
  }

  baci::BACIProperty* getProperty() const 
  { 
    return property_mp;
  }

    DevIO<T>* getDevIO() const
        {
            return devIO_mp;
        }

   virtual void destroy();

  /***
   * Implementation of async. get_value method
   */
  virtual baci::ActionRequest getValueAction(baci::BACIComponent* cob, const int& callbackID,
                                                        const CBDescIn& descIn, baci::BACIValue* value,
                                                        Completion& completion, CBDescOut& descOut);

  /***
   * Implementation of async. set_value method
   */
  virtual baci::ActionRequest setValueAction(baci::BACIComponent* cob, const int& callbackID,
                               const CBDescIn& descIn, baci::BACIValue* value,
                               Completion& completion, CBDescOut& descOut);

 /* --------------- [ Action implementator interface ] -------------- */

  virtual baci::ActionRequest invokeAction(int function,
                                     baci::BACIComponent* cob, const int& callbackID, 
                                     const CBDescIn& descIn, baci::BACIValue* value, 
                                     Completion& completion, CBDescOut& descOut);

  /* -------------- [ Property implementator interface ] -------------- */

  virtual void getValue(baci::BACIProperty* property,
                        baci::BACIValue* value, 
                        Completion &completion,
                        CBDescOut& descOut);

 /* ----------------- [ Other interface ] ----------------- */

  virtual void setValue(baci::BACIProperty* property,
                        baci::BACIValue* value, 
                        Completion &completion,
                        CBDescOut& descOut);

  /* ----------------------------------------------------------------- */
  /* ---------------------- [ CORBA interface ] ---------------------- */
  /* ----------------------------------------------------------------- */

  /* ------------------ [ CharacteristicModel interface ] ------------------ */

        virtual char * name (
              
          );

    /*
        virtual CORBA::Any * get_characteristic_by_name (
            const char * name
            
          );
        
        virtual ACS::stringSeq * find_characteristic (
            const char * reg_exp
            
          );
    */

  /* --------------------- [ Property interface ] --------------------- */

        virtual char * characteristic_component_name (
              
          );

    /*
        virtual CosPropertyService::PropertySet_ptr get_all_characteristics (
            
          );
    */
  
  /* ----------------- [ TypelessProperty interface ] ----------------- */

        virtual char * description (
              
          );
        
        virtual char * format (
              
          );
        
        virtual char * units (
              
          );
        
        virtual ACS::pattern resolution (
              
          );
        
        virtual CORBA::Boolean initialize_devio (); 
        
  /* -------------------- [ P interface ] -------------------- */

        virtual ACS::TimeInterval default_timer_trigger (
              
          );
        
        virtual ACS::TimeInterval min_timer_trigger (
              
          );
        
        virtual T default_value (
              
          );
                
        virtual T get_sync (
            ACSErr::Completion_out c
            
          );
        
  virtual void get_async (
                          CBpattern* cb,
                          const ACS::CBDescIn & desc
                            
                     );
        
        virtual CORBA::Long get_history (
            CORBA::Long n_last_values,
            TSeq_out vs,
            ACS::TimeSeq_out ts
            
          );
        
        virtual ACS::Monitorpattern* create_monitor (
            CBpattern* cb,
            const ACS::CBDescIn & desc
            
          );
        
     virtual ACS::Monitor* create_postponed_monitor (
            ACS::Time start_time,
            CBpattern* cb,
            const ACS::CBDescIn & desc
            
          );
        
     virtual ACS::stringSeq * statesDescription (
           
      ); 
    
    virtual ACS::ConditionSeq * condition (
          
      );
    
    virtual TSeq * allStates (
          
        );

  /* -------------------- [ RW interface ] -------------------- */
  virtual ACSErr::Completion * set_sync ( T value );
        
  virtual void set_async ( T value,
                           ACS::CBvoid_ptr cb,
                           const ACS::CBDescIn & desc
                           
      ) ;
        
  virtual void set_nonblocking ( T value);

protected:

  virtual bool readCharacteristics();
  
  /* --------------------- [ History support ] ---------------------- */

  void addValueToHistory(ACS::Time time, ACS::pattern value);
private:
  
  T state;
  /*  typedef baci::ActionRequest (RWdouble::*ActionFunction)(baci::BACIComponent* cob, const int& callbackID,
                                                    const CBDescIn& descIn, baci::BACIValue* value,
                                                    Completion& completion, CBDescOut& descOut);
  */
  int initialization_m;
  
  bool destroyed_m;

  CORBA::Object_ptr reference_mp;

  baci::BACIProperty* property_mp;

  T historyValue_m[HISTORY_SIZE];

  ACS::Time historyTime_m[HISTORY_SIZE];

  int historyStart_m;

  bool historyTurnaround_m;


  // Typeless property
  ACE_CString  m_description;                   
  ACE_CString  format_m;                                
  ACE_CString  units_m;                                 
  ACS::pattern m_resolution;                    
  bool initializeDevIO_m;   

  // P
  T     defaultValue_m;                         
  ACS::TimeInterval  defaultTimerTrig_m;                
  ACS::TimeInterval  minTimerTrig_m;                    

  ACS::stringSeq    m_statesDescription;
  ACS::ConditionSeq m_condition;
        
    DevIO<T> *devIO_mp;  
    bool deldevIO_m;
    T m_value;
    int m_enumLength;
};

#include "enumpropRWImpl.i"

#endif