summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJohnny Willemsen <jwillemsen@remedy.nl>2010-02-24 14:44:22 +0000
committerJohnny Willemsen <jwillemsen@remedy.nl>2010-02-24 14:44:22 +0000
commitf0ee4af8b4cfdfb309fb5914c038e546fa79fb06 (patch)
tree91e1b044c9cecd7650b7b19e9e166ec505f0df51
parent0fe8b27281cb8486c5003f569e0dd8abdbb15b3b (diff)
downloadATCD-f0ee4af8b4cfdfb309fb5914c038e546fa79fb06.tar.gz
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.cpp22
-rw-r--r--CIAO/connectors/dds4ccm/impl/ndds/DataReaderStateListener_T.h57
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;
+ };
}
}