baciPcommonImpl_T.h

Go to the documentation of this file.

#ifndef _baciPcommonImpl_T_H_
#define _baciPcommonImpl_T_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: baciPcommonImpl_T"
*
* who       when        what
* --------  ----------  ----------------------------------------------
* bjeram    07/02/2003  created
*/

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

#include "baciDB.h"
#include <acsutil.h>
#include <baci.h>
#include <baciS.h>
#include <baciCORBA.h>
#include <baciCORBAMem.h>
#include <baciEvent.h>
#include <baciDevIOMem.h>
#include <baciCharacteristicModelImpl.h>
#include <ACSErrTypeCommon.h>
#include <ACSErrTypeDevIO.h>
#include <baciErrTypeProperty.h>
#include <baciErrTypeDevIO.h>

#define HISTORY_SIZE 32


#define ACS_P_T(T, TC) TC, ACS::CB##T, ACS::T##Seq, ACS::T##Seq_out, ACS::Monitor##T, baci::Monitor##T,TC, TC, TC
//, POA_ACS::RW##T 

//#define ACS_P_TL(X) X T, X TCB, X TSeq, X TSeq_out, X TMonitor, X TMonitorImpl, X POA_SK, X TBACIValue 

#define ACS_P_TL T, TCB, TSeq, TSeq_out, TMonitor, TMonitorImpl, TM, TS, TSM, POA_SK

#define ACS_P_C class T, class TCB, class TSeq, class TSeq_out, class TMonitor, class TMonitorImpl, class TM, class TS, class TSM, class POA_SK


namespace baci {


class CheckDevIOValue
{
public:
        CheckDevIOValue(const ACE_CString& n){ propName_m = n;}

        template <class T>
        void checkValue(T value);
private:
        ACE_CString propName_m;
};

template <class T>
class CDBconverter
{
  public:
    static void convertValue(const char *str, T& v)
        {
            std::istringstream is(str);
            (istream&) is >> v;
            if (!is)
                throw cdbErrType::WrongCDBDataTypeExImpl(__FILE__, __LINE__, "CDBconverter::converterValue");
        }
};

template<>
class CDBconverter<ACE_CString>
{
  public:
    static void convertValue(const char *s, ACE_CString& v)
        {
            v = (const char*)s;
        }
};

template<>
class CDBconverter<CORBA::Boolean>
{
  public:
    static void convertValue(const char *str, CORBA::Boolean& v)
        {
            std::istringstream is(str);
            (istream&) is >> v;
            if (!is) {
                        std::istringstream is2(str);
                        (istream&) is2 >> std::boolalpha >> v;
                        if(!is2)
                                throw cdbErrType::WrongCDBDataTypeExImpl(__FILE__, __LINE__, "CDBconverter::converterValue");
                }

        }
};

template<ACS_P_C>
class baci_EXPORT PcommonImpl:  public virtual POA_SK,  
                                public CharacteristicModelImpl,
                                public PropertyImplementator,
                                public ActionImplementator
{


public:
    PcommonImpl(const ACE_CString& name, BACIComponent *component_p, DevIO<TM> *devIO, bool flagdeldevIO);

  virtual ~PcommonImpl();

  /*
   * Property construction status method
   * After contruction of a property, this method will be called
   * to check if construction was successful; if not, monitor will be destroyed by parent
   * @return 0 on success or any other value (value can indicate cause of faulire) on faulure
   */
  virtual int initialization() { return initialization_m; }

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

  BACIProperty* getProperty() const { return property_mp; }

  virtual void publishNow();

   virtual void destroy();

    DevIO<TM>* getDevIO() const { return devIO_mp; }
    
  /***
   * Implementations of async. get_value method
   */
    virtual ActionRequest getValueAction(BACIComponent* component_p, 
                                         int callbackID,
                                         const CBDescIn& descIn, 
                                         BACIValue* value,
                                         Completion& completion, 
                                         CBDescOut& descOut);


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

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

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

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

  /* ----------------------------------------------------------------- */
  /* ---------------------- [ CORBA interface ] ---------------------- */
  /* ----------------------------------------------------------------- */
  
  /* --------------------- [ Property interface ] --------------------- */
    
    virtual char * name ();
    
    virtual char * characteristic_component_name ();

    /*
      already defined bt CharacteristicModelImpl
    virtual CosPropertyService::PropertySet_ptr get_all_characteristics ()
    */
    
    /* ----------------- [ TypelessProperty interface ] ----------------- */
    
    virtual CORBA::Boolean initialize_devio ();
    
    virtual char * description ();
    
    virtual char * format ();
    
    virtual char * units ();
    
    virtual ACS::pattern resolution ();
    
    virtual void publish_now();

    /* -------------------- [ P interface ] -------------------- */
    
    virtual ACS::TimeInterval default_timer_trigger ();
    
    virtual ACS::TimeInterval min_timer_trigger ();
    
    virtual TS default_value ();
    
    virtual T get_sync (ACSErr::Completion_out c);
    
    virtual void get_async (TCB *cb,
                            const ACS::CBDescIn & desc);
    
    virtual CORBA::Long get_history (CORBA::Long n_last_values,
                                     TSeq_out vs,
                                     ACS::TimeSeq_out ts);
        
    virtual TMonitor* create_monitor (TCB*cb,
                                      const ACS::CBDescIn & desc);
        
    virtual TMonitor* create_postponed_monitor (ACS::Time start_time,
                                                TCB *cb,
                                                const ACS::CBDescIn & desc);
  
  protected:
    
    virtual bool readCharacteristics();
  
    /* --------------------- [ History support ] ---------------------- */
    
    void addValueToHistory(ACS::Time time, TM &value);
    

    CheckDevIOValue checkDevIOValue_m;

    BACIProperty* property_mp;
    
    DevIO<TM> *devIO_mp;  
    bool deldevIO_m;
    TM value_m;
    
    int initialization_m;
    
    typedef ActionRequest (PcommonImpl<ACS_P_TL>::*ActionFunction)(BACIComponent* component_p, 
                                                                   int callbackID,
                                                                   const CBDescIn& descIn, 
                                                                   BACIValue* value,
                                                                   ACSErr::Completion& completion, 
                                                                   CBDescOut& descOut);  

  bool destroyed_m;

  CORBA::Object_ptr reference_mp;

  TM historyValue_m[HISTORY_SIZE];

  ACS::Time historyTime_m[HISTORY_SIZE];

  int historyStart_m;

  bool historyTurnaround_m;

 
  bool initializeDevIO_m; 
  // Typeless property
  ACE_CString  description_m;                   
  ACE_CString  format_m;                                
  ACE_CString  units_m;                                 
  ACS::pattern resolution_m;                    

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

  private:
    void operator=(const PcommonImpl&);

    PcommonImpl(const PcommonImpl&);
};

//#include "baciPcommonImpl_T.i"

 }; 

#endif