FrameCollatorThread.h

Go to the documentation of this file.

#ifndef CARMA_MONITOR_FRAME_COLLATOR_THREAD_H
#define CARMA_MONITOR_FRAME_COLLATOR_THREAD_H

#include "carma/monitor/FrameSubscriber.h"

namespace carma  {

namespace corba {
    class Server;
} 

namespace monitor  {


class MonitorSystem;


class FrameCollatorThread {
    public:

        explicit FrameCollatorThread(const ::std::string& subscriberName,
                                     double                delayInS,
                                     bool                  rawMode,
                                     carma::corba::Server& server);
    
        virtual ~FrameCollatorThread( );
        
        void writeMonitorSystemToIPQ(double nextFireTimeMJD,
                                     double delayInSeconds,
                                     int    clearDelayInFrames);

        void setFirstFireTime( double firstFireTimeMJD );
        
        void operator( ) ( );

    private:
        FrameSubscriber * subscriber_;
        carma::corba::Server & server_;
};


} // namespace carma::monitor
} // namespace carma

#endif