CorbaCorrProducer.h

Go to the documentation of this file.

#ifndef CARMA_CORRELATOR_OBSRECORD2_CORBACORRPRODUCER_H
#define CARMA_CORRELATOR_OBSRECORD2_CORBACORRPRODUCER_H


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

#include <memory>
#include <orbsvcs/CosNotificationC.h>
#include <string>


namespace carma {

  namespace corba {
    class Client;
  }

  namespace util {
    class Orb;
  }

namespace correlator {

namespace lib {
    class CorrelatorData;
}

namespace obsRecord2 {


class CorbaCorrProducer {
    public:

        CorbaCorrProducer( const ::std::string & channelName );

        CorbaCorrProducer( carma::util::Orb* localOrb,
                           const ::std::string & channelName );
        
        virtual ~CorbaCorrProducer( );
        
        void sendCorData(
            const carma::correlator::lib::CorrelatorData & cd,
            double *                                       corbaSendMicros,
            size_t *                                       corbaSendBytes );
        
    private:
        // No copying
        CorbaCorrProducer( const CorbaCorrProducer & rhs );
        CorbaCorrProducer & operator=( const CorbaCorrProducer & rhs );
        

        const ::std::string notificationChannelName_;
        
        carma::util::Orb * localOrb_;
        const bool useLocalOrb_;

        CosNotification::StructuredEvent_var event_;
        carma::correlator::obsRecord2::CorData_s cordata_;
        carma::util::PthreadMutex containerMutex_;

        carma::corba::Client * client_;

};


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


#endif