DefaultCorrControl.h

Go to the documentation of this file.

#ifndef CARMA_CORRELATOR_OBSRECORD2_DEFAULTCORRCONTROL_H
#define CARMA_CORRELATOR_OBSRECORD2_DEFAULTCORRCONTROL_H


#include "carma/corba/corba.h"
#include "carma/correlator/obsRecord2/CorDataBase.h"
#include "carma/util/PhaseSwitchingImpl.h"
#include "carma/util/PthreadMutex.h"

#include <memory>
#include <vector>


namespace carma {

namespace corba {
    class Server;
}

namespace correlator {


namespace lib {
    class CorrelatorConfigChecker;
    class CorrelatorData;
}


namespace obsRecord2 {


class BandStatus;

class DefaultCorrControl : public carma::util::PhaseSwitchingImpl
{
    public:
        DefaultCorrControl( int controlPort );

        virtual ~DefaultCorrControl( );

        void startControlServer( carma::corba::Server & server,
                                 const ::std::string & servedObjName,
                                 void (*shutdownCallback)( void * ),
                                 void * shutdownCallbackArg );

        void setBandwidth( obsRecord2::BandWidthType bandwidth,
                           obsRecord2::FpgaModeType  fpgaMode,
                           CORBA::Long               seqNo ,
                           CORBA::Long               astroBandNo);

        void setBandwidthVector(const BandWidthSeq & bandwidth,
                          const FpgaModeSeq  & fpgaMode,
                          CORBA::Long          seqNo ,
                          const carma::util::SeqLong      & astroBandNo );

        void setNoiseSourceState( CORBA::Boolean isOn );


        void setInputDelayTriplets( const DelayTripletSeq & tripletSeq );

        void setWalshColumns(
                const carma::util::SeqLong & cols90,
                const carma::util::SeqLong & cols180,
                CORBA::Long nStates90,
                CORBA::Long nStates180,
                CORBA::Boolean noiseEnabled);

        void setDownconverterSettings(
          CORBA::Double                               freq,
          carma::correlator::obsRecord2::SidebandType sb,
          CORBA::Boolean  bdcEnabled );

        void setDownconverterSettingsVector( const carma::util::SeqFloat & freq );

        void optimizeThresholds( CORBA::Long seqNo );

        void flattenPhases( CORBA::Long seqNo );

        // CARMA boards only; No-op for COBRA hardware boards.
        // @param enable Enable calibration or not
        // @param cache  Whether to cache new calibration spectra.
        // @param count  Integration time for calibration spectra (in frames).
        // @param seqNo  Command sequence number for monitor stream reporting.
        void calibrateSpectra( CORBA::Boolean enable,
                               CORBA::Boolean cache,
                               CORBA::Long count,
                               CORBA::Long seqNo  );

        // @param enable True to enable correlation, false to disable.
        void enableCorrelation( CORBA::Boolean enable );

 protected:

        class CobraClient;
        struct AccumDelaySamps;

        typedef enum {
            INVALID_NOISE_SOURCE_STATE,
            ON_NOISE_SOURCE_STATE,
            OFF_NOISE_SOURCE_STATE
        } NoiseSourceState;

        util::PthreadMutex guard_;

        // Control connection to the correlator
        ::std::auto_ptr< CobraClient > cobraClient_;

        NoiseSourceState   requestedNoiseSourceState_;
        ::std::auto_ptr< AccumDelaySamps > accumDelaySamps_;
};


}  // namespace carma::correlator::obsRecord2
}  // namespace carma::correlator
}  // namespace carma


#endif