diff options
author | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-02-24 14:44:22 +0000 |
---|---|---|
committer | Johnny Willemsen <jwillemsen@remedy.nl> | 2010-02-24 14:44:22 +0000 |
commit | f0ee4af8b4cfdfb309fb5914c038e546fa79fb06 (patch) | |
tree | 91e1b044c9cecd7650b7b19e9e166ec505f0df51 | |
parent | 0fe8b27281cb8486c5003f569e0dd8abdbb15b3b (diff) | |
download | ATCD-f0ee4af8b4cfdfb309fb5914c038e546fa79fb06.tar.gz |
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp | 22 | ||||
-rw-r--r-- | CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h | 57 |
2 files changed, 38 insertions, 41 deletions
diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp index 896b446ac58..d3d09ec7ac8 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp +++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp @@ -9,7 +9,7 @@ #include <vector> template <typename DDS_TYPE, typename CCM_TYPE> -CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::DataReaderStateListener_T ( +CIAO::DDS4CCM::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::DataReaderStateListener_T ( typename CCM_TYPE::statelistener_type::_ptr_type listener, ::CCM_DDS::PortStatusListener_ptr port_status_listener, ::CCM_DDS::StateListenerControl_ptr control, @@ -18,21 +18,21 @@ CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::DataReaderSta listener_ (CCM_TYPE::statelistener_type::_duplicate (listener)), control_ (::CCM_DDS::StateListenerControl::_duplicate (control)) { - DDS4CCM_TRACE ("CIAO::DDS4CCM::RTI::DataReaderStateListener_T::DataReaderStateListener_T"); + DDS4CCM_TRACE ("CIAO::DDS4CCM::DataReaderStateListener_T::DataReaderStateListener_T"); } // Implementation skeleton destructor template <typename DDS_TYPE, typename CCM_TYPE> -CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::~DataReaderStateListener_T (void) +CIAO::DDS4CCM::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::~DataReaderStateListener_T (void) { - DDS4CCM_TRACE ("CIAO::DDS4CCM::RTI::DataReaderStateListener_T::~DataReaderStateListener_T"); + DDS4CCM_TRACE ("CIAO::DDS4CCM::DataReaderStateListener_T::~DataReaderStateListener_T"); } template <typename DDS_TYPE, typename CCM_TYPE> void -CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_available(::DDS::DataReader_ptr rdr) +CIAO::DDS4CCM::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_available(::DDS::DataReader_ptr rdr) { - DDS4CCM_TRACE ("CIAO::DDS4CCM::RTI::DataReaderStateListener_T::on_data_available"); + DDS4CCM_TRACE ("CIAO::DDS4CCM::DataReaderStateListener_T::on_data_available"); if (CORBA::is_nil (this->control_.in ()) || this->control_->mode () == ::CCM_DDS::NOT_ENABLED) return; else @@ -56,15 +56,15 @@ CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_avail template <typename DDS_TYPE, typename CCM_TYPE> void -CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_available_i (::DDS::DataReader_ptr rdr) +CIAO::DDS4CCM::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_available_i (::DDS::DataReader_ptr rdr) { - DDS4CCM_TRACE ("CIAO::DDS4CCM::RTI::DataReaderStateListener_T::on_data_available_i"); + DDS4CCM_TRACE ("CIAO::DDS4CCM::DataReaderStateListener_T::on_data_available_i"); if (CORBA::is_nil (this->control_.in ()) || this->control_->mode () == ::CCM_DDS::NOT_ENABLED) return; - ::CIAO::DDS4CCM::RTI::CCM_DDS_DataReader_i* rd = - dynamic_cast < ::CIAO::DDS4CCM::RTI::CCM_DDS_DataReader_i*>(rdr); + ::CIAO::DDS4CCM::CCM_DDS_DataReader_i* rd = + dynamic_cast < ::CIAO::DDS4CCM::CCM_DDS_DataReader_i*>(rdr); if (!rd) { /* In this specific case, this will never fail */ @@ -223,7 +223,7 @@ CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::on_data_avail template <typename DDS_TYPE, typename CCM_TYPE> ::DDS::StatusMask -CIAO::DDS4CCM::RTI::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::get_mask ( +CIAO::DDS4CCM::DataReaderStateListener_T<DDS_TYPE, CCM_TYPE>::get_mask ( typename CCM_TYPE::statelistener_type::_ptr_type listener) { if (!CORBA::is_nil (listener) || CIAO_debug_level >= 10) diff --git a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h index 5fb3e3a42a6..637c79bdf38 100644 --- a/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h +++ b/CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h @@ -17,37 +17,34 @@ namespace CIAO { namespace DDS4CCM { - namespace RTI + template <typename DDS_TYPE, typename CCM_TYPE> + class DataReaderStateListener_T : + public PortStatusListener_T <DDS_TYPE, CCM_TYPE> { - template <typename DDS_TYPE, typename CCM_TYPE> - class DataReaderStateListener_T : - public PortStatusListener_T <DDS_TYPE, CCM_TYPE> - { - public: - /// Constructor - DataReaderStateListener_T ( - typename CCM_TYPE::statelistener_type::_ptr_type listener, - ::CCM_DDS::PortStatusListener_ptr port_status_listener, - ::CCM_DDS::StateListenerControl_ptr control, - ACE_Reactor* reactor); - - /// Destructor - virtual ~DataReaderStateListener_T (void); - - virtual void on_data_available (::DDS::DataReader_ptr rdr); - - static ::DDS::StatusMask get_mask ( - typename CCM_TYPE::statelistener_type::_ptr_type listener); - - void on_data_available_i (::DDS::DataReader_ptr rdr); - - private: - typename CCM_TYPE::statelistener_type::_var_type listener_; - ::CCM_DDS::StateListenerControl_var control_; - - typedef ::CIAO::DDS4CCM::DataReaderStateHandler_T<DDS_TYPE, CCM_TYPE> drsh; - }; - } + public: + /// Constructor + DataReaderStateListener_T ( + typename CCM_TYPE::statelistener_type::_ptr_type listener, + ::CCM_DDS::PortStatusListener_ptr port_status_listener, + ::CCM_DDS::StateListenerControl_ptr control, + ACE_Reactor* reactor); + + /// Destructor + virtual ~DataReaderStateListener_T (void); + + virtual void on_data_available (::DDS::DataReader_ptr rdr); + + static ::DDS::StatusMask get_mask ( + typename CCM_TYPE::statelistener_type::_ptr_type listener); + + void on_data_available_i (::DDS::DataReader_ptr rdr); + + private: + typename CCM_TYPE::statelistener_type::_var_type listener_; + ::CCM_DDS::StateListenerControl_var control_; + + typedef ::CIAO::DDS4CCM::DataReaderStateHandler_T<DDS_TYPE, CCM_TYPE> drsh; + }; } } |