FramePublisherThread.h

#ifndef CARMA_MONITOR_FRAME_PUBLISHER_THREAD_H
#define CARMA_MONITOR_FRAME_PUBLISHER_THREAD_H

#include <string>
#include <memory>

namespace carma {

namespace corba {
    class Client;
}

namespace monitor {


class FramePublisher;
class SubsystemFrameBuffer;
class MonitorSubsystem;


class FramePublisherThread {
    public:

        FramePublisherThread( MonitorSubsystem &  subsystem, 
                              const std::string & senderName,
                              carma::corba::Client & client );
        
        ~FramePublisherThread( );
        
        void operator()();

    private:

        void publishFrame( SubsystemFrameBuffer & buffer );
        
        ::std::auto_ptr< FramePublisher > dispatcher_;
        
        MonitorSubsystem & subsystem_;
        
        size_t publishCount_;
        size_t nextPublishLogCount_;
};


}  // End namespace monitor
} // End namespace carma


#endif