Pipeline.h

Go to the documentation of this file.

#ifndef CARMA_PIPELINE_PIPELINE_H
#define CARMA_PIPELINE_PIPELINE_H

#include "carma/correlator/lib/CorrelatorDataPtr.h"

#include <memory>

namespace carma {
    
    namespace monitor {
        class AstroSubsystem;
        class PipelineSubsystem;
    }

    namespace correlator {
        namespace lib {
            class CorrelatorData;
        } // namespace lib
    } // namespace correlator
    
    namespace pipeline {

        class Stage;

        class Pipeline {
        public:

            explicit 
                Pipeline( carma::monitor::PipelineSubsystem & monitorData,
                        carma::monitor::AstroSubsystem & astroMonitor,
                        long monitorWriteDelayMs,
                        bool autowrite);

            virtual ~Pipeline( );

            void pushStageBack( Stage & stage ); 

            void clear( );

            void processCorrelatorData( 
                    carma::correlator::lib::CorrelatorDataPtr data ) const;

            void incrementMissedMonitorInfo( int by = 1 );

        private:

            Pipeline( const Pipeline & );
            Pipeline & operator=( const Pipeline & );

            class Pimpl;
            const ::std::auto_ptr<Pimpl> pimpl_;

        }; // class Pipeline 

    } // namespace pipeline
} // namespace carma
#endif