MonitorPoint.h

Go to the documentation of this file.

#ifndef MONITOR_POINT_IMPL_H
#define MONITOR_POINT_IMPL_H
/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2009
*
* 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: MonitorPoint.h,v 1.3 2011/05/23 19:31:44 javarias Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* bjeram  2009-02-11  created
*/

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

#include <tao/DynamicInterface/Request.h>

#include "MonitorCollectorS.h"
#include <baciCharacteristicComponentImpl.h>
#include <TMCDBCOMMON_IDLS.h>
namespace TMCDB
{


class MonitorPointBase : public virtual POA_ACS::Callback
{
public:
        MonitorPointBase(const char *propertyName, const ACS::TimeInterval &archivingInterval, TMCDB::DataValueType typeOfData, MonitorBlob& mb);

        virtual ~MonitorPointBase();

        void setPropertySerialNumber(serialNumberTypeSeq& sn);

        ACE_CString &getPropertyName() { return  propertyName_m; }

        CORBA::Boolean negotiate(ACS::TimeInterval, const ACS::CBDescOut&){ return true; }

        virtual void activate(maci::ContainerServices *cs);

        virtual void startMonitoring()=0;

        virtual void stopMonitoring()=0;

        virtual void fillSeq()=0;

        virtual void set_archiving_interval(ACS::TimeInterval time)=0;

        virtual void suppress_archiving()=0;

        virtual void enable_archiving()=0;

protected:

        ACE_CString propertyName_m; 

        ACS::TimeInterval archivingInterval_m; // interval in which the value should be archived (and so monitored)

        double valuePercentTrigger_m; // Delta value percentage a value can change before the value should be archived (and so monitored)

        MonitorBlob& monitorBlob_m; 

        ACS::Monitor_var monitor_m; 

        ACS::OffShoot_var callback_m; 

        unsigned int curSeqPos_m; 

        unsigned int seqLen_m; 

        ACE_Thread_Mutex switchMutex_m; //when we switch the collection sequence

        bool suppressed_m;

        static const unsigned int prealocSeqLen_m = 100; // preallocated length of the seqnece. This is the step that the sequence will grow
        //TBD: do we need also type (as string or ..)?
};//MonitorPointBase

template <class T, class TBLOB_SEQ, class TPROP, class TCB, class TBASE>
class MonitorPoint : public MonitorPointBase, public virtual TCB
{
public:
        MonitorPoint(const char *propertyName, const ACS::TimeInterval &monitoringInterval, ACS::Property* property, TMCDB::DataValueType typeOfData, MonitorBlob& mb);

        ~MonitorPoint();

        void startMonitoring();

        void stopMonitoring();

        void fillSeq();

        void set_archiving_interval(ACS::TimeInterval time);

        void suppress_archiving();

        void enable_archiving();

        void working(T value, const ACSErr::Completion& comp, const ACS::CBDescOut& cbdescout);

        void done(T value, const ACSErr::Completion& comp, const ACS::CBDescOut& cbdescout);
protected:
        TPROP* property_m;
        TBLOB_SEQ blobDataSeq_m;
        TBASE valueTrigger_m; // Delta value describing how much a value can change before the value should be archived (and so monitored)
};//MonitorPoint

template <class T>
T initValue(unsigned int len);
template <>
char* initValue(unsigned int len);
#include "MonitorPoint.i"

};

#endif