PipelineHandle.h

Go to the documentation of this file.

#ifndef CARMA_CONTROL_PIPELINE_HANDLE_H
#define CARMA_CONTROL_PIPELINE_HANDLE_H

#include "carma/corba/corba.h"
#include "carma/control/RemoteObjHandleT.h"
#include "carma/control/SubarrayControl.h"
#include "carma/monitor/ControlSubsystem.h"
#include "carma/pipeline/pipelineControl.h"
#include "carma/util/SeqTypedefs.h"

typedef carma::monitor::ControlBandPoints CBP;

namespace carma {
namespace control {


typedef RemoteObjHandleT< pipeline::PipelineControl > 
        PipelineControlRemoteObjHandle;


class PipelineHandle : public PipelineControlRemoteObjHandle {
    public:
        PipelineHandle(
            const std::string&         DOname,
            monitor::ControlSubsystem& controlSubsystem,
            monitor::MonitorSystem&    monitorSystem,
            monitor::MonitorPointBool& reachableMP,
            monitor::MonitorSubsystem& pipelineMonitorSystem,
            const int                  firstAstroBandNo,
            const std::string&         msgPrefix);
    
        virtual ~PipelineHandle();
        
        void setDecimationMode(const DecimationMode decimationMode,
                               const unsigned short astroBandNo);

        void integrate(double intTime, CORBA::Long numInts,
                       double gap, CORBA::Boolean science, 
                       int preferredSeqNo );  

        bool isIntegrationComplete(const monitor::MonitorSystem& monsys,
                                   int monErrLimit);

        void resetTsys(carma::util::SeqShort carmaAntNoSeq); 

    protected:
        virtual monitor::MonitorPointInt&   getSeqNoMP() = 0;
        virtual void decimate(const bool dec, const unsigned short astroBandNo);
        monitor::ControlSubsystem& controlSubsystem_;
        monitor::MonitorSystem&    monitorSystem_;
        const int                  firstAstroBandNo_;
        // Prefix for messages (e.g. "C3Gmax8")        
        const std::string          msgPrefix_;
        std::vector<CBP*>          CBPvector_;
        
    private:
        void keepEndChannels(const bool value, const unsigned short astroBandNo);

        // Sequence number boilerplate
        int nextSequenceNo_;
        int consecutiveErrors_;
        int errLimit_;
 };

// ===========================================================================
// ************** Derived classes for specific pipeline handles **************
// Derived classes for specific pipeline handles
class SLPipelineHandle : public PipelineHandle {
    public:
        SLPipelineHandle(
            monitor::ControlSubsystem&                controlSubsystem,
            monitor::MonitorSystem&                   monitorSystem,
            monitor::ControlSubsystemBase::Reachable& reachableContainer);

        monitor::MonitorPointInt& getSeqNoMP();
};

class WBPipelineHandle : public PipelineHandle {
    public:
        WBPipelineHandle(
            monitor::ControlSubsystem&                controlSubsystem,
            monitor::MonitorSystem&                   monitorSystem,
            monitor::ControlSubsystemBase::Reachable& reachableContainer);

        monitor::MonitorPointInt& getSeqNoMP();
        void decimate(const bool dec, const unsigned short astroBandNo);
};
 
class C3gMax8PipelineHandle : public PipelineHandle {
    public:
        C3gMax8PipelineHandle(
            monitor::ControlSubsystem&                controlSubsystem,
            monitor::MonitorSystem&                   monitorSystem,
            monitor::ControlSubsystemBase::Reachable& reachableContainer);

        monitor::MonitorPointInt& getSeqNoMP();
};

class C3gMax23PipelineHandle : public PipelineHandle {
    public:
        C3gMax23PipelineHandle(
            monitor::ControlSubsystem&                controlSubsystem,
            monitor::MonitorSystem&                   monitorSystem,
            monitor::ControlSubsystemBase::Reachable& reachableContainer);

        monitor::MonitorPointInt& getSeqNoMP();
};

}  // namespace carma::control
}  // namespace carma


#endif