TsysStage.h

// $Id: TsysStage.h,v 1.2 2013/05/15 15:23:00 abeard Exp $

#ifndef CARMA_PIPELINE_TSYSSTAGE_H
#define CARMA_PIPELINE_TSYSSTAGE_H

#include "carma/monitor/PipelineCommon.h"
#include "carma/monitor/NoiseStatusCommon.h"
#include "carma/pipeline/pipelineUtils.h"
#include "carma/pipeline/Stage.h"
#include "carma/pipeline/TsysPipelineInfo.h"
#include "carma/util/PthreadRWLock.h"
#include "carma/util/PthreadMutex.h"

namespace carma {

    namespace monitor {
        class AstroSubsystem;
        class PipelineSubsystem;
    }

    namespace correlator {
        namespace lib {
            class CorrelatorData;
        }
    }

    namespace pipeline {

        class TsysStage : public Stage {
        public:

            TsysStage(
                    carma::monitor::PipelineSubsystem & monitor, 
                    const carma::monitor::PipelineMonitorInput & plmi,
                    enum carma::pipeline::PipelineType plType,
                    carma::monitor::AstroSubsystem & astroMonitor ); 

            virtual ~TsysStage();

            void resetTsys( const std::vector< int > & carmaAntNoVec );

            void applyTsysToData( bool apply );

            bool isTsysBeingApplied( ) const;

            void applyFluxCalibrationToData( bool apply );

            bool isFluxBeingApplied( ) const;

            void logCalibration( short astroband );

            const TsysPipelineInfo & getTsysPipelineInfo( ) const;

        private:

            void
                preprocess( carma::correlator::lib::CorrelatorDataPtr cd ); 

            void
                processBand( carma::correlator::lib::CorrelatorBand * cb );

            carma::correlator::lib::CorrelatorDataPtr 
                postprocess( carma::correlator::lib::CorrelatorDataPtr cd );

            void fillMonitorData();

            const carma::monitor::PipelineMonitorInput & plmi_;

            TsysPipelineInfo tsysInfo_;

            bool applyTsys_;
            bool applyFlux_;
            mutable carma::util::PthreadRWLock applyTsysAndFluxRWLock_;

            std::vector< int > resetPendingAntNoVec_;
            mutable carma::util::PthreadMutex resetPendingMutex_;

            carma::monitor::NoiseStatusMonitorPointEnum::NOISESTATUS noiseStatus_;
            bool noiseStatusValid_;

            carma::monitor::PipelineSubsystem & monitorData_;
            carma::monitor::AstroSubsystem & astroMonitor_;

            const enum carma::pipeline::PipelineType plType_;

            short logBandOnce_;

        }; // class TsysStage

    } // namespace pipeline
} // namespace carma
#endif // #ifndef CARMA_PIPELINE_TSYSSTAGE_H